multiprotos

package
v3.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 17, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterFristServiceServer 

func RegisterFristServiceServer(s *grpc.Server, srv FristServiceServer)

func RegisterSecondServiceServer 

func RegisterSecondServiceServer(s *grpc.Server, srv SecondServiceServer)

Types

type FirstRequest 

type FirstRequest struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FirstRequest) Descriptor 

func (*FirstRequest) Descriptor() ([]byte, []int)

func (*FirstRequest) GetMessage 

func (m *FirstRequest) GetMessage() string

func (*FirstRequest) ProtoMessage 

func (*FirstRequest) ProtoMessage()

func (*FirstRequest) Reset 

func (m *FirstRequest) Reset()

func (*FirstRequest) String 

func (m *FirstRequest) String() string

func (*FirstRequest) XXX_DiscardUnknown 

func (m *FirstRequest) XXX_DiscardUnknown()

func (*FirstRequest) XXX_Marshal 

func (m *FirstRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FirstRequest) XXX_Merge 

func (m *FirstRequest) XXX_Merge(src proto.Message)

func (*FirstRequest) XXX_Size 

func (m *FirstRequest) XXX_Size() int

func (*FirstRequest) XXX_Unmarshal 

func (m *FirstRequest) XXX_Unmarshal(b []byte) error

type FirstResponse 

type FirstResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FirstResponse) Descriptor 

func (*FirstResponse) Descriptor() ([]byte, []int)

func (*FirstResponse) GetMessage 

func (m *FirstResponse) GetMessage() string

func (*FirstResponse) ProtoMessage 

func (*FirstResponse) ProtoMessage()

func (*FirstResponse) Reset 

func (m *FirstResponse) Reset()

func (*FirstResponse) String 

func (m *FirstResponse) String() string

func (*FirstResponse) XXX_DiscardUnknown 

func (m *FirstResponse) XXX_DiscardUnknown()

func (*FirstResponse) XXX_Marshal 

func (m *FirstResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FirstResponse) XXX_Merge 

func (m *FirstResponse) XXX_Merge(src proto.Message)

func (*FirstResponse) XXX_Size 

func (m *FirstResponse) XXX_Size() int

func (*FirstResponse) XXX_Unmarshal 

func (m *FirstResponse) XXX_Unmarshal(b []byte) error

type FristServiceClient 

type FristServiceClient interface {
	Service(ctx context.Context, in *FirstRequest, opts ...grpc.CallOption) (*FirstResponse, error)
}

FristServiceClient is the client API for FristService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFristServiceClient 

func NewFristServiceClient(cc grpc.ClientConnInterface) FristServiceClient

type FristServiceClientImpl 

type FristServiceClientImpl struct {
	Service func(ctx context.Context, in *FirstRequest, out *FirstResponse) error
}

FristServiceClientImpl is the client API for FristService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func (*FristServiceClientImpl) GetDubboStub 

func (c *FristServiceClientImpl) GetDubboStub(cc *grpc.ClientConn) FristServiceClient

func (*FristServiceClientImpl) Reference 

func (c *FristServiceClientImpl) Reference() string

type FristServiceProviderBase 

type FristServiceProviderBase struct {
	// contains filtered or unexported fields
}

func (*FristServiceProviderBase) GetProxyImpl 

func (s *FristServiceProviderBase) GetProxyImpl() protocol.Invoker

func (*FristServiceProviderBase) Reference 

func (c *FristServiceProviderBase) Reference() string

func (*FristServiceProviderBase) ServiceDesc 

func (s *FristServiceProviderBase) ServiceDesc() *grpc.ServiceDesc

func (*FristServiceProviderBase) SetProxyImpl 

func (s *FristServiceProviderBase) SetProxyImpl(impl protocol.Invoker)

type FristServiceServer 

type FristServiceServer interface {
	Service(context.Context, *FirstRequest) (*FirstResponse, error)
}

FristServiceServer is the server API for FristService service.

type SecondRequest 

type SecondRequest struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SecondRequest) Descriptor 

func (*SecondRequest) Descriptor() ([]byte, []int)

func (*SecondRequest) GetMessage 

func (m *SecondRequest) GetMessage() string

func (*SecondRequest) ProtoMessage 

func (*SecondRequest) ProtoMessage()

func (*SecondRequest) Reset 

func (m *SecondRequest) Reset()

func (*SecondRequest) String 

func (m *SecondRequest) String() string

func (*SecondRequest) XXX_DiscardUnknown 

func (m *SecondRequest) XXX_DiscardUnknown()

func (*SecondRequest) XXX_Marshal 

func (m *SecondRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecondRequest) XXX_Merge 

func (m *SecondRequest) XXX_Merge(src proto.Message)

func (*SecondRequest) XXX_Size 

func (m *SecondRequest) XXX_Size() int

func (*SecondRequest) XXX_Unmarshal 

func (m *SecondRequest) XXX_Unmarshal(b []byte) error

type SecondResponse 

type SecondResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SecondResponse) Descriptor 

func (*SecondResponse) Descriptor() ([]byte, []int)

func (*SecondResponse) GetMessage 

func (m *SecondResponse) GetMessage() string

func (*SecondResponse) ProtoMessage 

func (*SecondResponse) ProtoMessage()

func (*SecondResponse) Reset 

func (m *SecondResponse) Reset()

func (*SecondResponse) String 

func (m *SecondResponse) String() string

func (*SecondResponse) XXX_DiscardUnknown 

func (m *SecondResponse) XXX_DiscardUnknown()

func (*SecondResponse) XXX_Marshal 

func (m *SecondResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecondResponse) XXX_Merge 

func (m *SecondResponse) XXX_Merge(src proto.Message)

func (*SecondResponse) XXX_Size 

func (m *SecondResponse) XXX_Size() int

func (*SecondResponse) XXX_Unmarshal 

func (m *SecondResponse) XXX_Unmarshal(b []byte) error

type SecondServiceClient 

type SecondServiceClient interface {
	Service1(ctx context.Context, in *SecondRequest, opts ...grpc.CallOption) (*SecondResponse, error)
	Service2(ctx context.Context, in *SecondRequest, opts ...grpc.CallOption) (SecondService_Service2Client, error)
	Service3(ctx context.Context, opts ...grpc.CallOption) (SecondService_Service3Client, error)
	Service4(ctx context.Context, opts ...grpc.CallOption) (SecondService_Service4Client, error)
}

SecondServiceClient is the client API for SecondService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSecondServiceClient 

func NewSecondServiceClient(cc grpc.ClientConnInterface) SecondServiceClient

type SecondServiceClientImpl 

type SecondServiceClientImpl struct {
	Service1 func(ctx context.Context, in *SecondRequest, out *SecondResponse) error
	Service2 func(ctx context.Context, in *SecondRequest) (SecondService_Service2Client, error)
	Service3 func(ctx context.Context) (SecondService_Service3Client, error)
	Service4 func(ctx context.Context) (SecondService_Service4Client, error)
}

SecondServiceClientImpl is the client API for SecondService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func (*SecondServiceClientImpl) GetDubboStub 

func (c *SecondServiceClientImpl) GetDubboStub(cc *grpc.ClientConn) SecondServiceClient

func (*SecondServiceClientImpl) Reference 

func (c *SecondServiceClientImpl) Reference() string

type SecondServiceProviderBase 

type SecondServiceProviderBase struct {
	// contains filtered or unexported fields
}

func (*SecondServiceProviderBase) GetProxyImpl 

func (s *SecondServiceProviderBase) GetProxyImpl() protocol.Invoker

func (*SecondServiceProviderBase) Reference 

func (c *SecondServiceProviderBase) Reference() string

func (*SecondServiceProviderBase) ServiceDesc 

func (s *SecondServiceProviderBase) ServiceDesc() *grpc.ServiceDesc

func (*SecondServiceProviderBase) SetProxyImpl 

func (s *SecondServiceProviderBase) SetProxyImpl(impl protocol.Invoker)

type SecondServiceServer 

type SecondServiceServer interface {
	Service1(context.Context, *SecondRequest) (*SecondResponse, error)
	Service2(*SecondRequest, SecondService_Service2Server) error
	Service3(SecondService_Service3Server) error
	Service4(SecondService_Service4Server) error
}

SecondServiceServer is the server API for SecondService service.

type SecondService_Service2Client 

type SecondService_Service2Client interface {
	Recv() (*SecondResponse, error)
	grpc.ClientStream
}

type SecondService_Service2Server 

type SecondService_Service2Server interface {
	Send(*SecondResponse) error
	grpc.ServerStream
}

type SecondService_Service3Client 

type SecondService_Service3Client interface {
	Send(*SecondRequest) error
	CloseAndRecv() (*SecondResponse, error)
	grpc.ClientStream
}

type SecondService_Service3Server 

type SecondService_Service3Server interface {
	SendAndClose(*SecondResponse) error
	Recv() (*SecondRequest, error)
	grpc.ServerStream
}

type SecondService_Service4Client 

type SecondService_Service4Client interface {
	Send(*SecondRequest) error
	Recv() (*SecondResponse, error)
	grpc.ClientStream
}

type SecondService_Service4Server 

type SecondService_Service4Server interface {
	Send(*SecondResponse) error
	Recv() (*SecondRequest, error)
	grpc.ServerStream
}

type UnimplementedFristServiceServer 

type UnimplementedFristServiceServer struct {
}

UnimplementedFristServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFristServiceServer) Service 

func (*UnimplementedFristServiceServer) Service(ctx context.Context, req *FirstRequest) (*FirstResponse, error)

type UnimplementedSecondServiceServer 

type UnimplementedSecondServiceServer struct {
}

UnimplementedSecondServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSecondServiceServer) Service1 

func (*UnimplementedSecondServiceServer) Service1(ctx context.Context, req *SecondRequest) (*SecondResponse, error)

func (*UnimplementedSecondServiceServer) Service2 

func (*UnimplementedSecondServiceServer) Service2(req *SecondRequest, srv SecondService_Service2Server) error

func (*UnimplementedSecondServiceServer) Service3 

func (*UnimplementedSecondServiceServer) Service3(srv SecondService_Service3Server) error

func (*UnimplementedSecondServiceServer) Service4 

func (*UnimplementedSecondServiceServer) Service4(srv SecondService_Service4Server) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.