Versions in this module Expand all Collapse all v1 v1.0.0 Jul 11, 2016 Changes in this version + var PayloadType_name = map[int32]string + var PayloadType_value = map[string]int32 + func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) + type Empty struct + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type Payload struct + Body []byte + Type *PayloadType + XXX_unrecognized []byte + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (m *Payload) GetBody() []byte + func (m *Payload) GetType() PayloadType + func (m *Payload) Reset() + func (m *Payload) String() string + type PayloadType int32 + const PayloadType_COMPRESSABLE + const PayloadType_RANDOM + const PayloadType_UNCOMPRESSABLE + func (PayloadType) EnumDescriptor() ([]byte, []int) + func (x *PayloadType) UnmarshalJSON(data []byte) error + func (x PayloadType) Enum() *PayloadType + func (x PayloadType) String() string + type ResponseParameters struct + IntervalUs *int32 + Size *int32 + XXX_unrecognized []byte + func (*ResponseParameters) Descriptor() ([]byte, []int) + func (*ResponseParameters) ProtoMessage() + func (m *ResponseParameters) GetIntervalUs() int32 + func (m *ResponseParameters) GetSize() int32 + func (m *ResponseParameters) Reset() + func (m *ResponseParameters) String() string + type SimpleRequest struct + FillOauthScope *bool + FillUsername *bool + Payload *Payload + ResponseSize *int32 + ResponseType *PayloadType + XXX_unrecognized []byte + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (m *SimpleRequest) GetFillOauthScope() bool + func (m *SimpleRequest) GetFillUsername() bool + func (m *SimpleRequest) GetPayload() *Payload + func (m *SimpleRequest) GetResponseSize() int32 + func (m *SimpleRequest) GetResponseType() PayloadType + func (m *SimpleRequest) Reset() + func (m *SimpleRequest) String() string + type SimpleResponse struct + OauthScope *string + Payload *Payload + Username *string + XXX_unrecognized []byte + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (m *SimpleResponse) GetOauthScope() string + func (m *SimpleResponse) GetPayload() *Payload + func (m *SimpleResponse) GetUsername() string + func (m *SimpleResponse) Reset() + func (m *SimpleResponse) String() string + type StreamingInputCallRequest struct + Payload *Payload + XXX_unrecognized []byte + func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingInputCallRequest) ProtoMessage() + func (m *StreamingInputCallRequest) GetPayload() *Payload + func (m *StreamingInputCallRequest) Reset() + func (m *StreamingInputCallRequest) String() string + type StreamingInputCallResponse struct + AggregatedPayloadSize *int32 + XXX_unrecognized []byte + func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingInputCallResponse) ProtoMessage() + func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 + func (m *StreamingInputCallResponse) Reset() + func (m *StreamingInputCallResponse) String() string + type StreamingOutputCallRequest struct + Payload *Payload + ResponseParameters []*ResponseParameters + ResponseType *PayloadType + XXX_unrecognized []byte + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (m *StreamingOutputCallRequest) GetPayload() *Payload + func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (m *StreamingOutputCallRequest) GetResponseType() PayloadType + func (m *StreamingOutputCallRequest) Reset() + func (m *StreamingOutputCallRequest) String() string + type StreamingOutputCallResponse struct + Payload *Payload + XXX_unrecognized []byte + func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingOutputCallResponse) ProtoMessage() + func (m *StreamingOutputCallResponse) GetPayload() *Payload + func (m *StreamingOutputCallResponse) Reset() + func (m *StreamingOutputCallResponse) String() string + type TestServiceClient interface + EmptyCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + FullDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error) + HalfDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error) + StreamingInputCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error) + StreamingOutputCall func(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error) + UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient + type TestServiceServer interface + EmptyCall func(context.Context, *Empty) (*Empty, error) + FullDuplexCall func(TestService_FullDuplexCallServer) error + HalfDuplexCall func(TestService_HalfDuplexCallServer) error + StreamingInputCall func(TestService_StreamingInputCallServer) error + StreamingOutputCall func(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error + UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + type TestService_FullDuplexCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + Send func(*StreamingOutputCallRequest) error + type TestService_FullDuplexCallServer interface + Recv func() (*StreamingOutputCallRequest, error) + Send func(*StreamingOutputCallResponse) error + type TestService_HalfDuplexCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + Send func(*StreamingOutputCallRequest) error + type TestService_HalfDuplexCallServer interface + Recv func() (*StreamingOutputCallRequest, error) + Send func(*StreamingOutputCallResponse) error + type TestService_StreamingInputCallClient interface + CloseAndRecv func() (*StreamingInputCallResponse, error) + Send func(*StreamingInputCallRequest) error + type TestService_StreamingInputCallServer interface + Recv func() (*StreamingInputCallRequest, error) + SendAndClose func(*StreamingInputCallResponse) error + type TestService_StreamingOutputCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + type TestService_StreamingOutputCallServer interface + Send func(*StreamingOutputCallResponse) error
Go to main page