protocdiff.go

13a14
> // Requires gRPC-Go v1.32.0 or later.
24c25
< 	GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (Log_GetServersClient, error)
---
> 	GetServers(ctx context.Context, opts ...grpc.CallOption) (Log_GetServersClient, error)
54c55
< 	stream, err := c.cc.NewStream(ctx, &_Log_serviceDesc.Streams[0], "/log.v1.Log/ConsumeStream", opts...)
---
> 	stream, err := c.cc.NewStream(ctx, &Log_ServiceDesc.Streams[0], "/log.v1.Log/ConsumeStream", opts...)
86c87
< 	stream, err := c.cc.NewStream(ctx, &_Log_serviceDesc.Streams[1], "/log.v1.Log/ProduceStream", opts...)
---
> 	stream, err := c.cc.NewStream(ctx, &Log_ServiceDesc.Streams[1], "/log.v1.Log/ProduceStream", opts...)
116,117c117,118
< func (c *logClient) GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (Log_GetServersClient, error) {
< 	stream, err := c.cc.NewStream(ctx, &_Log_serviceDesc.Streams[2], "/log.v1.Log/GetServers", opts...)
---
> func (c *logClient) GetServers(ctx context.Context, opts ...grpc.CallOption) (Log_GetServersClient, error) {
> 	stream, err := c.cc.NewStream(ctx, &Log_ServiceDesc.Streams[2], "/log.v1.Log/GetServers", opts...)
122,127d122
< 	if err := x.ClientStream.SendMsg(in); err != nil {
< 		return nil, err
< 	}
< 	if err := x.ClientStream.CloseSend(); err != nil {
< 		return nil, err
< 	}
131a127
> 	Send(*GetServersRequest) error
139a136,139
> func (x *logGetServersClient) Send(m *GetServersRequest) error {
> 	return x.ClientStream.SendMsg(m)
> }
> 
156c156
< 	GetServers(*GetServersRequest, Log_GetServersServer) error
---
> 	GetServers(Log_GetServersServer) error
176c176
< func (UnimplementedLogServer) GetServers(*GetServersRequest, Log_GetServersServer) error {
---
> func (UnimplementedLogServer) GetServers(Log_GetServersServer) error {
188,189c188,189
< func RegisterLogServer(s *grpc.Server, srv LogServer) {
< 	s.RegisterService(&_Log_serviceDesc, srv)
---
> func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer) {
> 	s.RegisterService(&Log_ServiceDesc, srv)
276,280c276
< 	m := new(GetServersRequest)
< 	if err := stream.RecvMsg(m); err != nil {
< 		return err
< 	}
< 	return srv.(LogServer).GetServers(m, &logGetServersServer{stream})
---
> 	return srv.(LogServer).GetServers(&logGetServersServer{stream})
284a281
> 	Recv() (*GetServersRequest, error)
296c293,304
< var _Log_serviceDesc = grpc.ServiceDesc{
---
> func (x *logGetServersServer) Recv() (*GetServersRequest, error) {
> 	m := new(GetServersRequest)
> 	if err := x.ServerStream.RecvMsg(m); err != nil {
> 		return nil, err
> 	}
> 	return m, nil
> }
> 
> // Log_ServiceDesc is the grpc.ServiceDesc for Log service.
> // It's only intended for direct use with grpc.RegisterService,
> // and not to be introspected or modified (even as a copy)
> var Log_ServiceDesc = grpc.ServiceDesc{
324a333
> 			ClientStreams: true,