kmsintercom_grpc.pb.go

// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.5.1
// - protoc             (unknown)
// source: kmsintercom/kmsintercom.proto

package kmsintercom

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9

const (
	KmsTalker_InterComCapabilities_FullMethodName            = "/kmsintercom.KmsTalker/InterComCapabilities"
	KmsTalker_SyncQkdBulk_FullMethodName                     = "/kmsintercom.KmsTalker/SyncQkdBulk"
	KmsTalker_SyncKeyIdsForBulk_FullMethodName               = "/kmsintercom.KmsTalker/SyncKeyIdsForBulk"
	KmsTalker_InterComTransportKeyNegotiation_FullMethodName = "/kmsintercom.KmsTalker/InterComTransportKeyNegotiation"
	KmsTalker_KeyForwarding_FullMethodName                   = "/kmsintercom.KmsTalker/KeyForwarding"
	KmsTalker_AckKeyForwarding_FullMethodName                = "/kmsintercom.KmsTalker/AckKeyForwarding"
	KmsTalker_KeyIdNotification_FullMethodName               = "/kmsintercom.KmsTalker/KeyIdNotification"
	KmsTalker_KeyDelivery_FullMethodName                     = "/kmsintercom.KmsTalker/KeyDelivery"
)

// KmsTalkerClient is the client API for KmsTalker service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
//
// should be renamed to InterCom or KMSInterCom
type KmsTalkerClient interface {
	InterComCapabilities(ctx context.Context, in *InterComCapabilitiesRequest, opts ...grpc.CallOption) (*InterComCapabilitiesReply, error)
	SyncQkdBulk(ctx context.Context, in *SyncQkdBulkRequest, opts ...grpc.CallOption) (*SyncQkdBulkResponse, error)
	SyncKeyIdsForBulk(ctx context.Context, in *SyncKeyIdsForBulkRequest, opts ...grpc.CallOption) (*SyncKeyIdsForBulkResponse, error)
	InterComTransportKeyNegotiation(ctx context.Context, in *InterComTransportKeyNegotiationRequest, opts ...grpc.CallOption) (*InterComTransportKeyNegotiationResponse, error)
	KeyForwarding(ctx context.Context, in *KeyForwardingRequest, opts ...grpc.CallOption) (*KeyForwardingResponse, error)
	AckKeyForwarding(ctx context.Context, in *AckKeyForwardingRequest, opts ...grpc.CallOption) (*AckKeyForwardingResponse, error)
	// KeyIDNotification is used for ETSI GS QKD 014
	KeyIdNotification(ctx context.Context, in *KeyIdNotificationRequest, opts ...grpc.CallOption) (*KeyIdNotificationResponse, error)
	KeyDelivery(ctx context.Context, in *KeyDeliveryRequest, opts ...grpc.CallOption) (*KeyDeliveryResponse, error)
}

type kmsTalkerClient struct {
	cc grpc.ClientConnInterface
}

func NewKmsTalkerClient(cc grpc.ClientConnInterface) KmsTalkerClient {
	return &kmsTalkerClient{cc}
}

func (c *kmsTalkerClient) InterComCapabilities(ctx context.Context, in *InterComCapabilitiesRequest, opts ...grpc.CallOption) (*InterComCapabilitiesReply, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(InterComCapabilitiesReply)
	err := c.cc.Invoke(ctx, KmsTalker_InterComCapabilities_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) SyncQkdBulk(ctx context.Context, in *SyncQkdBulkRequest, opts ...grpc.CallOption) (*SyncQkdBulkResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SyncQkdBulkResponse)
	err := c.cc.Invoke(ctx, KmsTalker_SyncQkdBulk_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) SyncKeyIdsForBulk(ctx context.Context, in *SyncKeyIdsForBulkRequest, opts ...grpc.CallOption) (*SyncKeyIdsForBulkResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SyncKeyIdsForBulkResponse)
	err := c.cc.Invoke(ctx, KmsTalker_SyncKeyIdsForBulk_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) InterComTransportKeyNegotiation(ctx context.Context, in *InterComTransportKeyNegotiationRequest, opts ...grpc.CallOption) (*InterComTransportKeyNegotiationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(InterComTransportKeyNegotiationResponse)
	err := c.cc.Invoke(ctx, KmsTalker_InterComTransportKeyNegotiation_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) KeyForwarding(ctx context.Context, in *KeyForwardingRequest, opts ...grpc.CallOption) (*KeyForwardingResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KeyForwardingResponse)
	err := c.cc.Invoke(ctx, KmsTalker_KeyForwarding_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) AckKeyForwarding(ctx context.Context, in *AckKeyForwardingRequest, opts ...grpc.CallOption) (*AckKeyForwardingResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AckKeyForwardingResponse)
	err := c.cc.Invoke(ctx, KmsTalker_AckKeyForwarding_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) KeyIdNotification(ctx context.Context, in *KeyIdNotificationRequest, opts ...grpc.CallOption) (*KeyIdNotificationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KeyIdNotificationResponse)
	err := c.cc.Invoke(ctx, KmsTalker_KeyIdNotification_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *kmsTalkerClient) KeyDelivery(ctx context.Context, in *KeyDeliveryRequest, opts ...grpc.CallOption) (*KeyDeliveryResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KeyDeliveryResponse)
	err := c.cc.Invoke(ctx, KmsTalker_KeyDelivery_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// KmsTalkerServer is the server API for KmsTalker service.
// All implementations must embed UnimplementedKmsTalkerServer
// for forward compatibility.
//
// should be renamed to InterCom or KMSInterCom
type KmsTalkerServer interface {
	InterComCapabilities(context.Context, *InterComCapabilitiesRequest) (*InterComCapabilitiesReply, error)
	SyncQkdBulk(context.Context, *SyncQkdBulkRequest) (*SyncQkdBulkResponse, error)
	SyncKeyIdsForBulk(context.Context, *SyncKeyIdsForBulkRequest) (*SyncKeyIdsForBulkResponse, error)
	InterComTransportKeyNegotiation(context.Context, *InterComTransportKeyNegotiationRequest) (*InterComTransportKeyNegotiationResponse, error)
	KeyForwarding(context.Context, *KeyForwardingRequest) (*KeyForwardingResponse, error)
	AckKeyForwarding(context.Context, *AckKeyForwardingRequest) (*AckKeyForwardingResponse, error)
	// KeyIDNotification is used for ETSI GS QKD 014
	KeyIdNotification(context.Context, *KeyIdNotificationRequest) (*KeyIdNotificationResponse, error)
	KeyDelivery(context.Context, *KeyDeliveryRequest) (*KeyDeliveryResponse, error)
	mustEmbedUnimplementedKmsTalkerServer()
}

// UnimplementedKmsTalkerServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedKmsTalkerServer struct{}

func (UnimplementedKmsTalkerServer) InterComCapabilities(context.Context, *InterComCapabilitiesRequest) (*InterComCapabilitiesReply, error) {
	return nil, status.Errorf(codes.Unimplemented, "method InterComCapabilities not implemented")
}
func (UnimplementedKmsTalkerServer) SyncQkdBulk(context.Context, *SyncQkdBulkRequest) (*SyncQkdBulkResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncQkdBulk not implemented")
}
func (UnimplementedKmsTalkerServer) SyncKeyIdsForBulk(context.Context, *SyncKeyIdsForBulkRequest) (*SyncKeyIdsForBulkResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncKeyIdsForBulk not implemented")
}
func (UnimplementedKmsTalkerServer) InterComTransportKeyNegotiation(context.Context, *InterComTransportKeyNegotiationRequest) (*InterComTransportKeyNegotiationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method InterComTransportKeyNegotiation not implemented")
}
func (UnimplementedKmsTalkerServer) KeyForwarding(context.Context, *KeyForwardingRequest) (*KeyForwardingResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method KeyForwarding not implemented")
}
func (UnimplementedKmsTalkerServer) AckKeyForwarding(context.Context, *AckKeyForwardingRequest) (*AckKeyForwardingResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AckKeyForwarding not implemented")
}
func (UnimplementedKmsTalkerServer) KeyIdNotification(context.Context, *KeyIdNotificationRequest) (*KeyIdNotificationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method KeyIdNotification not implemented")
}
func (UnimplementedKmsTalkerServer) KeyDelivery(context.Context, *KeyDeliveryRequest) (*KeyDeliveryResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method KeyDelivery not implemented")
}
func (UnimplementedKmsTalkerServer) mustEmbedUnimplementedKmsTalkerServer() {}
func (UnimplementedKmsTalkerServer) testEmbeddedByValue()                   {}

// UnsafeKmsTalkerServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to KmsTalkerServer will
// result in compilation errors.
type UnsafeKmsTalkerServer interface {
	mustEmbedUnimplementedKmsTalkerServer()
}

func RegisterKmsTalkerServer(s grpc.ServiceRegistrar, srv KmsTalkerServer) {
	// If the following call pancis, it indicates UnimplementedKmsTalkerServer was
	// embedded by pointer and is nil.  This will cause panics if an
	// unimplemented method is ever invoked, so we test this at initialization
	// time to prevent it from happening at runtime later due to I/O.
	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
		t.testEmbeddedByValue()
	}
	s.RegisterService(&KmsTalker_ServiceDesc, srv)
}

func _KmsTalker_InterComCapabilities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InterComCapabilitiesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).InterComCapabilities(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_InterComCapabilities_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).InterComCapabilities(ctx, req.(*InterComCapabilitiesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_SyncQkdBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncQkdBulkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).SyncQkdBulk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_SyncQkdBulk_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).SyncQkdBulk(ctx, req.(*SyncQkdBulkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_SyncKeyIdsForBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncKeyIdsForBulkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).SyncKeyIdsForBulk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_SyncKeyIdsForBulk_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).SyncKeyIdsForBulk(ctx, req.(*SyncKeyIdsForBulkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_InterComTransportKeyNegotiation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InterComTransportKeyNegotiationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).InterComTransportKeyNegotiation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_InterComTransportKeyNegotiation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).InterComTransportKeyNegotiation(ctx, req.(*InterComTransportKeyNegotiationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_KeyForwarding_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(KeyForwardingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).KeyForwarding(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_KeyForwarding_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).KeyForwarding(ctx, req.(*KeyForwardingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_AckKeyForwarding_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AckKeyForwardingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).AckKeyForwarding(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_AckKeyForwarding_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).AckKeyForwarding(ctx, req.(*AckKeyForwardingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_KeyIdNotification_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(KeyIdNotificationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).KeyIdNotification(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_KeyIdNotification_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).KeyIdNotification(ctx, req.(*KeyIdNotificationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _KmsTalker_KeyDelivery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(KeyDeliveryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(KmsTalkerServer).KeyDelivery(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: KmsTalker_KeyDelivery_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(KmsTalkerServer).KeyDelivery(ctx, req.(*KeyDeliveryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// KmsTalker_ServiceDesc is the grpc.ServiceDesc for KmsTalker service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var KmsTalker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kmsintercom.KmsTalker",
	HandlerType: (*KmsTalkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InterComCapabilities",
			Handler:    _KmsTalker_InterComCapabilities_Handler,
		},
		{
			MethodName: "SyncQkdBulk",
			Handler:    _KmsTalker_SyncQkdBulk_Handler,
		},
		{
			MethodName: "SyncKeyIdsForBulk",
			Handler:    _KmsTalker_SyncKeyIdsForBulk_Handler,
		},
		{
			MethodName: "InterComTransportKeyNegotiation",
			Handler:    _KmsTalker_InterComTransportKeyNegotiation_Handler,
		},
		{
			MethodName: "KeyForwarding",
			Handler:    _KmsTalker_KeyForwarding_Handler,
		},
		{
			MethodName: "AckKeyForwarding",
			Handler:    _KmsTalker_AckKeyForwarding_Handler,
		},
		{
			MethodName: "KeyIdNotification",
			Handler:    _KmsTalker_KeyIdNotification_Handler,
		},
		{
			MethodName: "KeyDelivery",
			Handler:    _KmsTalker_KeyDelivery_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kmsintercom/kmsintercom.proto",
}