stream.pb.go

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

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // source: examples/internal/proto/examplepb/stream.proto
     3  
     4  package examplepb
     5  
     6  import (
     7  	context "context"
     8  	fmt "fmt"
     9  	proto "github.com/golang/protobuf/proto"
    10  	empty "github.com/golang/protobuf/ptypes/empty"
    11  	sub "github.com/grpc-ecosystem/grpc-gateway/examples/internal/proto/sub"
    12  	_ "google.golang.org/genproto/googleapis/api/annotations"
    13  	grpc "google.golang.org/grpc"
    14  	codes "google.golang.org/grpc/codes"
    15  	status "google.golang.org/grpc/status"
    16  	math "math"
    17  )
    18  
    19  // Reference imports to suppress errors if they are not otherwise used.
    20  var _ = proto.Marshal
    21  var _ = fmt.Errorf
    22  var _ = math.Inf
    23  
    24  // This is a compile-time assertion to ensure that this generated file
    25  // is compatible with the proto package it is being compiled against.
    26  // A compilation error at this line likely means your copy of the
    27  // proto package needs to be updated.
    28  const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
    29  
    30  func init() {
    31  	proto.RegisterFile("examples/internal/proto/examplepb/stream.proto", fileDescriptor_cc5dba844cf4f624)
    32  }
    33  
    34  var fileDescriptor_cc5dba844cf4f624 = []byte{
    35  	// 328 bytes of a gzipped FileDescriptorProto
    36  	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x90, 0xb1, 0x4e, 0xeb, 0x30,
    37  	0x14, 0x86, 0xe5, 0x7b, 0x11, 0x82, 0x20, 0x16, 0x0f, 0x0c, 0x01, 0x09, 0x51, 0x21, 0xd1, 0x32,
    38  	0xd8, 0x2d, 0x6c, 0x65, 0xa2, 0xa8, 0x1b, 0x88, 0xa1, 0x1b, 0x4b, 0x65, 0x47, 0xa7, 0xae, 0xd5,
    39  	0xc4, 0x8e, 0xec, 0x93, 0x42, 0x57, 0x24, 0x9e, 0xa0, 0xcf, 0xc0, 0x13, 0x21, 0xde, 0x80, 0x07,
    40  	0x41, 0x75, 0xd2, 0x4c, 0x54, 0x29, 0x62, 0xcc, 0x39, 0xf9, 0x8e, 0xff, 0xef, 0x8f, 0x18, 0xbc,
    41  	0x88, 0x2c, 0x4f, 0xc1, 0x73, 0x6d, 0x10, 0x9c, 0x11, 0x29, 0xcf, 0x9d, 0x45, 0xcb, 0xab, 0x79,
    42  	0x2e, 0xb9, 0x47, 0x07, 0x22, 0x63, 0x61, 0x4c, 0xdb, 0xca, 0xe5, 0x09, 0x53, 0x02, 0xe1, 0x59,
    43  	0x2c, 0x6a, 0x98, 0xad, 0x61, 0x56, 0x63, 0xf1, 0x89, 0xb2, 0x56, 0xa5, 0xc0, 0x45, 0xae, 0xb9,
    44  	0x30, 0xc6, 0xa2, 0x40, 0x6d, 0x8d, 0x2f, 0xef, 0xc4, 0xc7, 0xd5, 0x36, 0x7c, 0xc9, 0x62, 0xc2,
    45  	0x21, 0xcb, 0x71, 0x51, 0x2d, 0x6f, 0x9a, 0x43, 0x89, 0xb1, 0xd4, 0x38, 0xb6, 0x93, 0x31, 0xcc,
    46  	0xc1, 0x2d, 0x70, 0xaa, 0x8d, 0xaa, 0xe0, 0xce, 0x26, 0xd8, 0x17, 0x92, 0x67, 0xe0, 0xbd, 0x50,
    47  	0x50, 0xfe, 0x7a, 0xf5, 0xf9, 0x3f, 0x3a, 0x1c, 0x05, 0xbb, 0x11, 0xb8, 0xb9, 0x4e, 0x80, 0x2e,
    48  	0x49, 0x14, 0x0d, 0x8a, 0x74, 0x76, 0xe7, 0x40, 0x20, 0xd0, 0x3e, 0xdb, 0x56, 0x97, 0xdd, 0x0e,
    49  	0x34, 0x3e, 0x4e, 0x86, 0x75, 0x9a, 0xf8, 0x88, 0x95, 0x8a, 0x6c, 0xad, 0xc8, 0x86, 0x2b, 0xc5,
    50  	0x16, 0x7f, 0xfd, 0xf8, 0x5a, 0xfe, 0xeb, 0xb4, 0xce, 0xf9, 0xbc, 0xb7, 0x16, 0xfa, 0x49, 0x87,
    51  	0xcb, 0x22, 0x9d, 0xf5, 0xc9, 0x65, 0x9b, 0xd0, 0x37, 0x12, 0xed, 0xdc, 0x6b, 0x8f, 0x74, 0xc3,
    52  	0xcd, 0xf8, 0x0f, 0x39, 0x5b, 0x17, 0x21, 0xcf, 0x19, 0x3d, 0x6d, 0xc8, 0xd3, 0x25, 0xf4, 0x9d,
    53  	0x44, 0x7b, 0xab, 0x76, 0x86, 0xc9, 0xd4, 0xd2, 0x5e, 0xd3, 0x9b, 0xbe, 0x90, 0x6c, 0x84, 0x4e,
    54  	0x1b, 0xf5, 0x50, 0xb6, 0x1e, 0xff, 0x1e, 0xd9, 0xbe, 0x2d, 0x48, 0xa6, 0x36, 0xb4, 0xd5, 0x25,
    55  	0x83, 0x83, 0xa7, 0xfd, 0x5a, 0x58, 0xee, 0x86, 0xae, 0xae, 0xbf, 0x03, 0x00, 0x00, 0xff, 0xff,
    56  	0xb8, 0x9c, 0x62, 0x91, 0xea, 0x02, 0x00, 0x00,
    57  }
    58  
    59  // Reference imports to suppress errors if they are not otherwise used.
    60  var _ context.Context
    61  var _ grpc.ClientConnInterface
    62  
    63  // This is a compile-time assertion to ensure that this generated file
    64  // is compatible with the grpc package it is being compiled against.
    65  const _ = grpc.SupportPackageIsVersion6
    66  
    67  // StreamServiceClient is the client API for StreamService service.
    68  //
    69  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
    70  type StreamServiceClient interface {
    71  	BulkCreate(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkCreateClient, error)
    72  	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (StreamService_ListClient, error)
    73  	BulkEcho(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkEchoClient, error)
    74  }
    75  
    76  type streamServiceClient struct {
    77  	cc grpc.ClientConnInterface
    78  }
    79  
    80  func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient {
    81  	return &streamServiceClient{cc}
    82  }
    83  
    84  func (c *streamServiceClient) BulkCreate(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkCreateClient, error) {
    85  	stream, err := c.cc.NewStream(ctx, &_StreamService_serviceDesc.Streams[0], "/grpc.gateway.examples.internal.examplepb.StreamService/BulkCreate", opts...)
    86  	if err != nil {
    87  		return nil, err
    88  	}
    89  	x := &streamServiceBulkCreateClient{stream}
    90  	return x, nil
    91  }
    92  
    93  type StreamService_BulkCreateClient interface {
    94  	Send(*ABitOfEverything) error
    95  	CloseAndRecv() (*empty.Empty, error)
    96  	grpc.ClientStream
    97  }
    98  
    99  type streamServiceBulkCreateClient struct {
   100  	grpc.ClientStream
   101  }
   102  
   103  func (x *streamServiceBulkCreateClient) Send(m *ABitOfEverything) error {
   104  	return x.ClientStream.SendMsg(m)
   105  }
   106  
   107  func (x *streamServiceBulkCreateClient) CloseAndRecv() (*empty.Empty, error) {
   108  	if err := x.ClientStream.CloseSend(); err != nil {
   109  		return nil, err
   110  	}
   111  	m := new(empty.Empty)
   112  	if err := x.ClientStream.RecvMsg(m); err != nil {
   113  		return nil, err
   114  	}
   115  	return m, nil
   116  }
   117  
   118  func (c *streamServiceClient) List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (StreamService_ListClient, error) {
   119  	stream, err := c.cc.NewStream(ctx, &_StreamService_serviceDesc.Streams[1], "/grpc.gateway.examples.internal.examplepb.StreamService/List", opts...)
   120  	if err != nil {
   121  		return nil, err
   122  	}
   123  	x := &streamServiceListClient{stream}
   124  	if err := x.ClientStream.SendMsg(in); err != nil {
   125  		return nil, err
   126  	}
   127  	if err := x.ClientStream.CloseSend(); err != nil {
   128  		return nil, err
   129  	}
   130  	return x, nil
   131  }
   132  
   133  type StreamService_ListClient interface {
   134  	Recv() (*ABitOfEverything, error)
   135  	grpc.ClientStream
   136  }
   137  
   138  type streamServiceListClient struct {
   139  	grpc.ClientStream
   140  }
   141  
   142  func (x *streamServiceListClient) Recv() (*ABitOfEverything, error) {
   143  	m := new(ABitOfEverything)
   144  	if err := x.ClientStream.RecvMsg(m); err != nil {
   145  		return nil, err
   146  	}
   147  	return m, nil
   148  }
   149  
   150  func (c *streamServiceClient) BulkEcho(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkEchoClient, error) {
   151  	stream, err := c.cc.NewStream(ctx, &_StreamService_serviceDesc.Streams[2], "/grpc.gateway.examples.internal.examplepb.StreamService/BulkEcho", opts...)
   152  	if err != nil {
   153  		return nil, err
   154  	}
   155  	x := &streamServiceBulkEchoClient{stream}
   156  	return x, nil
   157  }
   158  
   159  type StreamService_BulkEchoClient interface {
   160  	Send(*sub.StringMessage) error
   161  	Recv() (*sub.StringMessage, error)
   162  	grpc.ClientStream
   163  }
   164  
   165  type streamServiceBulkEchoClient struct {
   166  	grpc.ClientStream
   167  }
   168  
   169  func (x *streamServiceBulkEchoClient) Send(m *sub.StringMessage) error {
   170  	return x.ClientStream.SendMsg(m)
   171  }
   172  
   173  func (x *streamServiceBulkEchoClient) Recv() (*sub.StringMessage, error) {
   174  	m := new(sub.StringMessage)
   175  	if err := x.ClientStream.RecvMsg(m); err != nil {
   176  		return nil, err
   177  	}
   178  	return m, nil
   179  }
   180  
   181  // StreamServiceServer is the server API for StreamService service.
   182  type StreamServiceServer interface {
   183  	BulkCreate(StreamService_BulkCreateServer) error
   184  	List(*empty.Empty, StreamService_ListServer) error
   185  	BulkEcho(StreamService_BulkEchoServer) error
   186  }
   187  
   188  // UnimplementedStreamServiceServer can be embedded to have forward compatible implementations.
   189  type UnimplementedStreamServiceServer struct {
   190  }
   191  
   192  func (*UnimplementedStreamServiceServer) BulkCreate(srv StreamService_BulkCreateServer) error {
   193  	return status.Errorf(codes.Unimplemented, "method BulkCreate not implemented")
   194  }
   195  func (*UnimplementedStreamServiceServer) List(req *empty.Empty, srv StreamService_ListServer) error {
   196  	return status.Errorf(codes.Unimplemented, "method List not implemented")
   197  }
   198  func (*UnimplementedStreamServiceServer) BulkEcho(srv StreamService_BulkEchoServer) error {
   199  	return status.Errorf(codes.Unimplemented, "method BulkEcho not implemented")
   200  }
   201  
   202  func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer) {
   203  	s.RegisterService(&_StreamService_serviceDesc, srv)
   204  }
   205  
   206  func _StreamService_BulkCreate_Handler(srv interface{}, stream grpc.ServerStream) error {
   207  	return srv.(StreamServiceServer).BulkCreate(&streamServiceBulkCreateServer{stream})
   208  }
   209  
   210  type StreamService_BulkCreateServer interface {
   211  	SendAndClose(*empty.Empty) error
   212  	Recv() (*ABitOfEverything, error)
   213  	grpc.ServerStream
   214  }
   215  
   216  type streamServiceBulkCreateServer struct {
   217  	grpc.ServerStream
   218  }
   219  
   220  func (x *streamServiceBulkCreateServer) SendAndClose(m *empty.Empty) error {
   221  	return x.ServerStream.SendMsg(m)
   222  }
   223  
   224  func (x *streamServiceBulkCreateServer) Recv() (*ABitOfEverything, error) {
   225  	m := new(ABitOfEverything)
   226  	if err := x.ServerStream.RecvMsg(m); err != nil {
   227  		return nil, err
   228  	}
   229  	return m, nil
   230  }
   231  
   232  func _StreamService_List_Handler(srv interface{}, stream grpc.ServerStream) error {
   233  	m := new(empty.Empty)
   234  	if err := stream.RecvMsg(m); err != nil {
   235  		return err
   236  	}
   237  	return srv.(StreamServiceServer).List(m, &streamServiceListServer{stream})
   238  }
   239  
   240  type StreamService_ListServer interface {
   241  	Send(*ABitOfEverything) error
   242  	grpc.ServerStream
   243  }
   244  
   245  type streamServiceListServer struct {
   246  	grpc.ServerStream
   247  }
   248  
   249  func (x *streamServiceListServer) Send(m *ABitOfEverything) error {
   250  	return x.ServerStream.SendMsg(m)
   251  }
   252  
   253  func _StreamService_BulkEcho_Handler(srv interface{}, stream grpc.ServerStream) error {
   254  	return srv.(StreamServiceServer).BulkEcho(&streamServiceBulkEchoServer{stream})
   255  }
   256  
   257  type StreamService_BulkEchoServer interface {
   258  	Send(*sub.StringMessage) error
   259  	Recv() (*sub.StringMessage, error)
   260  	grpc.ServerStream
   261  }
   262  
   263  type streamServiceBulkEchoServer struct {
   264  	grpc.ServerStream
   265  }
   266  
   267  func (x *streamServiceBulkEchoServer) Send(m *sub.StringMessage) error {
   268  	return x.ServerStream.SendMsg(m)
   269  }
   270  
   271  func (x *streamServiceBulkEchoServer) Recv() (*sub.StringMessage, error) {
   272  	m := new(sub.StringMessage)
   273  	if err := x.ServerStream.RecvMsg(m); err != nil {
   274  		return nil, err
   275  	}
   276  	return m, nil
   277  }
   278  
   279  var _StreamService_serviceDesc = grpc.ServiceDesc{
   280  	ServiceName: "grpc.gateway.examples.internal.examplepb.StreamService",
   281  	HandlerType: (*StreamServiceServer)(nil),
   282  	Methods:     []grpc.MethodDesc{},
   283  	Streams: []grpc.StreamDesc{
   284  		{
   285  			StreamName:    "BulkCreate",
   286  			Handler:       _StreamService_BulkCreate_Handler,
   287  			ClientStreams: true,
   288  		},
   289  		{
   290  			StreamName:    "List",
   291  			Handler:       _StreamService_List_Handler,
   292  			ServerStreams: true,
   293  		},
   294  		{
   295  			StreamName:    "BulkEcho",
   296  			Handler:       _StreamService_BulkEcho_Handler,
   297  			ServerStreams: true,
   298  			ClientStreams: true,
   299  		},
   300  	},
   301  	Metadata: "examples/internal/proto/examplepb/stream.proto",
   302  }
   303
View as plain text