func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Empty) Descriptor() ([]byte, []int)
func (*Empty) ProtoMessage()
func (m *Empty) Reset()
func (m *Empty) String() string
func (m *Empty) XXX_DiscardUnknown()
func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *Empty) XXX_Merge(src proto.Message)
func (m *Empty) XXX_Size() int
func (m *Empty) XXX_Unmarshal(b []byte) error
type PingRequest struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
SleepTimeMs int32 `protobuf:"varint,2,opt,name=sleep_time_ms,json=sleepTimeMs,proto3" json:"sleep_time_ms,omitempty"`
ErrorCodeReturned uint32 `protobuf:"varint,3,opt,name=error_code_returned,json=errorCodeReturned,proto3" json:"error_code_returned,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingRequest) Descriptor() ([]byte, []int)
func (m *PingRequest) ExtractRequestFields(appendToMap map[string]interface{})
This is implementing grpc_logging.requestLogFieldsExtractor
func (m *PingRequest) GetErrorCodeReturned() uint32
func (m *PingRequest) GetSleepTimeMs() int32
func (m *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage()
func (m *PingRequest) Reset()
func (m *PingRequest) String() string
func (p *PingRequest) Validate() error
Implements the legacy validation interface from protoc-gen-validate.
func (m *PingRequest) XXX_DiscardUnknown()
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PingRequest) XXX_Merge(src proto.Message)
func (m *PingRequest) XXX_Size() int
func (m *PingRequest) XXX_Unmarshal(b []byte) error
type PingResponse struct {
Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingResponse) Descriptor() ([]byte, []int)
func (m *PingResponse) GetCounter() int32
func (m *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage()
func (m *PingResponse) Reset()
func (m *PingResponse) String() string
func (p *PingResponse) Validate(bool) error
Implements the new validation interface from protoc-gen-validate.
func (m *PingResponse) XXX_DiscardUnknown()
func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PingResponse) XXX_Merge(src proto.Message)
func (m *PingResponse) XXX_Size() int
func (m *PingResponse) XXX_Unmarshal(b []byte) error
TestServiceClient is the client API for TestService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type TestServiceClient interface {
PingEmpty(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingResponse, error)
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*Empty, error)
PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error)
PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error)
}
func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient
TestServiceServer is the server API for TestService service.
type TestServiceServer interface {
PingEmpty(context.Context, *Empty) (*PingResponse, error)
Ping(context.Context, *PingRequest) (*PingResponse, error)
PingError(context.Context, *PingRequest) (*Empty, error)
PingList(*PingRequest, TestService_PingListServer) error
PingStream(TestService_PingStreamServer) error
}
type TestService_PingListClient interface {
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingListServer interface {
Send(*PingResponse) error
grpc.ServerStream
}
type TestService_PingStreamClient interface {
Send(*PingRequest) error
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingStreamServer interface {
Send(*PingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
UnimplementedTestServiceServer can be embedded to have forward compatible implementations.
type UnimplementedTestServiceServer struct {
}
func (*UnimplementedTestServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingEmpty(ctx context.Context, req *Empty) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingError(ctx context.Context, req *PingRequest) (*Empty, error)
func (*UnimplementedTestServiceServer) PingList(req *PingRequest, srv TestService_PingListServer) error
func (*UnimplementedTestServiceServer) PingStream(srv TestService_PingStreamServer) error