// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc (unknown) // source: examples/internal/proto/examplepb/flow_combination.proto package examplepb import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" ) // 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 // FlowCombinationClient is the client API for FlowCombination 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 FlowCombinationClient interface { RpcEmptyRpc(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (*EmptyProto, error) RpcEmptyStream(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcEmptyStreamClient, error) StreamEmptyRpc(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyRpcClient, error) StreamEmptyStream(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyStreamClient, error) RpcBodyRpc(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (*EmptyProto, error) RpcPathSingleNestedRpc(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (*EmptyProto, error) RpcPathNestedRpc(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (*EmptyProto, error) RpcBodyStream(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcBodyStreamClient, error) RpcPathSingleNestedStream(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathSingleNestedStreamClient, error) RpcPathNestedStream(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathNestedStreamClient, error) } type flowCombinationClient struct { cc grpc.ClientConnInterface } func NewFlowCombinationClient(cc grpc.ClientConnInterface) FlowCombinationClient { return &flowCombinationClient{cc} } func (c *flowCombinationClient) RpcEmptyRpc(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (*EmptyProto, error) { out := new(EmptyProto) err := c.cc.Invoke(ctx, "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcEmptyRpc", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *flowCombinationClient) RpcEmptyStream(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcEmptyStreamClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[0], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcEmptyStream", opts...) if err != nil { return nil, err } x := &flowCombinationRpcEmptyStreamClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type FlowCombination_RpcEmptyStreamClient interface { Recv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationRpcEmptyStreamClient struct { grpc.ClientStream } func (x *flowCombinationRpcEmptyStreamClient) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *flowCombinationClient) StreamEmptyRpc(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyRpcClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[1], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/StreamEmptyRpc", opts...) if err != nil { return nil, err } x := &flowCombinationStreamEmptyRpcClient{stream} return x, nil } type FlowCombination_StreamEmptyRpcClient interface { Send(*EmptyProto) error CloseAndRecv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationStreamEmptyRpcClient struct { grpc.ClientStream } func (x *flowCombinationStreamEmptyRpcClient) Send(m *EmptyProto) error { return x.ClientStream.SendMsg(m) } func (x *flowCombinationStreamEmptyRpcClient) CloseAndRecv() (*EmptyProto, error) { if err := x.ClientStream.CloseSend(); err != nil { return nil, err } m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *flowCombinationClient) StreamEmptyStream(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyStreamClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[2], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/StreamEmptyStream", opts...) if err != nil { return nil, err } x := &flowCombinationStreamEmptyStreamClient{stream} return x, nil } type FlowCombination_StreamEmptyStreamClient interface { Send(*EmptyProto) error Recv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationStreamEmptyStreamClient struct { grpc.ClientStream } func (x *flowCombinationStreamEmptyStreamClient) Send(m *EmptyProto) error { return x.ClientStream.SendMsg(m) } func (x *flowCombinationStreamEmptyStreamClient) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *flowCombinationClient) RpcBodyRpc(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (*EmptyProto, error) { out := new(EmptyProto) err := c.cc.Invoke(ctx, "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcBodyRpc", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *flowCombinationClient) RpcPathSingleNestedRpc(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (*EmptyProto, error) { out := new(EmptyProto) err := c.cc.Invoke(ctx, "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathSingleNestedRpc", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *flowCombinationClient) RpcPathNestedRpc(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (*EmptyProto, error) { out := new(EmptyProto) err := c.cc.Invoke(ctx, "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathNestedRpc", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *flowCombinationClient) RpcBodyStream(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcBodyStreamClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[3], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcBodyStream", opts...) if err != nil { return nil, err } x := &flowCombinationRpcBodyStreamClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type FlowCombination_RpcBodyStreamClient interface { Recv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationRpcBodyStreamClient struct { grpc.ClientStream } func (x *flowCombinationRpcBodyStreamClient) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *flowCombinationClient) RpcPathSingleNestedStream(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathSingleNestedStreamClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[4], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathSingleNestedStream", opts...) if err != nil { return nil, err } x := &flowCombinationRpcPathSingleNestedStreamClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type FlowCombination_RpcPathSingleNestedStreamClient interface { Recv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationRpcPathSingleNestedStreamClient struct { grpc.ClientStream } func (x *flowCombinationRpcPathSingleNestedStreamClient) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *flowCombinationClient) RpcPathNestedStream(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathNestedStreamClient, error) { stream, err := c.cc.NewStream(ctx, &FlowCombination_ServiceDesc.Streams[5], "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathNestedStream", opts...) if err != nil { return nil, err } x := &flowCombinationRpcPathNestedStreamClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type FlowCombination_RpcPathNestedStreamClient interface { Recv() (*EmptyProto, error) grpc.ClientStream } type flowCombinationRpcPathNestedStreamClient struct { grpc.ClientStream } func (x *flowCombinationRpcPathNestedStreamClient) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // FlowCombinationServer is the server API for FlowCombination service. // All implementations should embed UnimplementedFlowCombinationServer // for forward compatibility type FlowCombinationServer interface { RpcEmptyRpc(context.Context, *EmptyProto) (*EmptyProto, error) RpcEmptyStream(*EmptyProto, FlowCombination_RpcEmptyStreamServer) error StreamEmptyRpc(FlowCombination_StreamEmptyRpcServer) error StreamEmptyStream(FlowCombination_StreamEmptyStreamServer) error RpcBodyRpc(context.Context, *NonEmptyProto) (*EmptyProto, error) RpcPathSingleNestedRpc(context.Context, *SingleNestedProto) (*EmptyProto, error) RpcPathNestedRpc(context.Context, *NestedProto) (*EmptyProto, error) RpcBodyStream(*NonEmptyProto, FlowCombination_RpcBodyStreamServer) error RpcPathSingleNestedStream(*SingleNestedProto, FlowCombination_RpcPathSingleNestedStreamServer) error RpcPathNestedStream(*NestedProto, FlowCombination_RpcPathNestedStreamServer) error } // UnimplementedFlowCombinationServer should be embedded to have forward compatible implementations. type UnimplementedFlowCombinationServer struct { } func (UnimplementedFlowCombinationServer) RpcEmptyRpc(context.Context, *EmptyProto) (*EmptyProto, error) { return nil, status.Errorf(codes.Unimplemented, "method RpcEmptyRpc not implemented") } func (UnimplementedFlowCombinationServer) RpcEmptyStream(*EmptyProto, FlowCombination_RpcEmptyStreamServer) error { return status.Errorf(codes.Unimplemented, "method RpcEmptyStream not implemented") } func (UnimplementedFlowCombinationServer) StreamEmptyRpc(FlowCombination_StreamEmptyRpcServer) error { return status.Errorf(codes.Unimplemented, "method StreamEmptyRpc not implemented") } func (UnimplementedFlowCombinationServer) StreamEmptyStream(FlowCombination_StreamEmptyStreamServer) error { return status.Errorf(codes.Unimplemented, "method StreamEmptyStream not implemented") } func (UnimplementedFlowCombinationServer) RpcBodyRpc(context.Context, *NonEmptyProto) (*EmptyProto, error) { return nil, status.Errorf(codes.Unimplemented, "method RpcBodyRpc not implemented") } func (UnimplementedFlowCombinationServer) RpcPathSingleNestedRpc(context.Context, *SingleNestedProto) (*EmptyProto, error) { return nil, status.Errorf(codes.Unimplemented, "method RpcPathSingleNestedRpc not implemented") } func (UnimplementedFlowCombinationServer) RpcPathNestedRpc(context.Context, *NestedProto) (*EmptyProto, error) { return nil, status.Errorf(codes.Unimplemented, "method RpcPathNestedRpc not implemented") } func (UnimplementedFlowCombinationServer) RpcBodyStream(*NonEmptyProto, FlowCombination_RpcBodyStreamServer) error { return status.Errorf(codes.Unimplemented, "method RpcBodyStream not implemented") } func (UnimplementedFlowCombinationServer) RpcPathSingleNestedStream(*SingleNestedProto, FlowCombination_RpcPathSingleNestedStreamServer) error { return status.Errorf(codes.Unimplemented, "method RpcPathSingleNestedStream not implemented") } func (UnimplementedFlowCombinationServer) RpcPathNestedStream(*NestedProto, FlowCombination_RpcPathNestedStreamServer) error { return status.Errorf(codes.Unimplemented, "method RpcPathNestedStream not implemented") } // UnsafeFlowCombinationServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to FlowCombinationServer will // result in compilation errors. type UnsafeFlowCombinationServer interface { mustEmbedUnimplementedFlowCombinationServer() } func RegisterFlowCombinationServer(s grpc.ServiceRegistrar, srv FlowCombinationServer) { s.RegisterService(&FlowCombination_ServiceDesc, srv) } func _FlowCombination_RpcEmptyRpc_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(EmptyProto) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(FlowCombinationServer).RpcEmptyRpc(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcEmptyRpc", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FlowCombinationServer).RpcEmptyRpc(ctx, req.(*EmptyProto)) } return interceptor(ctx, in, info, handler) } func _FlowCombination_RpcEmptyStream_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(EmptyProto) if err := stream.RecvMsg(m); err != nil { return err } return srv.(FlowCombinationServer).RpcEmptyStream(m, &flowCombinationRpcEmptyStreamServer{stream}) } type FlowCombination_RpcEmptyStreamServer interface { Send(*EmptyProto) error grpc.ServerStream } type flowCombinationRpcEmptyStreamServer struct { grpc.ServerStream } func (x *flowCombinationRpcEmptyStreamServer) Send(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } func _FlowCombination_StreamEmptyRpc_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(FlowCombinationServer).StreamEmptyRpc(&flowCombinationStreamEmptyRpcServer{stream}) } type FlowCombination_StreamEmptyRpcServer interface { SendAndClose(*EmptyProto) error Recv() (*EmptyProto, error) grpc.ServerStream } type flowCombinationStreamEmptyRpcServer struct { grpc.ServerStream } func (x *flowCombinationStreamEmptyRpcServer) SendAndClose(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } func (x *flowCombinationStreamEmptyRpcServer) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func _FlowCombination_StreamEmptyStream_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(FlowCombinationServer).StreamEmptyStream(&flowCombinationStreamEmptyStreamServer{stream}) } type FlowCombination_StreamEmptyStreamServer interface { Send(*EmptyProto) error Recv() (*EmptyProto, error) grpc.ServerStream } type flowCombinationStreamEmptyStreamServer struct { grpc.ServerStream } func (x *flowCombinationStreamEmptyStreamServer) Send(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } func (x *flowCombinationStreamEmptyStreamServer) Recv() (*EmptyProto, error) { m := new(EmptyProto) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func _FlowCombination_RpcBodyRpc_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(NonEmptyProto) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(FlowCombinationServer).RpcBodyRpc(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcBodyRpc", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FlowCombinationServer).RpcBodyRpc(ctx, req.(*NonEmptyProto)) } return interceptor(ctx, in, info, handler) } func _FlowCombination_RpcPathSingleNestedRpc_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SingleNestedProto) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(FlowCombinationServer).RpcPathSingleNestedRpc(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathSingleNestedRpc", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FlowCombinationServer).RpcPathSingleNestedRpc(ctx, req.(*SingleNestedProto)) } return interceptor(ctx, in, info, handler) } func _FlowCombination_RpcPathNestedRpc_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(NestedProto) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(FlowCombinationServer).RpcPathNestedRpc(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/grpc.gateway.examples.internal.proto.examplepb.FlowCombination/RpcPathNestedRpc", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FlowCombinationServer).RpcPathNestedRpc(ctx, req.(*NestedProto)) } return interceptor(ctx, in, info, handler) } func _FlowCombination_RpcBodyStream_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(NonEmptyProto) if err := stream.RecvMsg(m); err != nil { return err } return srv.(FlowCombinationServer).RpcBodyStream(m, &flowCombinationRpcBodyStreamServer{stream}) } type FlowCombination_RpcBodyStreamServer interface { Send(*EmptyProto) error grpc.ServerStream } type flowCombinationRpcBodyStreamServer struct { grpc.ServerStream } func (x *flowCombinationRpcBodyStreamServer) Send(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } func _FlowCombination_RpcPathSingleNestedStream_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(SingleNestedProto) if err := stream.RecvMsg(m); err != nil { return err } return srv.(FlowCombinationServer).RpcPathSingleNestedStream(m, &flowCombinationRpcPathSingleNestedStreamServer{stream}) } type FlowCombination_RpcPathSingleNestedStreamServer interface { Send(*EmptyProto) error grpc.ServerStream } type flowCombinationRpcPathSingleNestedStreamServer struct { grpc.ServerStream } func (x *flowCombinationRpcPathSingleNestedStreamServer) Send(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } func _FlowCombination_RpcPathNestedStream_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(NestedProto) if err := stream.RecvMsg(m); err != nil { return err } return srv.(FlowCombinationServer).RpcPathNestedStream(m, &flowCombinationRpcPathNestedStreamServer{stream}) } type FlowCombination_RpcPathNestedStreamServer interface { Send(*EmptyProto) error grpc.ServerStream } type flowCombinationRpcPathNestedStreamServer struct { grpc.ServerStream } func (x *flowCombinationRpcPathNestedStreamServer) Send(m *EmptyProto) error { return x.ServerStream.SendMsg(m) } // FlowCombination_ServiceDesc is the grpc.ServiceDesc for FlowCombination service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var FlowCombination_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.gateway.examples.internal.proto.examplepb.FlowCombination", HandlerType: (*FlowCombinationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RpcEmptyRpc", Handler: _FlowCombination_RpcEmptyRpc_Handler, }, { MethodName: "RpcBodyRpc", Handler: _FlowCombination_RpcBodyRpc_Handler, }, { MethodName: "RpcPathSingleNestedRpc", Handler: _FlowCombination_RpcPathSingleNestedRpc_Handler, }, { MethodName: "RpcPathNestedRpc", Handler: _FlowCombination_RpcPathNestedRpc_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RpcEmptyStream", Handler: _FlowCombination_RpcEmptyStream_Handler, ServerStreams: true, }, { StreamName: "StreamEmptyRpc", Handler: _FlowCombination_StreamEmptyRpc_Handler, ClientStreams: true, }, { StreamName: "StreamEmptyStream", Handler: _FlowCombination_StreamEmptyStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "RpcBodyStream", Handler: _FlowCombination_RpcBodyStream_Handler, ServerStreams: true, }, { StreamName: "RpcPathSingleNestedStream", Handler: _FlowCombination_RpcPathSingleNestedStream_Handler, ServerStreams: true, }, { StreamName: "RpcPathNestedStream", Handler: _FlowCombination_RpcPathNestedStream_Handler, ServerStreams: true, }, }, Metadata: "examples/internal/proto/examplepb/flow_combination.proto", }