Versions in this module Expand all Collapse all v1 v1.8.8 Apr 3, 2022 Changes in this version + const MetadataFailEarly + const MetadataFailLate + const MetadataReplyHeaders + const MetadataReplyTrailers + var File_test_proto protoreflect.FileDescriptor + var PayloadType_name = map[int32]string + var PayloadType_value = map[string]int32 + func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) + func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer) + type EchoStatus struct + Code int32 + Message string + func (*EchoStatus) Descriptor() ([]byte, []int) + func (*EchoStatus) ProtoMessage() + func (x *EchoStatus) GetCode() int32 + func (x *EchoStatus) GetMessage() string + func (x *EchoStatus) ProtoReflect() protoreflect.Message + func (x *EchoStatus) Reset() + func (x *EchoStatus) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type Payload struct + Body []byte + Type PayloadType + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (x *Payload) GetBody() []byte + func (x *Payload) GetType() PayloadType + func (x *Payload) ProtoReflect() protoreflect.Message + func (x *Payload) Reset() + func (x *Payload) String() string + type PayloadType int32 + const PayloadType_COMPRESSABLE + const PayloadType_RANDOM + const PayloadType_UNCOMPRESSABLE + func (PayloadType) Descriptor() protoreflect.EnumDescriptor + func (PayloadType) EnumDescriptor() ([]byte, []int) + func (PayloadType) Type() protoreflect.EnumType + func (x PayloadType) Enum() *PayloadType + func (x PayloadType) Number() protoreflect.EnumNumber + func (x PayloadType) String() string + type ResponseParameters struct + IntervalUs int32 + Size int32 + func (*ResponseParameters) Descriptor() ([]byte, []int) + func (*ResponseParameters) ProtoMessage() + func (x *ResponseParameters) GetIntervalUs() int32 + func (x *ResponseParameters) GetSize() int32 + func (x *ResponseParameters) ProtoReflect() protoreflect.Message + func (x *ResponseParameters) Reset() + func (x *ResponseParameters) String() string + type SimpleRequest struct + FillOauthScope bool + FillUsername bool + Payload *Payload + ResponseSize int32 + ResponseStatus *EchoStatus + ResponseType PayloadType + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (x *SimpleRequest) GetFillOauthScope() bool + func (x *SimpleRequest) GetFillUsername() bool + func (x *SimpleRequest) GetPayload() *Payload + func (x *SimpleRequest) GetResponseSize() int32 + func (x *SimpleRequest) GetResponseStatus() *EchoStatus + func (x *SimpleRequest) GetResponseType() PayloadType + func (x *SimpleRequest) ProtoReflect() protoreflect.Message + func (x *SimpleRequest) Reset() + func (x *SimpleRequest) String() string + type SimpleResponse struct + OauthScope string + Payload *Payload + Username string + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (x *SimpleResponse) GetOauthScope() string + func (x *SimpleResponse) GetPayload() *Payload + func (x *SimpleResponse) GetUsername() string + func (x *SimpleResponse) ProtoReflect() protoreflect.Message + func (x *SimpleResponse) Reset() + func (x *SimpleResponse) String() string + type StreamingInputCallRequest struct + Payload *Payload + func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingInputCallRequest) ProtoMessage() + func (x *StreamingInputCallRequest) GetPayload() *Payload + func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallRequest) Reset() + func (x *StreamingInputCallRequest) String() string + type StreamingInputCallResponse struct + AggregatedPayloadSize int32 + func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingInputCallResponse) ProtoMessage() + func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 + func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallResponse) Reset() + func (x *StreamingInputCallResponse) String() string + type StreamingOutputCallRequest struct + Payload *Payload + ResponseParameters []*ResponseParameters + ResponseStatus *EchoStatus + ResponseType PayloadType + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (x *StreamingOutputCallRequest) GetPayload() *Payload + func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus + func (x *StreamingOutputCallRequest) GetResponseType() PayloadType + func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallRequest) Reset() + func (x *StreamingOutputCallRequest) String() string + type StreamingOutputCallResponse struct + Payload *Payload + func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingOutputCallResponse) ProtoMessage() + func (x *StreamingOutputCallResponse) GetPayload() *Payload + func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallResponse) Reset() + func (x *StreamingOutputCallResponse) String() string + type TestServer struct + func (TestServer) EmptyCall(ctx context.Context, req *Empty) (*Empty, error) + func (TestServer) FullDuplexCall(str TestService_FullDuplexCallServer) error + func (TestServer) HalfDuplexCall(str TestService_HalfDuplexCallServer) error + func (TestServer) StreamingInputCall(str TestService_StreamingInputCallServer) error + func (TestServer) StreamingOutputCall(req *StreamingOutputCallRequest, str TestService_StreamingOutputCallServer) error + func (TestServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error) + 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.ClientConnInterface) 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 + type UnimplementedServiceClient interface + UnimplementedCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient + type UnimplementedServiceServer interface + UnimplementedCall func(context.Context, *Empty) (*Empty, error) + type UnimplementedTestServiceServer struct + func (*UnimplementedTestServiceServer) EmptyCall(context.Context, *Empty) (*Empty, error) + func (*UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error + func (*UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error + func (*UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error + func (*UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error + func (*UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) + type UnimplementedUnimplementedServiceServer struct + func (*UnimplementedUnimplementedServiceServer) UnimplementedCall(context.Context, *Empty) (*Empty, error)
Go to main page