Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + var GrpclbRouteType_name = map[int32]string + var GrpclbRouteType_value = map[string]int32 + var PayloadType_name = map[int32]string + var PayloadType_value = map[string]int32 + func RegisterLoadBalancerStatsServiceServer(s *grpc.Server, srv LoadBalancerStatsServiceServer) + func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) + func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer) + type EchoStatus struct + Code int32 + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EchoStatus) Descriptor() ([]byte, []int) + func (*EchoStatus) ProtoMessage() + func (m *EchoStatus) GetCode() int32 + func (m *EchoStatus) GetMessage() string + func (m *EchoStatus) Reset() + func (m *EchoStatus) String() string + func (m *EchoStatus) XXX_DiscardUnknown() + func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EchoStatus) XXX_Merge(src proto.Message) + func (m *EchoStatus) XXX_Size() int + func (m *EchoStatus) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 GrpclbRouteType int32 + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN + func (GrpclbRouteType) EnumDescriptor() ([]byte, []int) + func (x GrpclbRouteType) String() string + type LoadBalancerStatsRequest struct + NumRpcs int32 + TimeoutSec int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsRequest) ProtoMessage() + func (m *LoadBalancerStatsRequest) GetNumRpcs() int32 + func (m *LoadBalancerStatsRequest) GetTimeoutSec() int32 + func (m *LoadBalancerStatsRequest) Reset() + func (m *LoadBalancerStatsRequest) String() string + func (m *LoadBalancerStatsRequest) XXX_DiscardUnknown() + func (m *LoadBalancerStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadBalancerStatsRequest) XXX_Merge(src proto.Message) + func (m *LoadBalancerStatsRequest) XXX_Size() int + func (m *LoadBalancerStatsRequest) XXX_Unmarshal(b []byte) error + type LoadBalancerStatsResponse struct + NumFailures int32 + RpcsByPeer map[string]int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse) ProtoMessage() + func (m *LoadBalancerStatsResponse) GetNumFailures() int32 + func (m *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32 + func (m *LoadBalancerStatsResponse) Reset() + func (m *LoadBalancerStatsResponse) String() string + func (m *LoadBalancerStatsResponse) XXX_DiscardUnknown() + func (m *LoadBalancerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadBalancerStatsResponse) XXX_Merge(src proto.Message) + func (m *LoadBalancerStatsResponse) XXX_Size() int + func (m *LoadBalancerStatsResponse) XXX_Unmarshal(b []byte) error + type LoadBalancerStatsServiceClient interface + GetClientStats func(ctx context.Context, in *LoadBalancerStatsRequest, opts ...grpc.CallOption) (*LoadBalancerStatsResponse, error) + func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient + type LoadBalancerStatsServiceServer interface + GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) + type Payload struct + Body []byte + Type PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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 + func (m *Payload) XXX_DiscardUnknown() + func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Payload) XXX_Merge(src proto.Message) + func (m *Payload) XXX_Size() int + func (m *Payload) XXX_Unmarshal(b []byte) error + type PayloadType int32 + const PayloadType_COMPRESSABLE + const PayloadType_RANDOM + const PayloadType_UNCOMPRESSABLE + func (PayloadType) EnumDescriptor() ([]byte, []int) + func (x PayloadType) String() string + type ResponseParameters struct + IntervalUs int32 + Size int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache 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 + func (m *ResponseParameters) XXX_DiscardUnknown() + func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseParameters) XXX_Merge(src proto.Message) + func (m *ResponseParameters) XXX_Size() int + func (m *ResponseParameters) XXX_Unmarshal(b []byte) error + type SimpleRequest struct + FillGrpclbRouteType bool + FillOauthScope bool + FillServerId bool + FillUsername bool + Payload *Payload + ResponseSize int32 + ResponseStatus *EchoStatus + ResponseType PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (m *SimpleRequest) GetFillGrpclbRouteType() bool + func (m *SimpleRequest) GetFillOauthScope() bool + func (m *SimpleRequest) GetFillServerId() bool + func (m *SimpleRequest) GetFillUsername() bool + func (m *SimpleRequest) GetPayload() *Payload + func (m *SimpleRequest) GetResponseSize() int32 + func (m *SimpleRequest) GetResponseStatus() *EchoStatus + func (m *SimpleRequest) GetResponseType() PayloadType + func (m *SimpleRequest) Reset() + func (m *SimpleRequest) String() string + func (m *SimpleRequest) XXX_DiscardUnknown() + func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimpleRequest) XXX_Merge(src proto.Message) + func (m *SimpleRequest) XXX_Size() int + func (m *SimpleRequest) XXX_Unmarshal(b []byte) error + type SimpleResponse struct + GrpclbRouteType GrpclbRouteType + Hostname string + OauthScope string + Payload *Payload + ServerId string + Username string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType + func (m *SimpleResponse) GetHostname() string + func (m *SimpleResponse) GetOauthScope() string + func (m *SimpleResponse) GetPayload() *Payload + func (m *SimpleResponse) GetServerId() string + func (m *SimpleResponse) GetUsername() string + func (m *SimpleResponse) Reset() + func (m *SimpleResponse) String() string + func (m *SimpleResponse) XXX_DiscardUnknown() + func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimpleResponse) XXX_Merge(src proto.Message) + func (m *SimpleResponse) XXX_Size() int + func (m *SimpleResponse) XXX_Unmarshal(b []byte) error + type StreamingInputCallRequest struct + Payload *Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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 + func (m *StreamingInputCallRequest) XXX_DiscardUnknown() + func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message) + func (m *StreamingInputCallRequest) XXX_Size() int + func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error + type StreamingInputCallResponse struct + AggregatedPayloadSize int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache 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 + func (m *StreamingInputCallResponse) XXX_DiscardUnknown() + func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message) + func (m *StreamingInputCallResponse) XXX_Size() int + func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error + type StreamingOutputCallRequest struct + Payload *Payload + ResponseParameters []*ResponseParameters + ResponseStatus *EchoStatus + ResponseType PayloadType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (m *StreamingOutputCallRequest) GetPayload() *Payload + func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus + func (m *StreamingOutputCallRequest) GetResponseType() PayloadType + func (m *StreamingOutputCallRequest) Reset() + func (m *StreamingOutputCallRequest) String() string + func (m *StreamingOutputCallRequest) XXX_DiscardUnknown() + func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message) + func (m *StreamingOutputCallRequest) XXX_Size() int + func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error + type StreamingOutputCallResponse struct + Payload *Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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 + func (m *StreamingOutputCallResponse) XXX_DiscardUnknown() + func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message) + func (m *StreamingOutputCallResponse) XXX_Size() int + func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) 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 UnimplementedLoadBalancerStatsServiceServer struct + func (*UnimplementedLoadBalancerStatsServiceServer) GetClientStats(ctx context.Context, req *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, 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(ctx context.Context, req *Empty) (*Empty, error) + func (*UnimplementedTestServiceServer) FullDuplexCall(srv TestService_FullDuplexCallServer) error + func (*UnimplementedTestServiceServer) HalfDuplexCall(srv TestService_HalfDuplexCallServer) error + func (*UnimplementedTestServiceServer) StreamingInputCall(srv TestService_StreamingInputCallServer) error + func (*UnimplementedTestServiceServer) StreamingOutputCall(req *StreamingOutputCallRequest, srv TestService_StreamingOutputCallServer) error + func (*UnimplementedTestServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error) + type UnimplementedUnimplementedServiceServer struct + func (*UnimplementedUnimplementedServiceServer) UnimplementedCall(ctx context.Context, req *Empty) (*Empty, error)