Documentation
¶
Index ¶
- func RegisterEchoServer(s *grpc.Server, srv EchoServer)
- type EchoClient
- type EchoRequest
- func (*EchoRequest) Descriptor() ([]byte, []int)
- func (m *EchoRequest) GetMessage() string
- func (*EchoRequest) ProtoMessage()
- func (m *EchoRequest) Reset()
- func (m *EchoRequest) String() string
- func (m *EchoRequest) XXX_DiscardUnknown()
- func (m *EchoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoRequest) XXX_Merge(src proto.Message)
- func (m *EchoRequest) XXX_Size() int
- func (m *EchoRequest) XXX_Unmarshal(b []byte) error
- type EchoResponse
- func (*EchoResponse) Descriptor() ([]byte, []int)
- func (m *EchoResponse) GetMessage() string
- func (*EchoResponse) ProtoMessage()
- func (m *EchoResponse) Reset()
- func (m *EchoResponse) String() string
- func (m *EchoResponse) XXX_DiscardUnknown()
- func (m *EchoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoResponse) XXX_Merge(src proto.Message)
- func (m *EchoResponse) XXX_Size() int
- func (m *EchoResponse) XXX_Unmarshal(b []byte) error
- type EchoServer
- type Echo_BidirectionalStreamingEchoClient
- type Echo_BidirectionalStreamingEchoServer
- type Echo_ClientStreamingEchoClient
- type Echo_ClientStreamingEchoServer
- type Echo_ServerStreamingEchoClient
- type Echo_ServerStreamingEchoServer
- type UnimplementedEchoServer
- func (*UnimplementedEchoServer) BidirectionalStreamingEcho(srv Echo_BidirectionalStreamingEchoServer) error
- func (*UnimplementedEchoServer) ClientStreamingEcho(srv Echo_ClientStreamingEchoServer) error
- func (*UnimplementedEchoServer) ServerStreamingEcho(req *EchoRequest, srv Echo_ServerStreamingEchoServer) error
- func (*UnimplementedEchoServer) UnaryEcho(ctx context.Context, req *EchoRequest) (*EchoResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterEchoServer ¶
func RegisterEchoServer(s *grpc.Server, srv EchoServer)
Types ¶
type EchoClient ¶
type EchoClient interface {
// UnaryEcho is unary echo.
UnaryEcho(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
// ServerStreamingEcho is server side streaming.
ServerStreamingEcho(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (Echo_ServerStreamingEchoClient, error)
// ClientStreamingEcho is client side streaming.
ClientStreamingEcho(ctx context.Context, opts ...grpc.CallOption) (Echo_ClientStreamingEchoClient, error)
// BidirectionalStreamingEcho is bidi streaming.
BidirectionalStreamingEcho(ctx context.Context, opts ...grpc.CallOption) (Echo_BidirectionalStreamingEchoClient, error)
}
EchoClient is the client API for Echo service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/code.aliyun.com/yjkj.ink/grpc#ClientConn.NewStream.
func NewEchoClient ¶
func NewEchoClient(cc grpc.ClientConnInterface) EchoClient
type EchoRequest ¶
type EchoRequest 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:"-"`
}
EchoRequest is the request for echo.
func (*EchoRequest) Descriptor ¶
func (*EchoRequest) Descriptor() ([]byte, []int)
func (*EchoRequest) GetMessage ¶
func (m *EchoRequest) GetMessage() string
func (*EchoRequest) ProtoMessage ¶
func (*EchoRequest) ProtoMessage()
func (*EchoRequest) Reset ¶
func (m *EchoRequest) Reset()
func (*EchoRequest) String ¶
func (m *EchoRequest) String() string
func (*EchoRequest) XXX_DiscardUnknown ¶
func (m *EchoRequest) XXX_DiscardUnknown()
func (*EchoRequest) XXX_Marshal ¶
func (m *EchoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoRequest) XXX_Merge ¶
func (m *EchoRequest) XXX_Merge(src proto.Message)
func (*EchoRequest) XXX_Size ¶
func (m *EchoRequest) XXX_Size() int
func (*EchoRequest) XXX_Unmarshal ¶
func (m *EchoRequest) XXX_Unmarshal(b []byte) error
type EchoResponse ¶
type EchoResponse 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:"-"`
}
EchoResponse is the response for echo.
func (*EchoResponse) Descriptor ¶
func (*EchoResponse) Descriptor() ([]byte, []int)
func (*EchoResponse) GetMessage ¶
func (m *EchoResponse) GetMessage() string
func (*EchoResponse) ProtoMessage ¶
func (*EchoResponse) ProtoMessage()
func (*EchoResponse) Reset ¶
func (m *EchoResponse) Reset()
func (*EchoResponse) String ¶
func (m *EchoResponse) String() string
func (*EchoResponse) XXX_DiscardUnknown ¶
func (m *EchoResponse) XXX_DiscardUnknown()
func (*EchoResponse) XXX_Marshal ¶
func (m *EchoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoResponse) XXX_Merge ¶
func (m *EchoResponse) XXX_Merge(src proto.Message)
func (*EchoResponse) XXX_Size ¶
func (m *EchoResponse) XXX_Size() int
func (*EchoResponse) XXX_Unmarshal ¶
func (m *EchoResponse) XXX_Unmarshal(b []byte) error
type EchoServer ¶
type EchoServer interface {
// UnaryEcho is unary echo.
UnaryEcho(context.Context, *EchoRequest) (*EchoResponse, error)
// ServerStreamingEcho is server side streaming.
ServerStreamingEcho(*EchoRequest, Echo_ServerStreamingEchoServer) error
// ClientStreamingEcho is client side streaming.
ClientStreamingEcho(Echo_ClientStreamingEchoServer) error
// BidirectionalStreamingEcho is bidi streaming.
BidirectionalStreamingEcho(Echo_BidirectionalStreamingEchoServer) error
}
EchoServer is the server API for Echo service.
type Echo_BidirectionalStreamingEchoClient ¶
type Echo_BidirectionalStreamingEchoClient interface {
Send(*EchoRequest) error
Recv() (*EchoResponse, error)
grpc.ClientStream
}
type Echo_BidirectionalStreamingEchoServer ¶
type Echo_BidirectionalStreamingEchoServer interface {
Send(*EchoResponse) error
Recv() (*EchoRequest, error)
grpc.ServerStream
}
type Echo_ClientStreamingEchoClient ¶
type Echo_ClientStreamingEchoClient interface {
Send(*EchoRequest) error
CloseAndRecv() (*EchoResponse, error)
grpc.ClientStream
}
type Echo_ClientStreamingEchoServer ¶
type Echo_ClientStreamingEchoServer interface {
SendAndClose(*EchoResponse) error
Recv() (*EchoRequest, error)
grpc.ServerStream
}
type Echo_ServerStreamingEchoClient ¶
type Echo_ServerStreamingEchoClient interface {
Recv() (*EchoResponse, error)
grpc.ClientStream
}
type Echo_ServerStreamingEchoServer ¶
type Echo_ServerStreamingEchoServer interface {
Send(*EchoResponse) error
grpc.ServerStream
}
type UnimplementedEchoServer ¶
type UnimplementedEchoServer struct {
}
UnimplementedEchoServer can be embedded to have forward compatible implementations.
func (*UnimplementedEchoServer) BidirectionalStreamingEcho ¶
func (*UnimplementedEchoServer) BidirectionalStreamingEcho(srv Echo_BidirectionalStreamingEchoServer) error
func (*UnimplementedEchoServer) ClientStreamingEcho ¶
func (*UnimplementedEchoServer) ClientStreamingEcho(srv Echo_ClientStreamingEchoServer) error
func (*UnimplementedEchoServer) ServerStreamingEcho ¶
func (*UnimplementedEchoServer) ServerStreamingEcho(req *EchoRequest, srv Echo_ServerStreamingEchoServer) error
func (*UnimplementedEchoServer) UnaryEcho ¶
func (*UnimplementedEchoServer) UnaryEcho(ctx context.Context, req *EchoRequest) (*EchoResponse, error)
Source Files
¶
- echo.pb.go
Click to show internal directories.
Click to hide internal directories.