diff options
Diffstat (limited to 'internal/streamrpc/testdata/test_grpc.pb.go')
-rw-r--r-- | internal/streamrpc/testdata/test_grpc.pb.go | 102 |
1 files changed, 0 insertions, 102 deletions
diff --git a/internal/streamrpc/testdata/test_grpc.pb.go b/internal/streamrpc/testdata/test_grpc.pb.go deleted file mode 100644 index 53fb22792..000000000 --- a/internal/streamrpc/testdata/test_grpc.pb.go +++ /dev/null @@ -1,102 +0,0 @@ -// Code generated by protoc-gen-go-grpc. DO NOT EDIT. - -package testdata - -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 - -// TestClient is the client API for Test 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 TestClient interface { - Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) -} - -type testClient struct { - cc grpc.ClientConnInterface -} - -func NewTestClient(cc grpc.ClientConnInterface) TestClient { - return &testClient{cc} -} - -func (c *testClient) Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/test.streamrpc.Test/Stream", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -// TestServer is the server API for Test service. -// All implementations must embed UnimplementedTestServer -// for forward compatibility -type TestServer interface { - Stream(context.Context, *StreamRequest) (*emptypb.Empty, error) - mustEmbedUnimplementedTestServer() -} - -// UnimplementedTestServer must be embedded to have forward compatible implementations. -type UnimplementedTestServer struct { -} - -func (UnimplementedTestServer) Stream(context.Context, *StreamRequest) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method Stream not implemented") -} -func (UnimplementedTestServer) mustEmbedUnimplementedTestServer() {} - -// UnsafeTestServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to TestServer will -// result in compilation errors. -type UnsafeTestServer interface { - mustEmbedUnimplementedTestServer() -} - -func RegisterTestServer(s grpc.ServiceRegistrar, srv TestServer) { - s.RegisterService(&Test_ServiceDesc, srv) -} - -func _Test_Stream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(StreamRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(TestServer).Stream(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/test.streamrpc.Test/Stream", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(TestServer).Stream(ctx, req.(*StreamRequest)) - } - return interceptor(ctx, in, info, handler) -} - -// Test_ServiceDesc is the grpc.ServiceDesc for Test service. -// It's only intended for direct use with grpc.RegisterService, -// and not to be introspected or modified (even as a copy) -var Test_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "test.streamrpc.Test", - HandlerType: (*TestServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "Stream", - Handler: _Test_Stream_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "streamrpc/testdata/test.proto", -} |