Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var File_grpc_echo_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEchoServer ¶
func RegisterEchoServer(s *grpc.Server, srv EchoServer)
Types ¶
type EchoClient ¶
type EchoClient interface {
Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*empty.Empty, error)
EchoStream(ctx context.Context, opts ...grpc.CallOption) (Echo_EchoStreamClient, error)
}
EchoClient is the client API for Echo 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.
func NewEchoClient ¶
func NewEchoClient(cc grpc.ClientConnInterface) EchoClient
type EchoRequest ¶
type EchoRequest struct {
ReturnStatus *rpc.Status `protobuf:"bytes,1,opt,name=return_status,json=returnStatus,proto3" json:"return_status,omitempty"`
// contains filtered or unexported fields
}
func (*EchoRequest) Descriptor
deprecated
func (*EchoRequest) Descriptor() ([]byte, []int)
Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.
func (*EchoRequest) GetReturnStatus ¶
func (x *EchoRequest) GetReturnStatus() *rpc.Status
func (*EchoRequest) ProtoMessage ¶
func (*EchoRequest) ProtoMessage()
func (*EchoRequest) ProtoReflect ¶
func (x *EchoRequest) ProtoReflect() protoreflect.Message
func (*EchoRequest) Reset ¶
func (x *EchoRequest) Reset()
func (*EchoRequest) String ¶
func (x *EchoRequest) String() string
type EchoServer ¶
type EchoServer interface {
Echo(context.Context, *EchoRequest) (*empty.Empty, error)
EchoStream(Echo_EchoStreamServer) error
// contains filtered or unexported methods
}
EchoServer is the server API for Echo service. All implementations must embed UnimplementedEchoServer for forward compatibility
type Echo_EchoStreamClient ¶
type Echo_EchoStreamClient interface {
Send(*StreamRequest) error
Recv() (*empty.Empty, error)
grpc.ClientStream
}
type Echo_EchoStreamServer ¶
type Echo_EchoStreamServer interface {
Send(*empty.Empty) error
Recv() (*StreamRequest, error)
grpc.ServerStream
}
type StreamRequest ¶
type StreamRequest struct {
ResponseCount uint32 `protobuf:"varint,1,opt,name=response_count,json=responseCount,proto3" json:"response_count,omitempty"`
// contains filtered or unexported fields
}
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetResponseCount ¶
func (x *StreamRequest) GetResponseCount() uint32
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type UnimplementedEchoServer ¶
type UnimplementedEchoServer struct {
}
UnimplementedEchoServer must be embedded to have forward compatible implementations.
func (UnimplementedEchoServer) Echo ¶
func (UnimplementedEchoServer) Echo(context.Context, *EchoRequest) (*empty.Empty, error)
func (UnimplementedEchoServer) EchoStream ¶
func (UnimplementedEchoServer) EchoStream(Echo_EchoStreamServer) error
type UnsafeEchoServer ¶
type UnsafeEchoServer interface {
// contains filtered or unexported methods
}
UnsafeEchoServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EchoServer will result in compilation errors.
Source Files