stream_grpc.pb.go

Documentation: github.com/grpc-ecosystem/grpc-gateway/v2/examples/internal/proto/examplepb

     1  // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
     2  // versions:
     3  // - protoc-gen-go-grpc v1.2.0
     4  // - protoc             (unknown)
     5  // source: examples/internal/proto/examplepb/stream.proto
     6  
     7  package examplepb
     8  
     9  import (
    10  	context "context"
    11  	sub "github.com/grpc-ecosystem/grpc-gateway/v2/examples/internal/proto/sub"
    12  	httpbody "google.golang.org/genproto/googleapis/api/httpbody"
    13  	grpc "google.golang.org/grpc"
    14  	codes "google.golang.org/grpc/codes"
    15  	status "google.golang.org/grpc/status"
    16  	emptypb "google.golang.org/protobuf/types/known/emptypb"
    17  )
    18  
    19  // This is a compile-time assertion to ensure that this generated file
    20  // is compatible with the grpc package it is being compiled against.
    21  // Requires gRPC-Go v1.32.0 or later.
    22  const _ = grpc.SupportPackageIsVersion7
    23  
    24  // StreamServiceClient is the client API for StreamService service.
    25  //
    26  // 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.
    27  type StreamServiceClient interface {
    28  	BulkCreate(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkCreateClient, error)
    29  	List(ctx context.Context, in *Options, opts ...grpc.CallOption) (StreamService_ListClient, error)
    30  	BulkEcho(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkEchoClient, error)
    31  	Download(ctx context.Context, in *Options, opts ...grpc.CallOption) (StreamService_DownloadClient, error)
    32  }
    33  
    34  type streamServiceClient struct {
    35  	cc grpc.ClientConnInterface
    36  }
    37  
    38  func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient {
    39  	return &streamServiceClient{cc}
    40  }
    41  
    42  func (c *streamServiceClient) BulkCreate(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkCreateClient, error) {
    43  	stream, err := c.cc.NewStream(ctx, &StreamService_ServiceDesc.Streams[0], "/grpc.gateway.examples.internal.proto.examplepb.StreamService/BulkCreate", opts...)
    44  	if err != nil {
    45  		return nil, err
    46  	}
    47  	x := &streamServiceBulkCreateClient{stream}
    48  	return x, nil
    49  }
    50  
    51  type StreamService_BulkCreateClient interface {
    52  	Send(*ABitOfEverything) error
    53  	CloseAndRecv() (*emptypb.Empty, error)
    54  	grpc.ClientStream
    55  }
    56  
    57  type streamServiceBulkCreateClient struct {
    58  	grpc.ClientStream
    59  }
    60  
    61  func (x *streamServiceBulkCreateClient) Send(m *ABitOfEverything) error {
    62  	return x.ClientStream.SendMsg(m)
    63  }
    64  
    65  func (x *streamServiceBulkCreateClient) CloseAndRecv() (*emptypb.Empty, error) {
    66  	if err := x.ClientStream.CloseSend(); err != nil {
    67  		return nil, err
    68  	}
    69  	m := new(emptypb.Empty)
    70  	if err := x.ClientStream.RecvMsg(m); err != nil {
    71  		return nil, err
    72  	}
    73  	return m, nil
    74  }
    75  
    76  func (c *streamServiceClient) List(ctx context.Context, in *Options, opts ...grpc.CallOption) (StreamService_ListClient, error) {
    77  	stream, err := c.cc.NewStream(ctx, &StreamService_ServiceDesc.Streams[1], "/grpc.gateway.examples.internal.proto.examplepb.StreamService/List", opts...)
    78  	if err != nil {
    79  		return nil, err
    80  	}
    81  	x := &streamServiceListClient{stream}
    82  	if err := x.ClientStream.SendMsg(in); err != nil {
    83  		return nil, err
    84  	}
    85  	if err := x.ClientStream.CloseSend(); err != nil {
    86  		return nil, err
    87  	}
    88  	return x, nil
    89  }
    90  
    91  type StreamService_ListClient interface {
    92  	Recv() (*ABitOfEverything, error)
    93  	grpc.ClientStream
    94  }
    95  
    96  type streamServiceListClient struct {
    97  	grpc.ClientStream
    98  }
    99  
   100  func (x *streamServiceListClient) Recv() (*ABitOfEverything, error) {
   101  	m := new(ABitOfEverything)
   102  	if err := x.ClientStream.RecvMsg(m); err != nil {
   103  		return nil, err
   104  	}
   105  	return m, nil
   106  }
   107  
   108  func (c *streamServiceClient) BulkEcho(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkEchoClient, error) {
   109  	stream, err := c.cc.NewStream(ctx, &StreamService_ServiceDesc.Streams[2], "/grpc.gateway.examples.internal.proto.examplepb.StreamService/BulkEcho", opts...)
   110  	if err != nil {
   111  		return nil, err
   112  	}
   113  	x := &streamServiceBulkEchoClient{stream}
   114  	return x, nil
   115  }
   116  
   117  type StreamService_BulkEchoClient interface {
   118  	Send(*sub.StringMessage) error
   119  	Recv() (*sub.StringMessage, error)
   120  	grpc.ClientStream
   121  }
   122  
   123  type streamServiceBulkEchoClient struct {
   124  	grpc.ClientStream
   125  }
   126  
   127  func (x *streamServiceBulkEchoClient) Send(m *sub.StringMessage) error {
   128  	return x.ClientStream.SendMsg(m)
   129  }
   130  
   131  func (x *streamServiceBulkEchoClient) Recv() (*sub.StringMessage, error) {
   132  	m := new(sub.StringMessage)
   133  	if err := x.ClientStream.RecvMsg(m); err != nil {
   134  		return nil, err
   135  	}
   136  	return m, nil
   137  }
   138  
   139  func (c *streamServiceClient) Download(ctx context.Context, in *Options, opts ...grpc.CallOption) (StreamService_DownloadClient, error) {
   140  	stream, err := c.cc.NewStream(ctx, &StreamService_ServiceDesc.Streams[3], "/grpc.gateway.examples.internal.proto.examplepb.StreamService/Download", opts...)
   141  	if err != nil {
   142  		return nil, err
   143  	}
   144  	x := &streamServiceDownloadClient{stream}
   145  	if err := x.ClientStream.SendMsg(in); err != nil {
   146  		return nil, err
   147  	}
   148  	if err := x.ClientStream.CloseSend(); err != nil {
   149  		return nil, err
   150  	}
   151  	return x, nil
   152  }
   153  
   154  type StreamService_DownloadClient interface {
   155  	Recv() (*httpbody.HttpBody, error)
   156  	grpc.ClientStream
   157  }
   158  
   159  type streamServiceDownloadClient struct {
   160  	grpc.ClientStream
   161  }
   162  
   163  func (x *streamServiceDownloadClient) Recv() (*httpbody.HttpBody, error) {
   164  	m := new(httpbody.HttpBody)
   165  	if err := x.ClientStream.RecvMsg(m); err != nil {
   166  		return nil, err
   167  	}
   168  	return m, nil
   169  }
   170  
   171  // StreamServiceServer is the server API for StreamService service.
   172  // All implementations should embed UnimplementedStreamServiceServer
   173  // for forward compatibility
   174  type StreamServiceServer interface {
   175  	BulkCreate(StreamService_BulkCreateServer) error
   176  	List(*Options, StreamService_ListServer) error
   177  	BulkEcho(StreamService_BulkEchoServer) error
   178  	Download(*Options, StreamService_DownloadServer) error
   179  }
   180  
   181  // UnimplementedStreamServiceServer should be embedded to have forward compatible implementations.
   182  type UnimplementedStreamServiceServer struct {
   183  }
   184  
   185  func (UnimplementedStreamServiceServer) BulkCreate(StreamService_BulkCreateServer) error {
   186  	return status.Errorf(codes.Unimplemented, "method BulkCreate not implemented")
   187  }
   188  func (UnimplementedStreamServiceServer) List(*Options, StreamService_ListServer) error {
   189  	return status.Errorf(codes.Unimplemented, "method List not implemented")
   190  }
   191  func (UnimplementedStreamServiceServer) BulkEcho(StreamService_BulkEchoServer) error {
   192  	return status.Errorf(codes.Unimplemented, "method BulkEcho not implemented")
   193  }
   194  func (UnimplementedStreamServiceServer) Download(*Options, StreamService_DownloadServer) error {
   195  	return status.Errorf(codes.Unimplemented, "method Download not implemented")
   196  }
   197  
   198  // UnsafeStreamServiceServer may be embedded to opt out of forward compatibility for this service.
   199  // Use of this interface is not recommended, as added methods to StreamServiceServer will
   200  // result in compilation errors.
   201  type UnsafeStreamServiceServer interface {
   202  	mustEmbedUnimplementedStreamServiceServer()
   203  }
   204  
   205  func RegisterStreamServiceServer(s grpc.ServiceRegistrar, srv StreamServiceServer) {
   206  	s.RegisterService(&StreamService_ServiceDesc, srv)
   207  }
   208  
   209  func _StreamService_BulkCreate_Handler(srv interface{}, stream grpc.ServerStream) error {
   210  	return srv.(StreamServiceServer).BulkCreate(&streamServiceBulkCreateServer{stream})
   211  }
   212  
   213  type StreamService_BulkCreateServer interface {
   214  	SendAndClose(*emptypb.Empty) error
   215  	Recv() (*ABitOfEverything, error)
   216  	grpc.ServerStream
   217  }
   218  
   219  type streamServiceBulkCreateServer struct {
   220  	grpc.ServerStream
   221  }
   222  
   223  func (x *streamServiceBulkCreateServer) SendAndClose(m *emptypb.Empty) error {
   224  	return x.ServerStream.SendMsg(m)
   225  }
   226  
   227  func (x *streamServiceBulkCreateServer) Recv() (*ABitOfEverything, error) {
   228  	m := new(ABitOfEverything)
   229  	if err := x.ServerStream.RecvMsg(m); err != nil {
   230  		return nil, err
   231  	}
   232  	return m, nil
   233  }
   234  
   235  func _StreamService_List_Handler(srv interface{}, stream grpc.ServerStream) error {
   236  	m := new(Options)
   237  	if err := stream.RecvMsg(m); err != nil {
   238  		return err
   239  	}
   240  	return srv.(StreamServiceServer).List(m, &streamServiceListServer{stream})
   241  }
   242  
   243  type StreamService_ListServer interface {
   244  	Send(*ABitOfEverything) error
   245  	grpc.ServerStream
   246  }
   247  
   248  type streamServiceListServer struct {
   249  	grpc.ServerStream
   250  }
   251  
   252  func (x *streamServiceListServer) Send(m *ABitOfEverything) error {
   253  	return x.ServerStream.SendMsg(m)
   254  }
   255  
   256  func _StreamService_BulkEcho_Handler(srv interface{}, stream grpc.ServerStream) error {
   257  	return srv.(StreamServiceServer).BulkEcho(&streamServiceBulkEchoServer{stream})
   258  }
   259  
   260  type StreamService_BulkEchoServer interface {
   261  	Send(*sub.StringMessage) error
   262  	Recv() (*sub.StringMessage, error)
   263  	grpc.ServerStream
   264  }
   265  
   266  type streamServiceBulkEchoServer struct {
   267  	grpc.ServerStream
   268  }
   269  
   270  func (x *streamServiceBulkEchoServer) Send(m *sub.StringMessage) error {
   271  	return x.ServerStream.SendMsg(m)
   272  }
   273  
   274  func (x *streamServiceBulkEchoServer) Recv() (*sub.StringMessage, error) {
   275  	m := new(sub.StringMessage)
   276  	if err := x.ServerStream.RecvMsg(m); err != nil {
   277  		return nil, err
   278  	}
   279  	return m, nil
   280  }
   281  
   282  func _StreamService_Download_Handler(srv interface{}, stream grpc.ServerStream) error {
   283  	m := new(Options)
   284  	if err := stream.RecvMsg(m); err != nil {
   285  		return err
   286  	}
   287  	return srv.(StreamServiceServer).Download(m, &streamServiceDownloadServer{stream})
   288  }
   289  
   290  type StreamService_DownloadServer interface {
   291  	Send(*httpbody.HttpBody) error
   292  	grpc.ServerStream
   293  }
   294  
   295  type streamServiceDownloadServer struct {
   296  	grpc.ServerStream
   297  }
   298  
   299  func (x *streamServiceDownloadServer) Send(m *httpbody.HttpBody) error {
   300  	return x.ServerStream.SendMsg(m)
   301  }
   302  
   303  // StreamService_ServiceDesc is the grpc.ServiceDesc for StreamService service.
   304  // It's only intended for direct use with grpc.RegisterService,
   305  // and not to be introspected or modified (even as a copy)
   306  var StreamService_ServiceDesc = grpc.ServiceDesc{
   307  	ServiceName: "grpc.gateway.examples.internal.proto.examplepb.StreamService",
   308  	HandlerType: (*StreamServiceServer)(nil),
   309  	Methods:     []grpc.MethodDesc{},
   310  	Streams: []grpc.StreamDesc{
   311  		{
   312  			StreamName:    "BulkCreate",
   313  			Handler:       _StreamService_BulkCreate_Handler,
   314  			ClientStreams: true,
   315  		},
   316  		{
   317  			StreamName:    "List",
   318  			Handler:       _StreamService_List_Handler,
   319  			ServerStreams: true,
   320  		},
   321  		{
   322  			StreamName:    "BulkEcho",
   323  			Handler:       _StreamService_BulkEcho_Handler,
   324  			ServerStreams: true,
   325  			ClientStreams: true,
   326  		},
   327  		{
   328  			StreamName:    "Download",
   329  			Handler:       _StreamService_Download_Handler,
   330  			ServerStreams: true,
   331  		},
   332  	},
   333  	Metadata: "examples/internal/proto/examplepb/stream.proto",
   334  }
   335
View as plain text