ca_grpc.pb.go

Documentation: github.com/letsencrypt/boulder/ca/proto

     1  // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
     2  // versions:
     3  // - protoc-gen-go-grpc v1.2.0
     4  // - protoc             v3.20.1
     5  // source: ca.proto
     6  
     7  package proto
     8  
     9  import (
    10  	context "context"
    11  	proto "github.com/letsencrypt/boulder/core/proto"
    12  	grpc "google.golang.org/grpc"
    13  	codes "google.golang.org/grpc/codes"
    14  	status "google.golang.org/grpc/status"
    15  )
    16  
    17  // This is a compile-time assertion to ensure that this generated file
    18  // is compatible with the grpc package it is being compiled against.
    19  // Requires gRPC-Go v1.32.0 or later.
    20  const _ = grpc.SupportPackageIsVersion7
    21  
    22  // CertificateAuthorityClient is the client API for CertificateAuthority service.
    23  //
    24  // 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.
    25  type CertificateAuthorityClient interface {
    26  	IssuePrecertificate(ctx context.Context, in *IssueCertificateRequest, opts ...grpc.CallOption) (*IssuePrecertificateResponse, error)
    27  	IssueCertificateForPrecertificate(ctx context.Context, in *IssueCertificateForPrecertificateRequest, opts ...grpc.CallOption) (*proto.Certificate, error)
    28  }
    29  
    30  type certificateAuthorityClient struct {
    31  	cc grpc.ClientConnInterface
    32  }
    33  
    34  func NewCertificateAuthorityClient(cc grpc.ClientConnInterface) CertificateAuthorityClient {
    35  	return &certificateAuthorityClient{cc}
    36  }
    37  
    38  func (c *certificateAuthorityClient) IssuePrecertificate(ctx context.Context, in *IssueCertificateRequest, opts ...grpc.CallOption) (*IssuePrecertificateResponse, error) {
    39  	out := new(IssuePrecertificateResponse)
    40  	err := c.cc.Invoke(ctx, "/ca.CertificateAuthority/IssuePrecertificate", in, out, opts...)
    41  	if err != nil {
    42  		return nil, err
    43  	}
    44  	return out, nil
    45  }
    46  
    47  func (c *certificateAuthorityClient) IssueCertificateForPrecertificate(ctx context.Context, in *IssueCertificateForPrecertificateRequest, opts ...grpc.CallOption) (*proto.Certificate, error) {
    48  	out := new(proto.Certificate)
    49  	err := c.cc.Invoke(ctx, "/ca.CertificateAuthority/IssueCertificateForPrecertificate", in, out, opts...)
    50  	if err != nil {
    51  		return nil, err
    52  	}
    53  	return out, nil
    54  }
    55  
    56  // CertificateAuthorityServer is the server API for CertificateAuthority service.
    57  // All implementations must embed UnimplementedCertificateAuthorityServer
    58  // for forward compatibility
    59  type CertificateAuthorityServer interface {
    60  	IssuePrecertificate(context.Context, *IssueCertificateRequest) (*IssuePrecertificateResponse, error)
    61  	IssueCertificateForPrecertificate(context.Context, *IssueCertificateForPrecertificateRequest) (*proto.Certificate, error)
    62  	mustEmbedUnimplementedCertificateAuthorityServer()
    63  }
    64  
    65  // UnimplementedCertificateAuthorityServer must be embedded to have forward compatible implementations.
    66  type UnimplementedCertificateAuthorityServer struct {
    67  }
    68  
    69  func (UnimplementedCertificateAuthorityServer) IssuePrecertificate(context.Context, *IssueCertificateRequest) (*IssuePrecertificateResponse, error) {
    70  	return nil, status.Errorf(codes.Unimplemented, "method IssuePrecertificate not implemented")
    71  }
    72  func (UnimplementedCertificateAuthorityServer) IssueCertificateForPrecertificate(context.Context, *IssueCertificateForPrecertificateRequest) (*proto.Certificate, error) {
    73  	return nil, status.Errorf(codes.Unimplemented, "method IssueCertificateForPrecertificate not implemented")
    74  }
    75  func (UnimplementedCertificateAuthorityServer) mustEmbedUnimplementedCertificateAuthorityServer() {}
    76  
    77  // UnsafeCertificateAuthorityServer may be embedded to opt out of forward compatibility for this service.
    78  // Use of this interface is not recommended, as added methods to CertificateAuthorityServer will
    79  // result in compilation errors.
    80  type UnsafeCertificateAuthorityServer interface {
    81  	mustEmbedUnimplementedCertificateAuthorityServer()
    82  }
    83  
    84  func RegisterCertificateAuthorityServer(s grpc.ServiceRegistrar, srv CertificateAuthorityServer) {
    85  	s.RegisterService(&CertificateAuthority_ServiceDesc, srv)
    86  }
    87  
    88  func _CertificateAuthority_IssuePrecertificate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    89  	in := new(IssueCertificateRequest)
    90  	if err := dec(in); err != nil {
    91  		return nil, err
    92  	}
    93  	if interceptor == nil {
    94  		return srv.(CertificateAuthorityServer).IssuePrecertificate(ctx, in)
    95  	}
    96  	info := &grpc.UnaryServerInfo{
    97  		Server:     srv,
    98  		FullMethod: "/ca.CertificateAuthority/IssuePrecertificate",
    99  	}
   100  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   101  		return srv.(CertificateAuthorityServer).IssuePrecertificate(ctx, req.(*IssueCertificateRequest))
   102  	}
   103  	return interceptor(ctx, in, info, handler)
   104  }
   105  
   106  func _CertificateAuthority_IssueCertificateForPrecertificate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   107  	in := new(IssueCertificateForPrecertificateRequest)
   108  	if err := dec(in); err != nil {
   109  		return nil, err
   110  	}
   111  	if interceptor == nil {
   112  		return srv.(CertificateAuthorityServer).IssueCertificateForPrecertificate(ctx, in)
   113  	}
   114  	info := &grpc.UnaryServerInfo{
   115  		Server:     srv,
   116  		FullMethod: "/ca.CertificateAuthority/IssueCertificateForPrecertificate",
   117  	}
   118  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   119  		return srv.(CertificateAuthorityServer).IssueCertificateForPrecertificate(ctx, req.(*IssueCertificateForPrecertificateRequest))
   120  	}
   121  	return interceptor(ctx, in, info, handler)
   122  }
   123  
   124  // CertificateAuthority_ServiceDesc is the grpc.ServiceDesc for CertificateAuthority service.
   125  // It's only intended for direct use with grpc.RegisterService,
   126  // and not to be introspected or modified (even as a copy)
   127  var CertificateAuthority_ServiceDesc = grpc.ServiceDesc{
   128  	ServiceName: "ca.CertificateAuthority",
   129  	HandlerType: (*CertificateAuthorityServer)(nil),
   130  	Methods: []grpc.MethodDesc{
   131  		{
   132  			MethodName: "IssuePrecertificate",
   133  			Handler:    _CertificateAuthority_IssuePrecertificate_Handler,
   134  		},
   135  		{
   136  			MethodName: "IssueCertificateForPrecertificate",
   137  			Handler:    _CertificateAuthority_IssueCertificateForPrecertificate_Handler,
   138  		},
   139  	},
   140  	Streams:  []grpc.StreamDesc{},
   141  	Metadata: "ca.proto",
   142  }
   143  
   144  // OCSPGeneratorClient is the client API for OCSPGenerator service.
   145  //
   146  // 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.
   147  type OCSPGeneratorClient interface {
   148  	GenerateOCSP(ctx context.Context, in *GenerateOCSPRequest, opts ...grpc.CallOption) (*OCSPResponse, error)
   149  }
   150  
   151  type oCSPGeneratorClient struct {
   152  	cc grpc.ClientConnInterface
   153  }
   154  
   155  func NewOCSPGeneratorClient(cc grpc.ClientConnInterface) OCSPGeneratorClient {
   156  	return &oCSPGeneratorClient{cc}
   157  }
   158  
   159  func (c *oCSPGeneratorClient) GenerateOCSP(ctx context.Context, in *GenerateOCSPRequest, opts ...grpc.CallOption) (*OCSPResponse, error) {
   160  	out := new(OCSPResponse)
   161  	err := c.cc.Invoke(ctx, "/ca.OCSPGenerator/GenerateOCSP", in, out, opts...)
   162  	if err != nil {
   163  		return nil, err
   164  	}
   165  	return out, nil
   166  }
   167  
   168  // OCSPGeneratorServer is the server API for OCSPGenerator service.
   169  // All implementations must embed UnimplementedOCSPGeneratorServer
   170  // for forward compatibility
   171  type OCSPGeneratorServer interface {
   172  	GenerateOCSP(context.Context, *GenerateOCSPRequest) (*OCSPResponse, error)
   173  	mustEmbedUnimplementedOCSPGeneratorServer()
   174  }
   175  
   176  // UnimplementedOCSPGeneratorServer must be embedded to have forward compatible implementations.
   177  type UnimplementedOCSPGeneratorServer struct {
   178  }
   179  
   180  func (UnimplementedOCSPGeneratorServer) GenerateOCSP(context.Context, *GenerateOCSPRequest) (*OCSPResponse, error) {
   181  	return nil, status.Errorf(codes.Unimplemented, "method GenerateOCSP not implemented")
   182  }
   183  func (UnimplementedOCSPGeneratorServer) mustEmbedUnimplementedOCSPGeneratorServer() {}
   184  
   185  // UnsafeOCSPGeneratorServer may be embedded to opt out of forward compatibility for this service.
   186  // Use of this interface is not recommended, as added methods to OCSPGeneratorServer will
   187  // result in compilation errors.
   188  type UnsafeOCSPGeneratorServer interface {
   189  	mustEmbedUnimplementedOCSPGeneratorServer()
   190  }
   191  
   192  func RegisterOCSPGeneratorServer(s grpc.ServiceRegistrar, srv OCSPGeneratorServer) {
   193  	s.RegisterService(&OCSPGenerator_ServiceDesc, srv)
   194  }
   195  
   196  func _OCSPGenerator_GenerateOCSP_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   197  	in := new(GenerateOCSPRequest)
   198  	if err := dec(in); err != nil {
   199  		return nil, err
   200  	}
   201  	if interceptor == nil {
   202  		return srv.(OCSPGeneratorServer).GenerateOCSP(ctx, in)
   203  	}
   204  	info := &grpc.UnaryServerInfo{
   205  		Server:     srv,
   206  		FullMethod: "/ca.OCSPGenerator/GenerateOCSP",
   207  	}
   208  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   209  		return srv.(OCSPGeneratorServer).GenerateOCSP(ctx, req.(*GenerateOCSPRequest))
   210  	}
   211  	return interceptor(ctx, in, info, handler)
   212  }
   213  
   214  // OCSPGenerator_ServiceDesc is the grpc.ServiceDesc for OCSPGenerator service.
   215  // It's only intended for direct use with grpc.RegisterService,
   216  // and not to be introspected or modified (even as a copy)
   217  var OCSPGenerator_ServiceDesc = grpc.ServiceDesc{
   218  	ServiceName: "ca.OCSPGenerator",
   219  	HandlerType: (*OCSPGeneratorServer)(nil),
   220  	Methods: []grpc.MethodDesc{
   221  		{
   222  			MethodName: "GenerateOCSP",
   223  			Handler:    _OCSPGenerator_GenerateOCSP_Handler,
   224  		},
   225  	},
   226  	Streams:  []grpc.StreamDesc{},
   227  	Metadata: "ca.proto",
   228  }
   229  
   230  // CRLGeneratorClient is the client API for CRLGenerator service.
   231  //
   232  // 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.
   233  type CRLGeneratorClient interface {
   234  	GenerateCRL(ctx context.Context, opts ...grpc.CallOption) (CRLGenerator_GenerateCRLClient, error)
   235  }
   236  
   237  type cRLGeneratorClient struct {
   238  	cc grpc.ClientConnInterface
   239  }
   240  
   241  func NewCRLGeneratorClient(cc grpc.ClientConnInterface) CRLGeneratorClient {
   242  	return &cRLGeneratorClient{cc}
   243  }
   244  
   245  func (c *cRLGeneratorClient) GenerateCRL(ctx context.Context, opts ...grpc.CallOption) (CRLGenerator_GenerateCRLClient, error) {
   246  	stream, err := c.cc.NewStream(ctx, &CRLGenerator_ServiceDesc.Streams[0], "/ca.CRLGenerator/GenerateCRL", opts...)
   247  	if err != nil {
   248  		return nil, err
   249  	}
   250  	x := &cRLGeneratorGenerateCRLClient{stream}
   251  	return x, nil
   252  }
   253  
   254  type CRLGenerator_GenerateCRLClient interface {
   255  	Send(*GenerateCRLRequest) error
   256  	Recv() (*GenerateCRLResponse, error)
   257  	grpc.ClientStream
   258  }
   259  
   260  type cRLGeneratorGenerateCRLClient struct {
   261  	grpc.ClientStream
   262  }
   263  
   264  func (x *cRLGeneratorGenerateCRLClient) Send(m *GenerateCRLRequest) error {
   265  	return x.ClientStream.SendMsg(m)
   266  }
   267  
   268  func (x *cRLGeneratorGenerateCRLClient) Recv() (*GenerateCRLResponse, error) {
   269  	m := new(GenerateCRLResponse)
   270  	if err := x.ClientStream.RecvMsg(m); err != nil {
   271  		return nil, err
   272  	}
   273  	return m, nil
   274  }
   275  
   276  // CRLGeneratorServer is the server API for CRLGenerator service.
   277  // All implementations must embed UnimplementedCRLGeneratorServer
   278  // for forward compatibility
   279  type CRLGeneratorServer interface {
   280  	GenerateCRL(CRLGenerator_GenerateCRLServer) error
   281  	mustEmbedUnimplementedCRLGeneratorServer()
   282  }
   283  
   284  // UnimplementedCRLGeneratorServer must be embedded to have forward compatible implementations.
   285  type UnimplementedCRLGeneratorServer struct {
   286  }
   287  
   288  func (UnimplementedCRLGeneratorServer) GenerateCRL(CRLGenerator_GenerateCRLServer) error {
   289  	return status.Errorf(codes.Unimplemented, "method GenerateCRL not implemented")
   290  }
   291  func (UnimplementedCRLGeneratorServer) mustEmbedUnimplementedCRLGeneratorServer() {}
   292  
   293  // UnsafeCRLGeneratorServer may be embedded to opt out of forward compatibility for this service.
   294  // Use of this interface is not recommended, as added methods to CRLGeneratorServer will
   295  // result in compilation errors.
   296  type UnsafeCRLGeneratorServer interface {
   297  	mustEmbedUnimplementedCRLGeneratorServer()
   298  }
   299  
   300  func RegisterCRLGeneratorServer(s grpc.ServiceRegistrar, srv CRLGeneratorServer) {
   301  	s.RegisterService(&CRLGenerator_ServiceDesc, srv)
   302  }
   303  
   304  func _CRLGenerator_GenerateCRL_Handler(srv interface{}, stream grpc.ServerStream) error {
   305  	return srv.(CRLGeneratorServer).GenerateCRL(&cRLGeneratorGenerateCRLServer{stream})
   306  }
   307  
   308  type CRLGenerator_GenerateCRLServer interface {
   309  	Send(*GenerateCRLResponse) error
   310  	Recv() (*GenerateCRLRequest, error)
   311  	grpc.ServerStream
   312  }
   313  
   314  type cRLGeneratorGenerateCRLServer struct {
   315  	grpc.ServerStream
   316  }
   317  
   318  func (x *cRLGeneratorGenerateCRLServer) Send(m *GenerateCRLResponse) error {
   319  	return x.ServerStream.SendMsg(m)
   320  }
   321  
   322  func (x *cRLGeneratorGenerateCRLServer) Recv() (*GenerateCRLRequest, error) {
   323  	m := new(GenerateCRLRequest)
   324  	if err := x.ServerStream.RecvMsg(m); err != nil {
   325  		return nil, err
   326  	}
   327  	return m, nil
   328  }
   329  
   330  // CRLGenerator_ServiceDesc is the grpc.ServiceDesc for CRLGenerator service.
   331  // It's only intended for direct use with grpc.RegisterService,
   332  // and not to be introspected or modified (even as a copy)
   333  var CRLGenerator_ServiceDesc = grpc.ServiceDesc{
   334  	ServiceName: "ca.CRLGenerator",
   335  	HandlerType: (*CRLGeneratorServer)(nil),
   336  	Methods:     []grpc.MethodDesc{},
   337  	Streams: []grpc.StreamDesc{
   338  		{
   339  			StreamName:    "GenerateCRL",
   340  			Handler:       _CRLGenerator_GenerateCRL_Handler,
   341  			ServerStreams: true,
   342  			ClientStreams: true,
   343  		},
   344  	},
   345  	Metadata: "ca.proto",
   346  }
   347
View as plain text