Skip to content
Snippets Groups Projects
csbi_grpc.pb.go 9.05 KiB
Newer Older
  • Learn to ignore specific revisions
  • Manuel Kieweg's avatar
    Manuel Kieweg committed
    // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
    
    package csbi
    
    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.
    
    Malte Bauch's avatar
    Malte Bauch committed
    // Requires gRPC-Go v1.32.0 or later.
    const _ = grpc.SupportPackageIsVersion7
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    
    
    // CsbiServiceClient is the client API for CsbiService service.
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    //
    // 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.
    
    type CsbiServiceClient interface {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
    	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
    	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Hello(ctx context.Context, in *Syn, opts ...grpc.CallOption) (*Ack, error)
    
    	CreatePlugin(ctx context.Context, in *CreatePluginRequest, opts ...grpc.CallOption) (CsbiService_CreatePluginClient, error)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    type csbiServiceClient struct {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	cc grpc.ClientConnInterface
    }
    
    
    func NewCsbiServiceClient(cc grpc.ClientConnInterface) CsbiServiceClient {
    	return &csbiServiceClient{cc}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    func (c *csbiServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	out := new(GetResponse)
    
    	err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Get", in, out, opts...)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    
    func (c *csbiServiceClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	out := new(CreateResponse)
    
    	err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Create", in, out, opts...)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    
    func (c *csbiServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	out := new(DeleteResponse)
    
    	err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Delete", in, out, opts...)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    
    func (c *csbiServiceClient) Hello(ctx context.Context, in *Syn, opts ...grpc.CallOption) (*Ack, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	out := new(Ack)
    
    	err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Hello", in, out, opts...)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    
    func (c *csbiServiceClient) CreatePlugin(ctx context.Context, in *CreatePluginRequest, opts ...grpc.CallOption) (CsbiService_CreatePluginClient, error) {
    
    	stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[0], "/gosdn.csbi.CsbiService/CreatePlugin", opts...)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		return nil, err
    	}
    
    	x := &csbiServiceCreatePluginClient{stream}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err := x.ClientStream.SendMsg(in); err != nil {
    		return nil, err
    	}
    	if err := x.ClientStream.CloseSend(); err != nil {
    		return nil, err
    	}
    	return x, nil
    }
    
    
    type CsbiService_CreatePluginClient interface {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Recv() (*Payload, error)
    	grpc.ClientStream
    }
    
    
    type csbiServiceCreatePluginClient struct {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	grpc.ClientStream
    }
    
    
    func (x *csbiServiceCreatePluginClient) Recv() (*Payload, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	m := new(Payload)
    	if err := x.ClientStream.RecvMsg(m); err != nil {
    		return nil, err
    	}
    	return m, nil
    }
    
    
    // CsbiServiceServer is the server API for CsbiService service.
    // All implementations must embed UnimplementedCsbiServiceServer
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    // for forward compatibility
    
    type CsbiServiceServer interface {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Get(context.Context, *GetRequest) (*GetResponse, error)
    	Create(context.Context, *CreateRequest) (*CreateResponse, error)
    	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Hello(context.Context, *Syn) (*Ack, error)
    
    	CreatePlugin(*CreatePluginRequest, CsbiService_CreatePluginServer) error
    	mustEmbedUnimplementedCsbiServiceServer()
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    // UnimplementedCsbiServiceServer must be embedded to have forward compatible implementations.
    type UnimplementedCsbiServiceServer struct {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    func (UnimplementedCsbiServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
    }
    
    func (UnimplementedCsbiServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
    }
    
    func (UnimplementedCsbiServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
    }
    
    func (UnimplementedCsbiServiceServer) Hello(context.Context, *Syn) (*Ack, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return nil, status.Errorf(codes.Unimplemented, "method Hello not implemented")
    }
    
    func (UnimplementedCsbiServiceServer) CreatePlugin(*CreatePluginRequest, CsbiService_CreatePluginServer) error {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return status.Errorf(codes.Unimplemented, "method CreatePlugin not implemented")
    }
    
    func (UnimplementedCsbiServiceServer) mustEmbedUnimplementedCsbiServiceServer() {}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    
    
    // UnsafeCsbiServiceServer may be embedded to opt out of forward compatibility for this service.
    // Use of this interface is not recommended, as added methods to CsbiServiceServer will
    
    Malte Bauch's avatar
    Malte Bauch committed
    // result in compilation errors.
    
    type UnsafeCsbiServiceServer interface {
    	mustEmbedUnimplementedCsbiServiceServer()
    
    func RegisterCsbiServiceServer(s grpc.ServiceRegistrar, srv CsbiServiceServer) {
    	s.RegisterService(&CsbiService_ServiceDesc, srv)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    func _CsbiService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	in := new(GetRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    
    		return srv.(CsbiServiceServer).Get(ctx, in)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    
    		FullMethod: "/gosdn.csbi.CsbiService/Get",
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    
    		return srv.(CsbiServiceServer).Get(ctx, req.(*GetRequest))
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    
    func _CsbiService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	in := new(CreateRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    
    		return srv.(CsbiServiceServer).Create(ctx, in)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    
    		FullMethod: "/gosdn.csbi.CsbiService/Create",
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    
    		return srv.(CsbiServiceServer).Create(ctx, req.(*CreateRequest))
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    
    func _CsbiService_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	in := new(DeleteRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    
    		return srv.(CsbiServiceServer).Delete(ctx, in)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    
    		FullMethod: "/gosdn.csbi.CsbiService/Delete",
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    
    		return srv.(CsbiServiceServer).Delete(ctx, req.(*DeleteRequest))
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    
    func _CsbiService_Hello_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	in := new(Syn)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    
    		return srv.(CsbiServiceServer).Hello(ctx, in)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    
    		FullMethod: "/gosdn.csbi.CsbiService/Hello",
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    
    		return srv.(CsbiServiceServer).Hello(ctx, req.(*Syn))
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    
    func _CsbiService_CreatePlugin_Handler(srv interface{}, stream grpc.ServerStream) error {
    	m := new(CreatePluginRequest)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err := stream.RecvMsg(m); err != nil {
    		return err
    	}
    
    	return srv.(CsbiServiceServer).CreatePlugin(m, &csbiServiceCreatePluginServer{stream})
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    type CsbiService_CreatePluginServer interface {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Send(*Payload) error
    	grpc.ServerStream
    }
    
    
    type csbiServiceCreatePluginServer struct {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	grpc.ServerStream
    }
    
    
    func (x *csbiServiceCreatePluginServer) Send(m *Payload) error {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	return x.ServerStream.SendMsg(m)
    }
    
    
    // CsbiService_ServiceDesc is the grpc.ServiceDesc for CsbiService service.
    
    Malte Bauch's avatar
    Malte Bauch committed
    // It's only intended for direct use with grpc.RegisterService,
    // and not to be introspected or modified (even as a copy)
    
    var CsbiService_ServiceDesc = grpc.ServiceDesc{
    
    	ServiceName: "gosdn.csbi.CsbiService",
    
    	HandlerType: (*CsbiServiceServer)(nil),
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Methods: []grpc.MethodDesc{
    		{
    			MethodName: "Get",
    
    			Handler:    _CsbiService_Get_Handler,
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		},
    		{
    			MethodName: "Create",
    
    			Handler:    _CsbiService_Create_Handler,
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		},
    		{
    			MethodName: "Delete",
    
    			Handler:    _CsbiService_Delete_Handler,
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		},
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		{
    			MethodName: "Hello",
    
    			Handler:    _CsbiService_Hello_Handler,
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		},
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	},
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Streams: []grpc.StreamDesc{
    		{
    			StreamName:    "CreatePlugin",
    
    			Handler:       _CsbiService_CreatePlugin_Handler,
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    			ServerStreams: true,
    		},
    	},
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	Metadata: "gosdn/csbi/csbi.proto",
    }