// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v3.20.1 // source: storer.proto package proto import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" emptypb "google.golang.org/protobuf/types/known/emptypb" ) // 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.32.0 or later. const _ = grpc.SupportPackageIsVersion7 // CRLStorerClient is the client API for CRLStorer 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. type CRLStorerClient interface { UploadCRL(ctx context.Context, opts ...grpc.CallOption) (CRLStorer_UploadCRLClient, error) } type cRLStorerClient struct { cc grpc.ClientConnInterface } func NewCRLStorerClient(cc grpc.ClientConnInterface) CRLStorerClient { return &cRLStorerClient{cc} } func (c *cRLStorerClient) UploadCRL(ctx context.Context, opts ...grpc.CallOption) (CRLStorer_UploadCRLClient, error) { stream, err := c.cc.NewStream(ctx, &CRLStorer_ServiceDesc.Streams[0], "/storer.CRLStorer/UploadCRL", opts...) if err != nil { return nil, err } x := &cRLStorerUploadCRLClient{stream} return x, nil } type CRLStorer_UploadCRLClient interface { Send(*UploadCRLRequest) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream } type cRLStorerUploadCRLClient struct { grpc.ClientStream } func (x *cRLStorerUploadCRLClient) Send(m *UploadCRLRequest) error { return x.ClientStream.SendMsg(m) } func (x *cRLStorerUploadCRLClient) CloseAndRecv() (*emptypb.Empty, error) { if err := x.ClientStream.CloseSend(); err != nil { return nil, err } m := new(emptypb.Empty) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // CRLStorerServer is the server API for CRLStorer service. // All implementations must embed UnimplementedCRLStorerServer // for forward compatibility type CRLStorerServer interface { UploadCRL(CRLStorer_UploadCRLServer) error mustEmbedUnimplementedCRLStorerServer() } // UnimplementedCRLStorerServer must be embedded to have forward compatible implementations. type UnimplementedCRLStorerServer struct { } func (UnimplementedCRLStorerServer) UploadCRL(CRLStorer_UploadCRLServer) error { return status.Errorf(codes.Unimplemented, "method UploadCRL not implemented") } func (UnimplementedCRLStorerServer) mustEmbedUnimplementedCRLStorerServer() {} // UnsafeCRLStorerServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to CRLStorerServer will // result in compilation errors. type UnsafeCRLStorerServer interface { mustEmbedUnimplementedCRLStorerServer() } func RegisterCRLStorerServer(s grpc.ServiceRegistrar, srv CRLStorerServer) { s.RegisterService(&CRLStorer_ServiceDesc, srv) } func _CRLStorer_UploadCRL_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(CRLStorerServer).UploadCRL(&cRLStorerUploadCRLServer{stream}) } type CRLStorer_UploadCRLServer interface { SendAndClose(*emptypb.Empty) error Recv() (*UploadCRLRequest, error) grpc.ServerStream } type cRLStorerUploadCRLServer struct { grpc.ServerStream } func (x *cRLStorerUploadCRLServer) SendAndClose(m *emptypb.Empty) error { return x.ServerStream.SendMsg(m) } func (x *cRLStorerUploadCRLServer) Recv() (*UploadCRLRequest, error) { m := new(UploadCRLRequest) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // CRLStorer_ServiceDesc is the grpc.ServiceDesc for CRLStorer service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var CRLStorer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "storer.CRLStorer", HandlerType: (*CRLStorerServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "UploadCRL", Handler: _CRLStorer_UploadCRL_Handler, ClientStreams: true, }, }, Metadata: "storer.proto", }