var Heartbeat_Status_name = map[int32]string{ 0: "UNKNOWN", 1: "OK", }
var Heartbeat_Status_value = map[string]int32{ "UNKNOWN": 0, "OK": 1, }
func RegisterEchoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterEchoServiceHandler registers the http handlers for service EchoService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterEchoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterEchoServiceHandlerFromEndpoint is same as RegisterEchoServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterEchoServiceServer(s *grpc.Server, srv EchoServiceServer)
type EchoRequest struct {
Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}
func (*EchoRequest) Descriptor() ([]byte, []int)
func (m *EchoRequest) GetMessage() string
func (*EchoRequest) ProtoMessage()
func (m *EchoRequest) Reset()
func (m *EchoRequest) String() string
type EchoResponse struct {
Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}
func (*EchoResponse) Descriptor() ([]byte, []int)
func (m *EchoResponse) GetMessage() string
func (*EchoResponse) ProtoMessage()
func (m *EchoResponse) Reset()
func (m *EchoResponse) String() string
type EchoServiceClient interface {
Echo(ctx context.Context, opts ...grpc.CallOption) (EchoService_EchoClient, error)
Stream(ctx context.Context, in *Empty, opts ...grpc.CallOption) (EchoService_StreamClient, error)
Heartbeats(ctx context.Context, opts ...grpc.CallOption) (EchoService_HeartbeatsClient, error)
}
func NewEchoServiceClient(cc *grpc.ClientConn) EchoServiceClient
type EchoServiceServer interface {
Echo(EchoService_EchoServer) error
Stream(*Empty, EchoService_StreamServer) error
Heartbeats(EchoService_HeartbeatsServer) error
}
type EchoService_EchoClient interface {
Send(*EchoRequest) error
Recv() (*EchoResponse, error)
grpc.ClientStream
}
type EchoService_EchoServer interface {
Send(*EchoResponse) error
Recv() (*EchoRequest, error)
grpc.ServerStream
}
type EchoService_HeartbeatsClient interface {
Send(*Empty) error
Recv() (*Heartbeat, error)
grpc.ClientStream
}
type EchoService_HeartbeatsServer interface {
Send(*Heartbeat) error
Recv() (*Empty, error)
grpc.ServerStream
}
type EchoService_StreamClient interface {
Recv() (*EchoResponse, error)
grpc.ClientStream
}
type EchoService_StreamServer interface {
Send(*EchoResponse) error
grpc.ServerStream
}
type Empty struct {
}
func (*Empty) Descriptor() ([]byte, []int)
func (*Empty) ProtoMessage()
func (m *Empty) Reset()
func (m *Empty) String() string
type Heartbeat struct {
Status Heartbeat_Status `protobuf:"varint,1,opt,name=status,enum=echoserver.Heartbeat_Status" json:"status,omitempty"`
}
func (*Heartbeat) Descriptor() ([]byte, []int)
func (m *Heartbeat) GetStatus() Heartbeat_Status
func (*Heartbeat) ProtoMessage()
func (m *Heartbeat) Reset()
func (m *Heartbeat) String() string
type Heartbeat_Status int32
const (
Heartbeat_UNKNOWN Heartbeat_Status = 0
Heartbeat_OK Heartbeat_Status = 1
)
func (Heartbeat_Status) EnumDescriptor() ([]byte, []int)
func (x Heartbeat_Status) String() string