Documentation ¶
Index ¶
- func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
- type Empty
- 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
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (m *PingRequest) ExtractRequestFields(appendToMap map[string]interface{})
- 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
- 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
- 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
- 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
- type TestServiceClient
- type TestServiceServer
- type TestService_PingListClient
- type TestService_PingListServer
- type TestService_PingStreamClient
- type TestService_PingStreamServer
- type UnimplementedTestServiceServer
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
Types ¶
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶ added in v1.1.0
func (*Empty) XXX_Unmarshal ¶ added in v1.1.0
type PingRequest ¶
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 ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) ExtractRequestFields ¶
func (m *PingRequest) ExtractRequestFields(appendToMap map[string]interface{})
This is implementing grpc_logging.requestLogFieldsExtractor
func (*PingRequest) GetErrorCodeReturned ¶
func (m *PingRequest) GetErrorCodeReturned() uint32
func (*PingRequest) GetSleepTimeMs ¶
func (m *PingRequest) GetSleepTimeMs() int32
func (*PingRequest) GetValue ¶
func (m *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
func (*PingRequest) Validate ¶
func (p *PingRequest) Validate() error
Implements the legacy validation interface from protoc-gen-validate.
func (*PingRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PingRequest) XXX_DiscardUnknown()
func (*PingRequest) XXX_Marshal ¶ added in v1.1.0
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingRequest) XXX_Merge ¶ added in v1.1.0
func (m *PingRequest) XXX_Merge(src proto.Message)
func (*PingRequest) XXX_Size ¶ added in v1.1.0
func (m *PingRequest) XXX_Size() int
func (*PingRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *PingRequest) XXX_Unmarshal(b []byte) error
type PingResponse ¶
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 ¶
func (*PingResponse) Descriptor() ([]byte, []int)
func (*PingResponse) GetCounter ¶
func (m *PingResponse) GetCounter() int32
func (*PingResponse) GetValue ¶
func (m *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) Reset ¶
func (m *PingResponse) Reset()
func (*PingResponse) String ¶
func (m *PingResponse) String() string
func (*PingResponse) Validate ¶ added in v1.3.0
func (p *PingResponse) Validate(bool) error
Implements the new validation interface from protoc-gen-validate.
func (*PingResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *PingResponse) XXX_DiscardUnknown()
func (*PingResponse) XXX_Marshal ¶ added in v1.1.0
func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingResponse) XXX_Merge ¶ added in v1.1.0
func (m *PingResponse) XXX_Merge(src proto.Message)
func (*PingResponse) XXX_Size ¶ added in v1.1.0
func (m *PingResponse) XXX_Size() int
func (*PingResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *PingResponse) XXX_Unmarshal(b []byte) error
type TestServiceClient ¶
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) }
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.
func NewTestServiceClient ¶
func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient
type TestServiceServer ¶
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 }
TestServiceServer is the server API for TestService service.
type TestService_PingListClient ¶
type TestService_PingListClient interface { Recv() (*PingResponse, error) grpc.ClientStream }
type TestService_PingListServer ¶
type TestService_PingListServer interface { Send(*PingResponse) error grpc.ServerStream }
type TestService_PingStreamClient ¶
type TestService_PingStreamClient interface { Send(*PingRequest) error Recv() (*PingResponse, error) grpc.ClientStream }
type TestService_PingStreamServer ¶
type TestService_PingStreamServer interface { Send(*PingResponse) error Recv() (*PingRequest, error) grpc.ServerStream }
type UnimplementedTestServiceServer ¶ added in v1.1.0
type UnimplementedTestServiceServer struct { }
UnimplementedTestServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTestServiceServer) Ping ¶ added in v1.1.0
func (*UnimplementedTestServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingEmpty ¶ added in v1.1.0
func (*UnimplementedTestServiceServer) PingEmpty(ctx context.Context, req *Empty) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingError ¶ added in v1.1.0
func (*UnimplementedTestServiceServer) PingError(ctx context.Context, req *PingRequest) (*Empty, error)
func (*UnimplementedTestServiceServer) PingList ¶ added in v1.1.0
func (*UnimplementedTestServiceServer) PingList(req *PingRequest, srv TestService_PingListServer) error
func (*UnimplementedTestServiceServer) PingStream ¶ added in v1.1.0
func (*UnimplementedTestServiceServer) PingStream(srv TestService_PingStreamServer) error
Click to show internal directories.
Click to hide internal directories.