Documentation
¶
Index ¶
- Variables
- type BoolValue
- type ClientConfigureRequest
- func (*ClientConfigureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfigureRequest) GetMetadata() []*ClientConfigureRequest_Metadata
- func (x *ClientConfigureRequest) GetTimeoutSec() int32
- func (x *ClientConfigureRequest) GetTypes() []ClientConfigureRequest_RpcType
- func (*ClientConfigureRequest) ProtoMessage()
- func (x *ClientConfigureRequest) ProtoReflect() protoreflect.Message
- func (x *ClientConfigureRequest) Reset()
- func (x *ClientConfigureRequest) String() string
- type ClientConfigureRequest_Metadata
- func (*ClientConfigureRequest_Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfigureRequest_Metadata) GetKey() string
- func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType
- func (x *ClientConfigureRequest_Metadata) GetValue() string
- func (*ClientConfigureRequest_Metadata) ProtoMessage()
- func (x *ClientConfigureRequest_Metadata) ProtoReflect() protoreflect.Message
- func (x *ClientConfigureRequest_Metadata) Reset()
- func (x *ClientConfigureRequest_Metadata) String() string
- type ClientConfigureRequest_RpcType
- func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor
- func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType
- func (ClientConfigureRequest_RpcType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber
- func (x ClientConfigureRequest_RpcType) String() string
- func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType
- type ClientConfigureResponse
- type EchoStatus
- type GrpclbRouteType
- func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor
- func (x GrpclbRouteType) Enum() *GrpclbRouteType
- func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)deprecated
- func (x GrpclbRouteType) Number() protoreflect.EnumNumber
- func (x GrpclbRouteType) String() string
- func (GrpclbRouteType) Type() protoreflect.EnumType
- type HookRequest
- func (*HookRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand
- func (x *HookRequest) GetGrpcCodeToReturn() int32
- func (x *HookRequest) GetGrpcStatusDescription() string
- func (x *HookRequest) GetServerPort() int32
- func (*HookRequest) ProtoMessage()
- func (x *HookRequest) ProtoReflect() protoreflect.Message
- func (x *HookRequest) Reset()
- func (x *HookRequest) String() string
- type HookRequest_HookRequestCommand
- func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor
- func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand
- func (HookRequest_HookRequestCommand) EnumDescriptor() ([]byte, []int)deprecated
- func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber
- func (x HookRequest_HookRequestCommand) String() string
- func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType
- type HookResponse
- type LoadBalancerAccumulatedStatsRequest
- func (*LoadBalancerAccumulatedStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsRequest) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsRequest) Reset()
- func (x *LoadBalancerAccumulatedStatsRequest) String() string
- type LoadBalancerAccumulatedStatsResponse
- func (*LoadBalancerAccumulatedStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats
- func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsResponse) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsResponse) Reset()
- func (x *LoadBalancerAccumulatedStatsResponse) String() string
- type LoadBalancerAccumulatedStatsResponse_MethodStats
- func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32
- func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string
- type LoadBalancerStatsRequest
- func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string
- func (x *LoadBalancerStatsRequest) GetNumRpcs() int32
- func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32
- func (*LoadBalancerStatsRequest) ProtoMessage()
- func (x *LoadBalancerStatsRequest) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsRequest) Reset()
- func (x *LoadBalancerStatsRequest) String() string
- type LoadBalancerStatsResponse
- func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer
- func (x *LoadBalancerStatsResponse) GetNumFailures() int32
- func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
- func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse) ProtoMessage()
- func (x *LoadBalancerStatsResponse) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse) Reset()
- func (x *LoadBalancerStatsResponse) String() string
- type LoadBalancerStatsResponse_MetadataByPeer
- func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata
- func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage()
- func (x *LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset()
- func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string
- type LoadBalancerStatsResponse_MetadataEntry
- func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string
- func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage()
- func (x *LoadBalancerStatsResponse_MetadataEntry) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_MetadataEntry) Reset()
- func (x *LoadBalancerStatsResponse_MetadataEntry) String() string
- type LoadBalancerStatsResponse_MetadataType
- func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor
- func (x LoadBalancerStatsResponse_MetadataType) Enum() *LoadBalancerStatsResponse_MetadataType
- func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor() ([]byte, []int)deprecated
- func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber
- func (x LoadBalancerStatsResponse_MetadataType) String() string
- func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType
- type LoadBalancerStatsResponse_RpcMetadata
- func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry
- func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()
- func (x *LoadBalancerStatsResponse_RpcMetadata) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_RpcMetadata) Reset()
- func (x *LoadBalancerStatsResponse_RpcMetadata) String() string
- type LoadBalancerStatsResponse_RpcsByPeer
- func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
- func (x *LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()
- func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string
- type MemorySize
- type Payload
- type PayloadType
- func (PayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x PayloadType) Enum() *PayloadType
- func (PayloadType) EnumDescriptor() ([]byte, []int)deprecated
- func (x PayloadType) Number() protoreflect.EnumNumber
- func (x PayloadType) String() string
- func (PayloadType) Type() protoreflect.EnumType
- type ReconnectInfo
- func (*ReconnectInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ReconnectInfo) GetBackoffMs() []int32
- func (x *ReconnectInfo) GetPassed() bool
- func (*ReconnectInfo) ProtoMessage()
- func (x *ReconnectInfo) ProtoReflect() protoreflect.Message
- func (x *ReconnectInfo) Reset()
- func (x *ReconnectInfo) String() string
- type ReconnectParams
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseParameters) GetCompressed() *BoolValue
- func (x *ResponseParameters) GetIntervalUs() int32
- func (x *ResponseParameters) GetSize() int32
- func (*ResponseParameters) ProtoMessage()
- func (x *ResponseParameters) ProtoReflect() protoreflect.Message
- func (x *ResponseParameters) Reset()
- func (x *ResponseParameters) String() string
- type SetReturnStatusRequest
- func (*SetReturnStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32
- func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string
- func (*SetReturnStatusRequest) ProtoMessage()
- func (x *SetReturnStatusRequest) ProtoReflect() protoreflect.Message
- func (x *SetReturnStatusRequest) Reset()
- func (x *SetReturnStatusRequest) String() string
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleRequest) GetExpectCompressed() *BoolValue
- func (x *SimpleRequest) GetFillGrpclbRouteType() bool
- func (x *SimpleRequest) GetFillOauthScope() bool
- func (x *SimpleRequest) GetFillServerId() bool
- func (x *SimpleRequest) GetFillUsername() bool
- func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport
- func (x *SimpleRequest) GetPayload() *Payload
- func (x *SimpleRequest) GetResponseCompressed() *BoolValue
- func (x *SimpleRequest) GetResponseSize() int32
- func (x *SimpleRequest) GetResponseStatus() *EchoStatus
- func (x *SimpleRequest) GetResponseType() PayloadType
- func (*SimpleRequest) ProtoMessage()
- func (x *SimpleRequest) ProtoReflect() protoreflect.Message
- func (x *SimpleRequest) Reset()
- func (x *SimpleRequest) String() string
- type SimpleResponse
- func (*SimpleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
- func (x *SimpleResponse) GetHostname() string
- func (x *SimpleResponse) GetOauthScope() string
- func (x *SimpleResponse) GetPayload() *Payload
- func (x *SimpleResponse) GetServerId() string
- func (x *SimpleResponse) GetUsername() string
- func (*SimpleResponse) ProtoMessage()
- func (x *SimpleResponse) ProtoReflect() protoreflect.Message
- func (x *SimpleResponse) Reset()
- func (x *SimpleResponse) String() string
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
- func (x *StreamingInputCallRequest) GetPayload() *Payload
- func (*StreamingInputCallRequest) ProtoMessage()
- func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallRequest) Reset()
- func (x *StreamingInputCallRequest) String() string
- type StreamingInputCallResponse
- func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
- func (*StreamingInputCallResponse) ProtoMessage()
- func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallResponse) Reset()
- func (x *StreamingInputCallResponse) String() string
- type StreamingOutputCallRequest
- func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport
- func (x *StreamingOutputCallRequest) GetPayload() *Payload
- func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
- func (*StreamingOutputCallRequest) ProtoMessage()
- func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallRequest) Reset()
- func (x *StreamingOutputCallRequest) String() string
- type StreamingOutputCallResponse
- func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallResponse) Reset()
- func (x *StreamingOutputCallResponse) String() string
- type TestOrcaReport
- func (*TestOrcaReport) Descriptor() ([]byte, []int)deprecated
- func (x *TestOrcaReport) GetCpuUtilization() float64
- func (x *TestOrcaReport) GetMemoryUtilization() float64
- func (x *TestOrcaReport) GetRequestCost() map[string]float64
- func (x *TestOrcaReport) GetUtilization() map[string]float64
- func (*TestOrcaReport) ProtoMessage()
- func (x *TestOrcaReport) ProtoReflect() protoreflect.Message
- func (x *TestOrcaReport) Reset()
- func (x *TestOrcaReport) String() string
Constants ¶
This section is empty.
Variables ¶
var ( PayloadType_name = map[int32]string{ 0: "COMPRESSABLE", } PayloadType_value = map[string]int32{ "COMPRESSABLE": 0, } )
Enum value maps for PayloadType.
var ( GrpclbRouteType_name = map[int32]string{ 0: "GRPCLB_ROUTE_TYPE_UNKNOWN", 1: "GRPCLB_ROUTE_TYPE_FALLBACK", 2: "GRPCLB_ROUTE_TYPE_BACKEND", } GrpclbRouteType_value = map[string]int32{ "GRPCLB_ROUTE_TYPE_UNKNOWN": 0, "GRPCLB_ROUTE_TYPE_FALLBACK": 1, "GRPCLB_ROUTE_TYPE_BACKEND": 2, } )
Enum value maps for GrpclbRouteType.
var ( LoadBalancerStatsResponse_MetadataType_name = map[int32]string{ 0: "UNKNOWN", 1: "INITIAL", 2: "TRAILING", } LoadBalancerStatsResponse_MetadataType_value = map[string]int32{ "UNKNOWN": 0, "INITIAL": 1, "TRAILING": 2, } )
Enum value maps for LoadBalancerStatsResponse_MetadataType.
var ( ClientConfigureRequest_RpcType_name = map[int32]string{ 0: "EMPTY_CALL", 1: "UNARY_CALL", } ClientConfigureRequest_RpcType_value = map[string]int32{ "EMPTY_CALL": 0, "UNARY_CALL": 1, } )
Enum value maps for ClientConfigureRequest_RpcType.
var ( HookRequest_HookRequestCommand_name = map[int32]string{ 0: "UNSPECIFIED", 1: "START", 2: "STOP", 3: "RETURN", } HookRequest_HookRequestCommand_value = map[string]int32{ "UNSPECIFIED": 0, "START": 1, "STOP": 2, "RETURN": 3, } )
Enum value maps for HookRequest_HookRequestCommand.
var File_grpc_testing_messages_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BoolValue ¶
type BoolValue struct {
// The bool value.
Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
TODO(dgq): Go back to using well-known types once https://github.com/grpc/grpc/issues/6980 has been fixed. import "google/protobuf/wrappers.proto";
func (*BoolValue) Descriptor
deprecated
func (*BoolValue) ProtoMessage ¶
func (*BoolValue) ProtoMessage()
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type ClientConfigureRequest ¶
type ClientConfigureRequest struct {
// The types of RPCs the client sends.
Types []ClientConfigureRequest_RpcType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"types,omitempty"`
// The collection of custom metadata to be attached to RPCs sent by the client.
Metadata []*ClientConfigureRequest_Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
// The deadline to use, in seconds, for all RPCs. If unset or zero, the
// client will use the default from the command-line.
TimeoutSec int32 `protobuf:"varint,3,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
// contains filtered or unexported fields
}
Configurations for a test client.
func (*ClientConfigureRequest) Descriptor
deprecated
func (*ClientConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.
func (*ClientConfigureRequest) GetMetadata ¶
func (x *ClientConfigureRequest) GetMetadata() []*ClientConfigureRequest_Metadata
func (*ClientConfigureRequest) GetTimeoutSec ¶
func (x *ClientConfigureRequest) GetTimeoutSec() int32
func (*ClientConfigureRequest) GetTypes ¶
func (x *ClientConfigureRequest) GetTypes() []ClientConfigureRequest_RpcType
func (*ClientConfigureRequest) ProtoMessage ¶
func (*ClientConfigureRequest) ProtoMessage()
func (*ClientConfigureRequest) ProtoReflect ¶
func (x *ClientConfigureRequest) ProtoReflect() protoreflect.Message
func (*ClientConfigureRequest) Reset ¶
func (x *ClientConfigureRequest) Reset()
func (*ClientConfigureRequest) String ¶
func (x *ClientConfigureRequest) String() string
type ClientConfigureRequest_Metadata ¶
type ClientConfigureRequest_Metadata struct {
Type ClientConfigureRequest_RpcType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"type,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
Metadata to be attached for the given type of RPCs.
func (*ClientConfigureRequest_Metadata) Descriptor
deprecated
func (*ClientConfigureRequest_Metadata) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.
func (*ClientConfigureRequest_Metadata) GetKey ¶
func (x *ClientConfigureRequest_Metadata) GetKey() string
func (*ClientConfigureRequest_Metadata) GetType ¶
func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType
func (*ClientConfigureRequest_Metadata) GetValue ¶
func (x *ClientConfigureRequest_Metadata) GetValue() string
func (*ClientConfigureRequest_Metadata) ProtoMessage ¶
func (*ClientConfigureRequest_Metadata) ProtoMessage()
func (*ClientConfigureRequest_Metadata) ProtoReflect ¶
func (x *ClientConfigureRequest_Metadata) ProtoReflect() protoreflect.Message
func (*ClientConfigureRequest_Metadata) Reset ¶
func (x *ClientConfigureRequest_Metadata) Reset()
func (*ClientConfigureRequest_Metadata) String ¶
func (x *ClientConfigureRequest_Metadata) String() string
type ClientConfigureRequest_RpcType ¶
type ClientConfigureRequest_RpcType int32
Type of RPCs to send.
const ( ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0 ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1 )
func (ClientConfigureRequest_RpcType) Descriptor ¶
func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor
func (ClientConfigureRequest_RpcType) Enum ¶
func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType
func (ClientConfigureRequest_RpcType) EnumDescriptor
deprecated
func (ClientConfigureRequest_RpcType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.
func (ClientConfigureRequest_RpcType) Number ¶
func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber
func (ClientConfigureRequest_RpcType) String ¶
func (x ClientConfigureRequest_RpcType) String() string
func (ClientConfigureRequest_RpcType) Type ¶
func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType
type ClientConfigureResponse ¶
type ClientConfigureResponse struct {
// contains filtered or unexported fields
}
Response for updating a test client's configuration.
func (*ClientConfigureResponse) Descriptor
deprecated
func (*ClientConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.
func (*ClientConfigureResponse) ProtoMessage ¶
func (*ClientConfigureResponse) ProtoMessage()
func (*ClientConfigureResponse) ProtoReflect ¶
func (x *ClientConfigureResponse) ProtoReflect() protoreflect.Message
func (*ClientConfigureResponse) Reset ¶
func (x *ClientConfigureResponse) Reset()
func (*ClientConfigureResponse) String ¶
func (x *ClientConfigureResponse) String() string
type EchoStatus ¶
type EchoStatus struct {
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.
func (*EchoStatus) Descriptor
deprecated
func (*EchoStatus) Descriptor() ([]byte, []int)
Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.
func (*EchoStatus) GetCode ¶
func (x *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶
func (x *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) ProtoReflect ¶
func (x *EchoStatus) ProtoReflect() protoreflect.Message
func (*EchoStatus) Reset ¶
func (x *EchoStatus) Reset()
func (*EchoStatus) String ¶
func (x *EchoStatus) String() string
type GrpclbRouteType ¶
type GrpclbRouteType int32
The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependent.
const ( // Server didn't detect the route that a client took to reach it. GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0 // Indicates that a client reached a server via gRPCLB fallback. GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1 // Indicates that a client reached a server as a gRPCLB-given backend. GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND GrpclbRouteType = 2 )
func (GrpclbRouteType) Descriptor ¶
func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor
func (GrpclbRouteType) Enum ¶
func (x GrpclbRouteType) Enum() *GrpclbRouteType
func (GrpclbRouteType) EnumDescriptor
deprecated
func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)
Deprecated: Use GrpclbRouteType.Descriptor instead.
func (GrpclbRouteType) Number ¶
func (x GrpclbRouteType) Number() protoreflect.EnumNumber
func (GrpclbRouteType) String ¶
func (x GrpclbRouteType) String() string
func (GrpclbRouteType) Type ¶
func (GrpclbRouteType) Type() protoreflect.EnumType
type HookRequest ¶
type HookRequest struct {
Command HookRequest_HookRequestCommand `protobuf:"varint,1,opt,name=command,proto3,enum=grpc.testing.HookRequest_HookRequestCommand" json:"command,omitempty"`
GrpcCodeToReturn int32 `protobuf:"varint,2,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"`
GrpcStatusDescription string `` /* 126-byte string literal not displayed */
// Server port to listen to
ServerPort int32 `protobuf:"varint,4,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
// contains filtered or unexported fields
}
func (*HookRequest) Descriptor
deprecated
func (*HookRequest) Descriptor() ([]byte, []int)
Deprecated: Use HookRequest.ProtoReflect.Descriptor instead.
func (*HookRequest) GetCommand ¶
func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand
func (*HookRequest) GetGrpcCodeToReturn ¶
func (x *HookRequest) GetGrpcCodeToReturn() int32
func (*HookRequest) GetGrpcStatusDescription ¶
func (x *HookRequest) GetGrpcStatusDescription() string
func (*HookRequest) GetServerPort ¶
func (x *HookRequest) GetServerPort() int32
func (*HookRequest) ProtoMessage ¶
func (*HookRequest) ProtoMessage()
func (*HookRequest) ProtoReflect ¶
func (x *HookRequest) ProtoReflect() protoreflect.Message
func (*HookRequest) Reset ¶
func (x *HookRequest) Reset()
func (*HookRequest) String ¶
func (x *HookRequest) String() string
type HookRequest_HookRequestCommand ¶
type HookRequest_HookRequestCommand int32
const ( // Default value HookRequest_UNSPECIFIED HookRequest_HookRequestCommand = 0 // Start the HTTP endpoint HookRequest_START HookRequest_HookRequestCommand = 1 // Stop HookRequest_STOP HookRequest_HookRequestCommand = 2 // Return from HTTP GET/POST HookRequest_RETURN HookRequest_HookRequestCommand = 3 )
func (HookRequest_HookRequestCommand) Descriptor ¶
func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor
func (HookRequest_HookRequestCommand) Enum ¶
func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand
func (HookRequest_HookRequestCommand) EnumDescriptor
deprecated
func (HookRequest_HookRequestCommand) EnumDescriptor() ([]byte, []int)
Deprecated: Use HookRequest_HookRequestCommand.Descriptor instead.
func (HookRequest_HookRequestCommand) Number ¶
func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber
func (HookRequest_HookRequestCommand) String ¶
func (x HookRequest_HookRequestCommand) String() string
func (HookRequest_HookRequestCommand) Type ¶
func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType
type HookResponse ¶
type HookResponse struct {
// contains filtered or unexported fields
}
func (*HookResponse) Descriptor
deprecated
func (*HookResponse) Descriptor() ([]byte, []int)
Deprecated: Use HookResponse.ProtoReflect.Descriptor instead.
func (*HookResponse) ProtoMessage ¶
func (*HookResponse) ProtoMessage()
func (*HookResponse) ProtoReflect ¶
func (x *HookResponse) ProtoReflect() protoreflect.Message
func (*HookResponse) Reset ¶
func (x *HookResponse) Reset()
func (*HookResponse) String ¶
func (x *HookResponse) String() string
type LoadBalancerAccumulatedStatsRequest ¶
type LoadBalancerAccumulatedStatsRequest struct {
// contains filtered or unexported fields
}
Request for retrieving a test client's accumulated stats.
func (*LoadBalancerAccumulatedStatsRequest) Descriptor
deprecated
func (*LoadBalancerAccumulatedStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage ¶
func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()
func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect ¶
func (x *LoadBalancerAccumulatedStatsRequest) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsRequest) Reset ¶
func (x *LoadBalancerAccumulatedStatsRequest) Reset()
func (*LoadBalancerAccumulatedStatsRequest) String ¶
func (x *LoadBalancerAccumulatedStatsRequest) String() string
type LoadBalancerAccumulatedStatsResponse ¶
type LoadBalancerAccumulatedStatsResponse struct {
// The total number of RPCs have ever issued for each type.
// Deprecated: use stats_per_method.rpcs_started instead.
//
// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
NumRpcsStartedByMethod map[string]int32 `` /* 208-byte string literal not displayed */
// The total number of RPCs have ever completed successfully for each type.
// Deprecated: use stats_per_method.result instead.
//
// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
NumRpcsSucceededByMethod map[string]int32 `` /* 214-byte string literal not displayed */
// The total number of RPCs have ever failed for each type.
// Deprecated: use stats_per_method.result instead.
//
// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
NumRpcsFailedByMethod map[string]int32 `` /* 205-byte string literal not displayed */
// Per-method RPC statistics. The key is the RpcType in string form; e.g.
// 'EMPTY_CALL' or 'UNARY_CALL'
StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 179-byte string literal not displayed */
// contains filtered or unexported fields
}
Accumulated stats for RPCs sent by a test client.
func (*LoadBalancerAccumulatedStatsResponse) Descriptor
deprecated
func (*LoadBalancerAccumulatedStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod
deprecated
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod
deprecated
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod
deprecated
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod ¶
func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats
func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage ¶
func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()
func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect ¶
func (x *LoadBalancerAccumulatedStatsResponse) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsResponse) Reset ¶
func (x *LoadBalancerAccumulatedStatsResponse) Reset()
func (*LoadBalancerAccumulatedStatsResponse) String ¶
func (x *LoadBalancerAccumulatedStatsResponse) String() string
type LoadBalancerAccumulatedStatsResponse_MethodStats ¶
type LoadBalancerAccumulatedStatsResponse_MethodStats struct {
// The number of RPCs that were started for this method.
RpcsStarted int32 `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"`
// The number of RPCs that completed with each status for this method. The
// key is the integral value of a google.rpc.Code; the value is the count.
Result map[int32]int32 `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor
deprecated
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult ¶
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted ¶
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage ¶
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect ¶
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset ¶
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String ¶
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string
type LoadBalancerStatsRequest ¶
type LoadBalancerStatsRequest struct {
// Request stats for the next num_rpcs sent by client.
NumRpcs int32 `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"`
// If num_rpcs have not completed within timeout_sec, return partial results.
TimeoutSec int32 `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
// Response header + trailer metadata entries we want the values of.
// Matching of the keys is case-insensitive as per rfc7540#section-8.1.2
// * (asterisk) is a special value that will return all metadata entries
MetadataKeys []string `protobuf:"bytes,3,rep,name=metadata_keys,json=metadataKeys,proto3" json:"metadata_keys,omitempty"`
// contains filtered or unexported fields
}
func (*LoadBalancerStatsRequest) Descriptor
deprecated
func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsRequest) GetMetadataKeys ¶
func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string
func (*LoadBalancerStatsRequest) GetNumRpcs ¶
func (x *LoadBalancerStatsRequest) GetNumRpcs() int32
func (*LoadBalancerStatsRequest) GetTimeoutSec ¶
func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32
func (*LoadBalancerStatsRequest) ProtoMessage ¶
func (*LoadBalancerStatsRequest) ProtoMessage()
func (*LoadBalancerStatsRequest) ProtoReflect ¶
func (x *LoadBalancerStatsRequest) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsRequest) Reset ¶
func (x *LoadBalancerStatsRequest) Reset()
func (*LoadBalancerStatsRequest) String ¶
func (x *LoadBalancerStatsRequest) String() string
type LoadBalancerStatsResponse ¶
type LoadBalancerStatsResponse struct {
// The number of completed RPCs for each peer.
RpcsByPeer map[string]int32 `` /* 168-byte string literal not displayed */
// The number of RPCs that failed to record a remote peer.
NumFailures int32 `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `` /* 173-byte string literal not displayed */
// All the metadata of all RPCs for each peer.
MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer `` /* 182-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LoadBalancerStatsResponse) Descriptor
deprecated
func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse) GetMetadatasByPeer ¶
func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer
func (*LoadBalancerStatsResponse) GetNumFailures ¶
func (x *LoadBalancerStatsResponse) GetNumFailures() int32
func (*LoadBalancerStatsResponse) GetRpcsByMethod ¶
func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
func (*LoadBalancerStatsResponse) GetRpcsByPeer ¶
func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse) ProtoMessage ¶
func (*LoadBalancerStatsResponse) ProtoMessage()
func (*LoadBalancerStatsResponse) ProtoReflect ¶
func (x *LoadBalancerStatsResponse) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse) Reset ¶
func (x *LoadBalancerStatsResponse) Reset()
func (*LoadBalancerStatsResponse) String ¶
func (x *LoadBalancerStatsResponse) String() string
type LoadBalancerStatsResponse_MetadataByPeer ¶
type LoadBalancerStatsResponse_MetadataByPeer struct {
// List of RpcMetadata in for each RPC with a given peer
RpcMetadata []*LoadBalancerStatsResponse_RpcMetadata `protobuf:"bytes,1,rep,name=rpc_metadata,json=rpcMetadata,proto3" json:"rpc_metadata,omitempty"`
// contains filtered or unexported fields
}
func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor
deprecated
func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataByPeer.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata ¶
func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage ¶
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage()
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect ¶
func (x *LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_MetadataByPeer) Reset ¶
func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset()
func (*LoadBalancerStatsResponse_MetadataByPeer) String ¶
func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string
type LoadBalancerStatsResponse_MetadataEntry ¶
type LoadBalancerStatsResponse_MetadataEntry struct {
// Key, exactly as received from the server. Case may be different from what
// was requested in the LoadBalancerStatsRequest)
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// Value, exactly as received from the server.
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// Metadata type
Type LoadBalancerStatsResponse_MetadataType `protobuf:"varint,3,opt,name=type,proto3,enum=grpc.testing.LoadBalancerStatsResponse_MetadataType" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor
deprecated
func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataEntry.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_MetadataEntry) GetKey ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string
func (*LoadBalancerStatsResponse_MetadataEntry) GetType ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType
func (*LoadBalancerStatsResponse_MetadataEntry) GetValue ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage ¶
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage()
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoReflect ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_MetadataEntry) Reset ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) Reset()
func (*LoadBalancerStatsResponse_MetadataEntry) String ¶
func (x *LoadBalancerStatsResponse_MetadataEntry) String() string
type LoadBalancerStatsResponse_MetadataType ¶
type LoadBalancerStatsResponse_MetadataType int32
const ( LoadBalancerStatsResponse_UNKNOWN LoadBalancerStatsResponse_MetadataType = 0 LoadBalancerStatsResponse_INITIAL LoadBalancerStatsResponse_MetadataType = 1 LoadBalancerStatsResponse_TRAILING LoadBalancerStatsResponse_MetadataType = 2 )
func (LoadBalancerStatsResponse_MetadataType) Descriptor ¶
func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor
func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor
deprecated
func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataType.Descriptor instead.
func (LoadBalancerStatsResponse_MetadataType) Number ¶
func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber
func (LoadBalancerStatsResponse_MetadataType) String ¶
func (x LoadBalancerStatsResponse_MetadataType) String() string
func (LoadBalancerStatsResponse_MetadataType) Type ¶
func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType
type LoadBalancerStatsResponse_RpcMetadata ¶
type LoadBalancerStatsResponse_RpcMetadata struct {
// metadata values for each rpc for the keys specified in
// LoadBalancerStatsRequest.metadata_keys.
Metadata []*LoadBalancerStatsResponse_MetadataEntry `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor
deprecated
func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_RpcMetadata.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_RpcMetadata) GetMetadata ¶
func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage ¶
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoReflect ¶
func (x *LoadBalancerStatsResponse_RpcMetadata) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_RpcMetadata) Reset ¶
func (x *LoadBalancerStatsResponse_RpcMetadata) Reset()
func (*LoadBalancerStatsResponse_RpcMetadata) String ¶
func (x *LoadBalancerStatsResponse_RpcMetadata) String() string
type LoadBalancerStatsResponse_RpcsByPeer ¶
type LoadBalancerStatsResponse_RpcsByPeer struct {
// The number of completed RPCs for each peer.
RpcsByPeer map[string]int32 `` /* 168-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor
deprecated
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer ¶
func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage ¶
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect ¶
func (x *LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_RpcsByPeer) Reset ¶
func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()
func (*LoadBalancerStatsResponse_RpcsByPeer) String ¶
func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string
type MemorySize ¶
type MemorySize struct {
Rss int64 `protobuf:"varint,1,opt,name=rss,proto3" json:"rss,omitempty"`
// contains filtered or unexported fields
}
func (*MemorySize) Descriptor
deprecated
func (*MemorySize) Descriptor() ([]byte, []int)
Deprecated: Use MemorySize.ProtoReflect.Descriptor instead.
func (*MemorySize) GetRss ¶
func (x *MemorySize) GetRss() int64
func (*MemorySize) ProtoMessage ¶
func (*MemorySize) ProtoMessage()
func (*MemorySize) ProtoReflect ¶
func (x *MemorySize) ProtoReflect() protoreflect.Message
func (*MemorySize) Reset ¶
func (x *MemorySize) Reset()
func (*MemorySize) String ¶
func (x *MemorySize) String() string
type Payload ¶
type Payload struct {
// The type of data in body.
Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
// Primary contents of payload.
Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
// contains filtered or unexported fields
}
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor
deprecated
func (*Payload) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type PayloadType ¶
type PayloadType int32
The type of payload that should be returned.
const ( // Compressable text format. PayloadType_COMPRESSABLE PayloadType = 0 )
func (PayloadType) Descriptor ¶
func (PayloadType) Descriptor() protoreflect.EnumDescriptor
func (PayloadType) Enum ¶
func (x PayloadType) Enum() *PayloadType
func (PayloadType) EnumDescriptor
deprecated
func (PayloadType) EnumDescriptor() ([]byte, []int)
Deprecated: Use PayloadType.Descriptor instead.
func (PayloadType) Number ¶
func (x PayloadType) Number() protoreflect.EnumNumber
func (PayloadType) String ¶
func (x PayloadType) String() string
func (PayloadType) Type ¶
func (PayloadType) Type() protoreflect.EnumType
type ReconnectInfo ¶
type ReconnectInfo struct {
Passed bool `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"`
// contains filtered or unexported fields
}
For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.
func (*ReconnectInfo) Descriptor
deprecated
func (*ReconnectInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.
func (*ReconnectInfo) GetBackoffMs ¶
func (x *ReconnectInfo) GetBackoffMs() []int32
func (*ReconnectInfo) GetPassed ¶
func (x *ReconnectInfo) GetPassed() bool
func (*ReconnectInfo) ProtoMessage ¶
func (*ReconnectInfo) ProtoMessage()
func (*ReconnectInfo) ProtoReflect ¶
func (x *ReconnectInfo) ProtoReflect() protoreflect.Message
func (*ReconnectInfo) Reset ¶
func (x *ReconnectInfo) Reset()
func (*ReconnectInfo) String ¶
func (x *ReconnectInfo) String() string
type ReconnectParams ¶
type ReconnectParams struct {
MaxReconnectBackoffMs int32 `` /* 129-byte string literal not displayed */
// contains filtered or unexported fields
}
For reconnect interop test only. Client tells server what reconnection parameters it used.
func (*ReconnectParams) Descriptor
deprecated
func (*ReconnectParams) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.
func (*ReconnectParams) GetMaxReconnectBackoffMs ¶
func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32
func (*ReconnectParams) ProtoMessage ¶
func (*ReconnectParams) ProtoMessage()
func (*ReconnectParams) ProtoReflect ¶
func (x *ReconnectParams) ProtoReflect() protoreflect.Message
func (*ReconnectParams) Reset ¶
func (x *ReconnectParams) Reset()
func (*ReconnectParams) String ¶
func (x *ReconnectParams) String() string
type ResponseParameters ¶
type ResponseParameters struct {
// Desired payload sizes in responses from the server.
Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
// Desired interval between consecutive responses in the response stream in
// microseconds.
IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
// Whether to request the server to compress the response. This field is
// "nullable" in order to interoperate seamlessly with clients not able to
// implement the full compression tests by introspecting the call to verify
// the response's compression status.
Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,omitempty"`
// contains filtered or unexported fields
}
Configuration for a particular response.
func (*ResponseParameters) Descriptor
deprecated
func (*ResponseParameters) Descriptor() ([]byte, []int)
Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.
func (*ResponseParameters) GetCompressed ¶
func (x *ResponseParameters) GetCompressed() *BoolValue
func (*ResponseParameters) GetIntervalUs ¶
func (x *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (x *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) ProtoReflect ¶
func (x *ResponseParameters) ProtoReflect() protoreflect.Message
func (*ResponseParameters) Reset ¶
func (x *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (x *ResponseParameters) String() string
type SetReturnStatusRequest ¶
type SetReturnStatusRequest struct {
GrpcCodeToReturn int32 `protobuf:"varint,1,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"`
GrpcStatusDescription string `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
Status that will be return to callers of the Hook method
func (*SetReturnStatusRequest) Descriptor
deprecated
func (*SetReturnStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetReturnStatusRequest.ProtoReflect.Descriptor instead.
func (*SetReturnStatusRequest) GetGrpcCodeToReturn ¶
func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32
func (*SetReturnStatusRequest) GetGrpcStatusDescription ¶
func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string
func (*SetReturnStatusRequest) ProtoMessage ¶
func (*SetReturnStatusRequest) ProtoMessage()
func (*SetReturnStatusRequest) ProtoReflect ¶
func (x *SetReturnStatusRequest) ProtoReflect() protoreflect.Message
func (*SetReturnStatusRequest) Reset ¶
func (x *SetReturnStatusRequest) Reset()
func (*SetReturnStatusRequest) String ¶
func (x *SetReturnStatusRequest) String() string
type SimpleRequest ¶
type SimpleRequest struct {
// Desired payload type in the response from the server.
// If response_type is RANDOM, server randomly chooses one from other formats.
ResponseType PayloadType `` /* 128-byte string literal not displayed */
// Desired payload size in the response from the server.
ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
// Whether SimpleResponse should include username.
FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
// Whether SimpleResponse should include OAuth scope.
FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
// Whether to request the server to compress the response. This field is
// "nullable" in order to interoperate seamlessly with clients not able to
// implement the full compression tests by introspecting the call to verify
// the response's compression status.
ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"`
// Whether server should return a given status
ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
// Whether the server should expect this request to be compressed.
ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
// Whether SimpleResponse should include server_id.
FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`
// Whether SimpleResponse should include grpclb_route_type.
FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"`
// If set the server should record this metrics report data for the current RPC.
OrcaPerQueryReport *TestOrcaReport `protobuf:"bytes,11,opt,name=orca_per_query_report,json=orcaPerQueryReport,proto3" json:"orca_per_query_report,omitempty"`
// contains filtered or unexported fields
}
Unary request.
func (*SimpleRequest) Descriptor
deprecated
func (*SimpleRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.
func (*SimpleRequest) GetExpectCompressed ¶
func (x *SimpleRequest) GetExpectCompressed() *BoolValue
func (*SimpleRequest) GetFillGrpclbRouteType ¶
func (x *SimpleRequest) GetFillGrpclbRouteType() bool
func (*SimpleRequest) GetFillOauthScope ¶
func (x *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillServerId ¶
func (x *SimpleRequest) GetFillServerId() bool
func (*SimpleRequest) GetFillUsername ¶
func (x *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetOrcaPerQueryReport ¶
func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport
func (*SimpleRequest) GetPayload ¶
func (x *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompressed ¶
func (x *SimpleRequest) GetResponseCompressed() *BoolValue
func (*SimpleRequest) GetResponseSize ¶
func (x *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶
func (x *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (x *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) ProtoReflect ¶
func (x *SimpleRequest) ProtoReflect() protoreflect.Message
func (*SimpleRequest) Reset ¶
func (x *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (x *SimpleRequest) String() string
type SimpleResponse ¶
type SimpleResponse struct {
// Payload to increase message size.
Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// The user the request came from, for verifying authentication was
// successful when the client expected it.
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
// OAuth scope.
OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
// Server ID. This must be unique among different server instances,
// but the same across all RPC's made to a particular server instance.
ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
// gRPCLB Path.
GrpclbRouteType GrpclbRouteType `` /* 143-byte string literal not displayed */
// Server hostname.
Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
// contains filtered or unexported fields
}
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor
deprecated
func (*SimpleResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.
func (*SimpleResponse) GetGrpclbRouteType ¶
func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
func (*SimpleResponse) GetHostname ¶
func (x *SimpleResponse) GetHostname() string
func (*SimpleResponse) GetOauthScope ¶
func (x *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (x *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetServerId ¶
func (x *SimpleResponse) GetServerId() string
func (*SimpleResponse) GetUsername ¶
func (x *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) ProtoReflect ¶
func (x *SimpleResponse) ProtoReflect() protoreflect.Message
func (*SimpleResponse) Reset ¶
func (x *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (x *SimpleResponse) String() string
type StreamingInputCallRequest ¶
type StreamingInputCallRequest struct {
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// Whether the server should expect this request to be compressed. This field
// is "nullable" in order to interoperate seamlessly with servers not able to
// implement the full compression tests by introspecting the call to verify
// the request's compression status.
ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
// contains filtered or unexported fields
}
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor
deprecated
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingInputCallRequest) GetExpectCompressed ¶
func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
func (*StreamingInputCallRequest) GetPayload ¶
func (x *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) ProtoReflect ¶
func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingInputCallRequest) Reset ¶
func (x *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (x *StreamingInputCallRequest) String() string
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct {
// Aggregated size of payloads received from the client.
AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */
// contains filtered or unexported fields
}
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor
deprecated
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingInputCallResponse) GetAggregatedPayloadSize ¶
func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage ¶
func (*StreamingInputCallResponse) ProtoMessage()
func (*StreamingInputCallResponse) ProtoReflect ¶
func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingInputCallResponse) Reset ¶
func (x *StreamingInputCallResponse) Reset()
func (*StreamingInputCallResponse) String ¶
func (x *StreamingInputCallResponse) String() string
type StreamingOutputCallRequest ¶
type StreamingOutputCallRequest struct {
// Desired payload type in the response from the server.
// If response_type is RANDOM, the payload from each response in the stream
// might be of different types. This is to simulate a mixed type of payload
// stream.
ResponseType PayloadType `` /* 128-byte string literal not displayed */
// Configuration for each expected response message.
ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
// Whether server should return a given status
ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
// If set the server should update this metrics report data at the OOB server.
OrcaOobReport *TestOrcaReport `protobuf:"bytes,8,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"`
// contains filtered or unexported fields
}
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor
deprecated
func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallRequest) GetOrcaOobReport ¶
func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport
func (*StreamingOutputCallRequest) GetPayload ¶
func (x *StreamingOutputCallRequest) GetPayload() *Payload
func (*StreamingOutputCallRequest) GetResponseParameters ¶
func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶
func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) ProtoReflect ¶
func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallRequest) Reset ¶
func (x *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (x *StreamingOutputCallRequest) String() string
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct {
// Payload to increase response size.
Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor
deprecated
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallResponse) GetPayload ¶
func (x *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage ¶
func (*StreamingOutputCallResponse) ProtoMessage()
func (*StreamingOutputCallResponse) ProtoReflect ¶
func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallResponse) Reset ¶
func (x *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (x *StreamingOutputCallResponse) String() string
type TestOrcaReport ¶
type TestOrcaReport struct {
CpuUtilization float64 `protobuf:"fixed64,1,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"`
MemoryUtilization float64 `protobuf:"fixed64,2,opt,name=memory_utilization,json=memoryUtilization,proto3" json:"memory_utilization,omitempty"`
RequestCost map[string]float64 `` /* 170-byte string literal not displayed */
Utilization map[string]float64 `` /* 151-byte string literal not displayed */
// contains filtered or unexported fields
}
Metrics data the server will update and send to the client. It mirrors orca load report https://github.com/cncf/xds/blob/eded343319d09f30032952beda9840bbd3dcf7ac/xds/data/orca/v3/orca_load_report.proto#L15, but avoids orca dependency. Used by both per-query and out-of-band reporting tests.
func (*TestOrcaReport) Descriptor
deprecated
func (*TestOrcaReport) Descriptor() ([]byte, []int)
Deprecated: Use TestOrcaReport.ProtoReflect.Descriptor instead.
func (*TestOrcaReport) GetCpuUtilization ¶
func (x *TestOrcaReport) GetCpuUtilization() float64
func (*TestOrcaReport) GetMemoryUtilization ¶
func (x *TestOrcaReport) GetMemoryUtilization() float64
func (*TestOrcaReport) GetRequestCost ¶
func (x *TestOrcaReport) GetRequestCost() map[string]float64
func (*TestOrcaReport) GetUtilization ¶
func (x *TestOrcaReport) GetUtilization() map[string]float64
func (*TestOrcaReport) ProtoMessage ¶
func (*TestOrcaReport) ProtoMessage()
func (*TestOrcaReport) ProtoReflect ¶
func (x *TestOrcaReport) ProtoReflect() protoreflect.Message
func (*TestOrcaReport) Reset ¶
func (x *TestOrcaReport) Reset()
func (*TestOrcaReport) String ¶
func (x *TestOrcaReport) String() string