Documentation ¶
Index ¶
- Variables
- type BoolValue
- type ByteBufferParams
- func (*ByteBufferParams) Descriptor() ([]byte, []int)deprecated
- func (x *ByteBufferParams) GetReqSize() int32
- func (x *ByteBufferParams) GetRespSize() int32
- func (*ByteBufferParams) ProtoMessage()
- func (x *ByteBufferParams) ProtoReflect() protoreflect.Message
- func (x *ByteBufferParams) Reset()
- func (x *ByteBufferParams) String() string
- type ChannelArg
- func (*ChannelArg) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelArg) GetIntValue() int32
- func (x *ChannelArg) GetName() string
- func (x *ChannelArg) GetStrValue() string
- func (m *ChannelArg) GetValue() isChannelArg_Value
- func (*ChannelArg) ProtoMessage()
- func (x *ChannelArg) ProtoReflect() protoreflect.Message
- func (x *ChannelArg) Reset()
- func (x *ChannelArg) String() string
- type ChannelArg_IntValue
- type ChannelArg_StrValue
- type ClientArgs
- func (*ClientArgs) Descriptor() ([]byte, []int)deprecated
- func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
- func (x *ClientArgs) GetMark() *Mark
- func (x *ClientArgs) GetSetup() *ClientConfig
- func (*ClientArgs) ProtoMessage()
- func (x *ClientArgs) ProtoReflect() protoreflect.Message
- func (x *ClientArgs) Reset()
- func (x *ClientArgs) String() string
- type ClientArgs_Mark
- type ClientArgs_Setup
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfig) GetAsyncClientThreads() int32
- func (x *ClientConfig) GetChannelArgs() []*ChannelArg
- func (x *ClientConfig) GetClientChannels() int32
- func (x *ClientConfig) GetClientProcesses() int32
- func (x *ClientConfig) GetClientType() ClientType
- func (x *ClientConfig) GetCoreLimit() int32
- func (x *ClientConfig) GetCoreList() []int32
- func (x *ClientConfig) GetHistogramParams() *HistogramParams
- func (x *ClientConfig) GetLoadParams() *LoadParams
- func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32
- func (x *ClientConfig) GetMessagesPerStream() int32
- func (x *ClientConfig) GetOtherClientApi() string
- func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32
- func (x *ClientConfig) GetPayloadConfig() *PayloadConfig
- func (x *ClientConfig) GetRpcType() RpcType
- func (x *ClientConfig) GetSecurityParams() *SecurityParams
- func (x *ClientConfig) GetServerTargets() []string
- func (x *ClientConfig) GetThreadsPerCq() int32
- func (x *ClientConfig) GetUseCoalesceApi() bool
- func (*ClientConfig) ProtoMessage()
- func (x *ClientConfig) ProtoReflect() protoreflect.Message
- func (x *ClientConfig) Reset()
- func (x *ClientConfig) String() string
- 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 ClientStats
- func (*ClientStats) Descriptor() ([]byte, []int)deprecated
- func (x *ClientStats) GetCoreStats() *core.Stats
- func (x *ClientStats) GetCqPollCount() uint64
- func (x *ClientStats) GetLatencies() *HistogramData
- func (x *ClientStats) GetRequestResults() []*RequestResultCount
- func (x *ClientStats) GetTimeElapsed() float64
- func (x *ClientStats) GetTimeSystem() float64
- func (x *ClientStats) GetTimeUser() float64
- func (*ClientStats) ProtoMessage()
- func (x *ClientStats) ProtoReflect() protoreflect.Message
- func (x *ClientStats) Reset()
- func (x *ClientStats) String() string
- type ClientStatus
- type ClientType
- type ClosedLoopParams
- type ComplexProtoParams
- type CoreRequest
- type CoreResponse
- type EchoStatus
- type Empty
- 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 HistogramData
- func (*HistogramData) Descriptor() ([]byte, []int)deprecated
- func (x *HistogramData) GetBucket() []uint32
- func (x *HistogramData) GetCount() float64
- func (x *HistogramData) GetMaxSeen() float64
- func (x *HistogramData) GetMinSeen() float64
- func (x *HistogramData) GetSum() float64
- func (x *HistogramData) GetSumOfSquares() float64
- func (*HistogramData) ProtoMessage()
- func (x *HistogramData) ProtoReflect() protoreflect.Message
- func (x *HistogramData) Reset()
- func (x *HistogramData) String() string
- type HistogramParams
- func (*HistogramParams) Descriptor() ([]byte, []int)deprecated
- func (x *HistogramParams) GetMaxPossible() float64
- func (x *HistogramParams) GetResolution() float64
- func (*HistogramParams) ProtoMessage()
- func (x *HistogramParams) ProtoReflect() protoreflect.Message
- func (x *HistogramParams) Reset()
- func (x *HistogramParams) String() string
- 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) 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) 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_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 LoadParams
- func (*LoadParams) Descriptor() ([]byte, []int)deprecated
- func (x *LoadParams) GetClosedLoop() *ClosedLoopParams
- func (m *LoadParams) GetLoad() isLoadParams_Load
- func (x *LoadParams) GetPoisson() *PoissonParams
- func (*LoadParams) ProtoMessage()
- func (x *LoadParams) ProtoReflect() protoreflect.Message
- func (x *LoadParams) Reset()
- func (x *LoadParams) String() string
- type LoadParams_ClosedLoop
- type LoadParams_Poisson
- type Mark
- type Payload
- type PayloadConfig
- func (*PayloadConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams
- func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams
- func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
- func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams
- func (*PayloadConfig) ProtoMessage()
- func (x *PayloadConfig) ProtoReflect() protoreflect.Message
- func (x *PayloadConfig) Reset()
- func (x *PayloadConfig) String() string
- type PayloadConfig_BytebufParams
- type PayloadConfig_ComplexParams
- type PayloadConfig_SimpleParams
- 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 PoissonParams
- 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 RequestResultCount
- func (*RequestResultCount) Descriptor() ([]byte, []int)deprecated
- func (x *RequestResultCount) GetCount() int64
- func (x *RequestResultCount) GetStatusCode() int32
- func (*RequestResultCount) ProtoMessage()
- func (x *RequestResultCount) ProtoReflect() protoreflect.Message
- func (x *RequestResultCount) Reset()
- func (x *RequestResultCount) String() string
- 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 RpcType
- type Scenario
- func (*Scenario) Descriptor() ([]byte, []int)deprecated
- func (x *Scenario) GetBenchmarkSeconds() int32
- func (x *Scenario) GetClientConfig() *ClientConfig
- func (x *Scenario) GetName() string
- func (x *Scenario) GetNumClients() int32
- func (x *Scenario) GetNumServers() int32
- func (x *Scenario) GetServerConfig() *ServerConfig
- func (x *Scenario) GetSpawnLocalWorkerCount() int32
- func (x *Scenario) GetWarmupSeconds() int32
- func (*Scenario) ProtoMessage()
- func (x *Scenario) ProtoReflect() protoreflect.Message
- func (x *Scenario) Reset()
- func (x *Scenario) String() string
- type ScenarioResult
- func (*ScenarioResult) Descriptor() ([]byte, []int)deprecated
- func (x *ScenarioResult) GetClientStats() []*ClientStats
- func (x *ScenarioResult) GetClientSuccess() []bool
- func (x *ScenarioResult) GetLatencies() *HistogramData
- func (x *ScenarioResult) GetRequestResults() []*RequestResultCount
- func (x *ScenarioResult) GetScenario() *Scenario
- func (x *ScenarioResult) GetServerCores() []int32
- func (x *ScenarioResult) GetServerStats() []*ServerStats
- func (x *ScenarioResult) GetServerSuccess() []bool
- func (x *ScenarioResult) GetSummary() *ScenarioResultSummary
- func (*ScenarioResult) ProtoMessage()
- func (x *ScenarioResult) ProtoReflect() protoreflect.Message
- func (x *ScenarioResult) Reset()
- func (x *ScenarioResult) String() string
- type ScenarioResultSummary
- func (*ScenarioResultSummary) Descriptor() ([]byte, []int)deprecated
- func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64
- func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64
- func (x *ScenarioResultSummary) GetClientSystemTime() float64
- func (x *ScenarioResultSummary) GetClientUserTime() float64
- func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp
- func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64
- func (x *ScenarioResultSummary) GetLatency_50() float64
- func (x *ScenarioResultSummary) GetLatency_90() float64
- func (x *ScenarioResultSummary) GetLatency_95() float64
- func (x *ScenarioResultSummary) GetLatency_99() float64
- func (x *ScenarioResultSummary) GetLatency_999() float64
- func (x *ScenarioResultSummary) GetQps() float64
- func (x *ScenarioResultSummary) GetQpsPerServerCore() float64
- func (x *ScenarioResultSummary) GetServerCpuUsage() float64
- func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64
- func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64
- func (x *ScenarioResultSummary) GetServerSystemTime() float64
- func (x *ScenarioResultSummary) GetServerUserTime() float64
- func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp
- func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64
- func (*ScenarioResultSummary) ProtoMessage()
- func (x *ScenarioResultSummary) ProtoReflect() protoreflect.Message
- func (x *ScenarioResultSummary) Reset()
- func (x *ScenarioResultSummary) String() string
- type Scenarios
- type SecurityParams
- func (*SecurityParams) Descriptor() ([]byte, []int)deprecated
- func (x *SecurityParams) GetCredType() string
- func (x *SecurityParams) GetServerHostOverride() string
- func (x *SecurityParams) GetUseTestCa() bool
- func (*SecurityParams) ProtoMessage()
- func (x *SecurityParams) ProtoReflect() protoreflect.Message
- func (x *SecurityParams) Reset()
- func (x *SecurityParams) String() string
- type ServerArgs
- func (*ServerArgs) Descriptor() ([]byte, []int)deprecated
- func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
- func (x *ServerArgs) GetMark() *Mark
- func (x *ServerArgs) GetSetup() *ServerConfig
- func (*ServerArgs) ProtoMessage()
- func (x *ServerArgs) ProtoReflect() protoreflect.Message
- func (x *ServerArgs) Reset()
- func (x *ServerArgs) String() string
- type ServerArgs_Mark
- type ServerArgs_Setup
- type ServerConfig
- func (*ServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ServerConfig) GetAsyncServerThreads() int32
- func (x *ServerConfig) GetChannelArgs() []*ChannelArg
- func (x *ServerConfig) GetCoreLimit() int32
- func (x *ServerConfig) GetCoreList() []int32
- func (x *ServerConfig) GetOtherServerApi() string
- func (x *ServerConfig) GetPayloadConfig() *PayloadConfig
- func (x *ServerConfig) GetPort() int32
- func (x *ServerConfig) GetResourceQuotaSize() int32
- func (x *ServerConfig) GetSecurityParams() *SecurityParams
- func (x *ServerConfig) GetServerProcesses() int32
- func (x *ServerConfig) GetServerType() ServerType
- func (x *ServerConfig) GetThreadsPerCq() int32
- func (*ServerConfig) ProtoMessage()
- func (x *ServerConfig) ProtoReflect() protoreflect.Message
- func (x *ServerConfig) Reset()
- func (x *ServerConfig) String() string
- type ServerStats
- func (*ServerStats) Descriptor() ([]byte, []int)deprecated
- func (x *ServerStats) GetCoreStats() *core.Stats
- func (x *ServerStats) GetCqPollCount() uint64
- func (x *ServerStats) GetIdleCpuTime() uint64
- func (x *ServerStats) GetTimeElapsed() float64
- func (x *ServerStats) GetTimeSystem() float64
- func (x *ServerStats) GetTimeUser() float64
- func (x *ServerStats) GetTotalCpuTime() uint64
- func (*ServerStats) ProtoMessage()
- func (x *ServerStats) ProtoReflect() protoreflect.Message
- func (x *ServerStats) Reset()
- func (x *ServerStats) String() string
- type ServerStatus
- func (*ServerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ServerStatus) GetCores() int32
- func (x *ServerStatus) GetPort() int32
- func (x *ServerStatus) GetStats() *ServerStats
- func (*ServerStatus) ProtoMessage()
- func (x *ServerStatus) ProtoReflect() protoreflect.Message
- func (x *ServerStatus) Reset()
- func (x *ServerStatus) String() string
- type ServerType
- type SimpleProtoParams
- func (*SimpleProtoParams) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleProtoParams) GetReqSize() int32
- func (x *SimpleProtoParams) GetRespSize() int32
- func (*SimpleProtoParams) ProtoMessage()
- func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message
- func (x *SimpleProtoParams) Reset()
- func (x *SimpleProtoParams) 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) GetOrcaOobReport() *TestOrcaReport
- 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
- type Void
Constants ¶
This section is empty.
Variables ¶
var ( ClientType_name = map[int32]string{ 0: "SYNC_CLIENT", 1: "ASYNC_CLIENT", 2: "OTHER_CLIENT", 3: "CALLBACK_CLIENT", } ClientType_value = map[string]int32{ "SYNC_CLIENT": 0, "ASYNC_CLIENT": 1, "OTHER_CLIENT": 2, "CALLBACK_CLIENT": 3, } )
Enum value maps for ClientType.
var ( ServerType_name = map[int32]string{ 0: "SYNC_SERVER", 1: "ASYNC_SERVER", 2: "ASYNC_GENERIC_SERVER", 3: "OTHER_SERVER", 4: "CALLBACK_SERVER", } ServerType_value = map[string]int32{ "SYNC_SERVER": 0, "ASYNC_SERVER": 1, "ASYNC_GENERIC_SERVER": 2, "OTHER_SERVER": 3, "CALLBACK_SERVER": 4, } )
Enum value maps for ServerType.
var ( RpcType_name = map[int32]string{ 0: "UNARY", 1: "STREAMING", 2: "STREAMING_FROM_CLIENT", 3: "STREAMING_FROM_SERVER", 4: "STREAMING_BOTH_WAYS", } RpcType_value = map[string]int32{ "UNARY": 0, "STREAMING": 1, "STREAMING_FROM_CLIENT": 2, "STREAMING_FROM_SERVER": 3, "STREAMING_BOTH_WAYS": 4, } )
Enum value maps for RpcType.
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 ( 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 File_grpc_testing_benchmark_service_proto protoreflect.FileDescriptor
var File_grpc_testing_control_proto protoreflect.FileDescriptor
var File_grpc_testing_empty_proto protoreflect.FileDescriptor
var File_grpc_testing_messages_proto protoreflect.FileDescriptor
var File_grpc_testing_payloads_proto protoreflect.FileDescriptor
var File_grpc_testing_report_qps_scenario_service_proto protoreflect.FileDescriptor
var File_grpc_testing_stats_proto protoreflect.FileDescriptor
var File_grpc_testing_test_proto protoreflect.FileDescriptor
var File_grpc_testing_worker_service_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BoolValue ¶
type BoolValue struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type ByteBufferParams ¶
type ByteBufferParams struct { ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"` // contains filtered or unexported fields }
func (*ByteBufferParams) Descriptor
deprecated
func (*ByteBufferParams) Descriptor() ([]byte, []int)
Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.
func (*ByteBufferParams) GetReqSize ¶
func (x *ByteBufferParams) GetReqSize() int32
func (*ByteBufferParams) GetRespSize ¶
func (x *ByteBufferParams) GetRespSize() int32
func (*ByteBufferParams) ProtoMessage ¶
func (*ByteBufferParams) ProtoMessage()
func (*ByteBufferParams) ProtoReflect ¶
func (x *ByteBufferParams) ProtoReflect() protoreflect.Message
func (*ByteBufferParams) Reset ¶
func (x *ByteBufferParams) Reset()
func (*ByteBufferParams) String ¶
func (x *ByteBufferParams) String() string
type ChannelArg ¶
type ChannelArg struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Value: // // *ChannelArg_StrValue // *ChannelArg_IntValue Value isChannelArg_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*ChannelArg) Descriptor
deprecated
func (*ChannelArg) Descriptor() ([]byte, []int)
Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.
func (*ChannelArg) GetIntValue ¶
func (x *ChannelArg) GetIntValue() int32
func (*ChannelArg) GetName ¶
func (x *ChannelArg) GetName() string
func (*ChannelArg) GetStrValue ¶
func (x *ChannelArg) GetStrValue() string
func (*ChannelArg) GetValue ¶
func (m *ChannelArg) GetValue() isChannelArg_Value
func (*ChannelArg) ProtoMessage ¶
func (*ChannelArg) ProtoMessage()
func (*ChannelArg) ProtoReflect ¶
func (x *ChannelArg) ProtoReflect() protoreflect.Message
func (*ChannelArg) Reset ¶
func (x *ChannelArg) Reset()
func (*ChannelArg) String ¶
func (x *ChannelArg) String() string
type ChannelArg_IntValue ¶
type ChannelArg_IntValue struct {
IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}
type ChannelArg_StrValue ¶
type ChannelArg_StrValue struct {
StrValue string `protobuf:"bytes,2,opt,name=str_value,json=strValue,proto3,oneof"`
}
type ClientArgs ¶
type ClientArgs struct { // Types that are assignable to Argtype: // // *ClientArgs_Setup // *ClientArgs_Mark Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"` // contains filtered or unexported fields }
func (*ClientArgs) Descriptor
deprecated
func (*ClientArgs) Descriptor() ([]byte, []int)
Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.
func (*ClientArgs) GetArgtype ¶
func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
func (*ClientArgs) GetMark ¶
func (x *ClientArgs) GetMark() *Mark
func (*ClientArgs) GetSetup ¶
func (x *ClientArgs) GetSetup() *ClientConfig
func (*ClientArgs) ProtoMessage ¶
func (*ClientArgs) ProtoMessage()
func (*ClientArgs) ProtoReflect ¶
func (x *ClientArgs) ProtoReflect() protoreflect.Message
func (*ClientArgs) Reset ¶
func (x *ClientArgs) Reset()
func (*ClientArgs) String ¶
func (x *ClientArgs) String() string
type ClientArgs_Mark ¶
type ClientArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ClientArgs_Setup ¶
type ClientArgs_Setup struct {
Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ClientConfig ¶
type ClientConfig struct { ServerTargets []string `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"` ClientType ClientType `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"` SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"` OutstandingRpcsPerChannel int32 `` /* 141-byte string literal not displayed */ ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"` AsyncClientThreads int32 `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"` RpcType RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"` LoadParams *LoadParams `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"` PayloadConfig *PayloadConfig `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"` HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"` CoreList []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"` CoreLimit int32 `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"` OtherClientApi string `protobuf:"bytes,15,opt,name=other_client_api,json=otherClientApi,proto3" json:"other_client_api,omitempty"` ChannelArgs []*ChannelArg `protobuf:"bytes,16,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"` ThreadsPerCq int32 `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"` MessagesPerStream int32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"` UseCoalesceApi bool `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,omitempty"` MedianLatencyCollectionIntervalMillis int32 `` /* 180-byte string literal not displayed */ ClientProcesses int32 `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"` // contains filtered or unexported fields }
func (*ClientConfig) Descriptor
deprecated
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig) GetAsyncClientThreads ¶
func (x *ClientConfig) GetAsyncClientThreads() int32
func (*ClientConfig) GetChannelArgs ¶
func (x *ClientConfig) GetChannelArgs() []*ChannelArg
func (*ClientConfig) GetClientChannels ¶
func (x *ClientConfig) GetClientChannels() int32
func (*ClientConfig) GetClientProcesses ¶
func (x *ClientConfig) GetClientProcesses() int32
func (*ClientConfig) GetClientType ¶
func (x *ClientConfig) GetClientType() ClientType
func (*ClientConfig) GetCoreLimit ¶
func (x *ClientConfig) GetCoreLimit() int32
func (*ClientConfig) GetCoreList ¶
func (x *ClientConfig) GetCoreList() []int32
func (*ClientConfig) GetHistogramParams ¶
func (x *ClientConfig) GetHistogramParams() *HistogramParams
func (*ClientConfig) GetLoadParams ¶
func (x *ClientConfig) GetLoadParams() *LoadParams
func (*ClientConfig) GetMedianLatencyCollectionIntervalMillis ¶
func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32
func (*ClientConfig) GetMessagesPerStream ¶
func (x *ClientConfig) GetMessagesPerStream() int32
func (*ClientConfig) GetOtherClientApi ¶
func (x *ClientConfig) GetOtherClientApi() string
func (*ClientConfig) GetOutstandingRpcsPerChannel ¶
func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32
func (*ClientConfig) GetPayloadConfig ¶
func (x *ClientConfig) GetPayloadConfig() *PayloadConfig
func (*ClientConfig) GetRpcType ¶
func (x *ClientConfig) GetRpcType() RpcType
func (*ClientConfig) GetSecurityParams ¶
func (x *ClientConfig) GetSecurityParams() *SecurityParams
func (*ClientConfig) GetServerTargets ¶
func (x *ClientConfig) GetServerTargets() []string
func (*ClientConfig) GetThreadsPerCq ¶
func (x *ClientConfig) GetThreadsPerCq() int32
func (*ClientConfig) GetUseCoalesceApi ¶
func (x *ClientConfig) GetUseCoalesceApi() bool
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) ProtoReflect ¶
func (x *ClientConfig) ProtoReflect() protoreflect.Message
func (*ClientConfig) Reset ¶
func (x *ClientConfig) Reset()
func (*ClientConfig) String ¶
func (x *ClientConfig) String() string
type ClientConfigureRequest ¶
type ClientConfigureRequest struct { Types []ClientConfigureRequest_RpcType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"types,omitempty"` Metadata []*ClientConfigureRequest_Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"` TimeoutSec int32 `protobuf:"varint,3,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"` // contains filtered or unexported fields }
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 }
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
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
}
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 ClientStats ¶
type ClientStats struct { Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"` TimeElapsed float64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"` TimeUser float64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"` TimeSystem float64 `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"` RequestResults []*RequestResultCount `protobuf:"bytes,5,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"` CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"` CoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"` // contains filtered or unexported fields }
func (*ClientStats) Descriptor
deprecated
func (*ClientStats) Descriptor() ([]byte, []int)
Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.
func (*ClientStats) GetCoreStats ¶
func (x *ClientStats) GetCoreStats() *core.Stats
func (*ClientStats) GetCqPollCount ¶
func (x *ClientStats) GetCqPollCount() uint64
func (*ClientStats) GetLatencies ¶
func (x *ClientStats) GetLatencies() *HistogramData
func (*ClientStats) GetRequestResults ¶
func (x *ClientStats) GetRequestResults() []*RequestResultCount
func (*ClientStats) GetTimeElapsed ¶
func (x *ClientStats) GetTimeElapsed() float64
func (*ClientStats) GetTimeSystem ¶
func (x *ClientStats) GetTimeSystem() float64
func (*ClientStats) GetTimeUser ¶
func (x *ClientStats) GetTimeUser() float64
func (*ClientStats) ProtoMessage ¶
func (*ClientStats) ProtoMessage()
func (*ClientStats) ProtoReflect ¶
func (x *ClientStats) ProtoReflect() protoreflect.Message
func (*ClientStats) Reset ¶
func (x *ClientStats) Reset()
func (*ClientStats) String ¶
func (x *ClientStats) String() string
type ClientStatus ¶
type ClientStatus struct { Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // contains filtered or unexported fields }
func (*ClientStatus) Descriptor
deprecated
func (*ClientStatus) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.
func (*ClientStatus) GetStats ¶
func (x *ClientStatus) GetStats() *ClientStats
func (*ClientStatus) ProtoMessage ¶
func (*ClientStatus) ProtoMessage()
func (*ClientStatus) ProtoReflect ¶
func (x *ClientStatus) ProtoReflect() protoreflect.Message
func (*ClientStatus) Reset ¶
func (x *ClientStatus) Reset()
func (*ClientStatus) String ¶
func (x *ClientStatus) String() string
type ClientType ¶
type ClientType int32
const ( ClientType_SYNC_CLIENT ClientType = 0 ClientType_ASYNC_CLIENT ClientType = 1 ClientType_OTHER_CLIENT ClientType = 2 ClientType_CALLBACK_CLIENT ClientType = 3 )
func (ClientType) Descriptor ¶
func (ClientType) Descriptor() protoreflect.EnumDescriptor
func (ClientType) Enum ¶
func (x ClientType) Enum() *ClientType
func (ClientType) EnumDescriptor
deprecated
func (ClientType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientType.Descriptor instead.
func (ClientType) Number ¶
func (x ClientType) Number() protoreflect.EnumNumber
func (ClientType) String ¶
func (x ClientType) String() string
func (ClientType) Type ¶
func (ClientType) Type() protoreflect.EnumType
type ClosedLoopParams ¶
type ClosedLoopParams struct {
// contains filtered or unexported fields
}
func (*ClosedLoopParams) Descriptor
deprecated
func (*ClosedLoopParams) Descriptor() ([]byte, []int)
Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.
func (*ClosedLoopParams) ProtoMessage ¶
func (*ClosedLoopParams) ProtoMessage()
func (*ClosedLoopParams) ProtoReflect ¶
func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message
func (*ClosedLoopParams) Reset ¶
func (x *ClosedLoopParams) Reset()
func (*ClosedLoopParams) String ¶
func (x *ClosedLoopParams) String() string
type ComplexProtoParams ¶
type ComplexProtoParams struct {
// contains filtered or unexported fields
}
func (*ComplexProtoParams) Descriptor
deprecated
func (*ComplexProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.
func (*ComplexProtoParams) ProtoMessage ¶
func (*ComplexProtoParams) ProtoMessage()
func (*ComplexProtoParams) ProtoReflect ¶
func (x *ComplexProtoParams) ProtoReflect() protoreflect.Message
func (*ComplexProtoParams) Reset ¶
func (x *ComplexProtoParams) Reset()
func (*ComplexProtoParams) String ¶
func (x *ComplexProtoParams) String() string
type CoreRequest ¶
type CoreRequest struct {
// contains filtered or unexported fields
}
func (*CoreRequest) Descriptor
deprecated
func (*CoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.
func (*CoreRequest) ProtoMessage ¶
func (*CoreRequest) ProtoMessage()
func (*CoreRequest) ProtoReflect ¶
func (x *CoreRequest) ProtoReflect() protoreflect.Message
func (*CoreRequest) Reset ¶
func (x *CoreRequest) Reset()
func (*CoreRequest) String ¶
func (x *CoreRequest) String() string
type CoreResponse ¶
type CoreResponse struct { Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*CoreResponse) Descriptor
deprecated
func (*CoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.
func (*CoreResponse) GetCores ¶
func (x *CoreResponse) GetCores() int32
func (*CoreResponse) ProtoMessage ¶
func (*CoreResponse) ProtoMessage()
func (*CoreResponse) ProtoReflect ¶
func (x *CoreResponse) ProtoReflect() protoreflect.Message
func (*CoreResponse) Reset ¶
func (x *CoreResponse) Reset()
func (*CoreResponse) String ¶
func (x *CoreResponse) 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 }
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 Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type GrpclbRouteType ¶
type GrpclbRouteType int32
const ( GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0 GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1 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 HistogramData ¶
type HistogramData struct { Bucket []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"` MinSeen float64 `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"` MaxSeen float64 `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"` Sum float64 `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"` SumOfSquares float64 `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"` Count float64 `protobuf:"fixed64,6,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*HistogramData) Descriptor
deprecated
func (*HistogramData) Descriptor() ([]byte, []int)
Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.
func (*HistogramData) GetBucket ¶
func (x *HistogramData) GetBucket() []uint32
func (*HistogramData) GetCount ¶
func (x *HistogramData) GetCount() float64
func (*HistogramData) GetMaxSeen ¶
func (x *HistogramData) GetMaxSeen() float64
func (*HistogramData) GetMinSeen ¶
func (x *HistogramData) GetMinSeen() float64
func (*HistogramData) GetSum ¶
func (x *HistogramData) GetSum() float64
func (*HistogramData) GetSumOfSquares ¶
func (x *HistogramData) GetSumOfSquares() float64
func (*HistogramData) ProtoMessage ¶
func (*HistogramData) ProtoMessage()
func (*HistogramData) ProtoReflect ¶
func (x *HistogramData) ProtoReflect() protoreflect.Message
func (*HistogramData) Reset ¶
func (x *HistogramData) Reset()
func (*HistogramData) String ¶
func (x *HistogramData) String() string
type HistogramParams ¶
type HistogramParams struct { Resolution float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"` MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"` // contains filtered or unexported fields }
func (*HistogramParams) Descriptor
deprecated
func (*HistogramParams) Descriptor() ([]byte, []int)
Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.
func (*HistogramParams) GetMaxPossible ¶
func (x *HistogramParams) GetMaxPossible() float64
func (*HistogramParams) GetResolution ¶
func (x *HistogramParams) GetResolution() float64
func (*HistogramParams) ProtoMessage ¶
func (*HistogramParams) ProtoMessage()
func (*HistogramParams) ProtoReflect ¶
func (x *HistogramParams) ProtoReflect() protoreflect.Message
func (*HistogramParams) Reset ¶
func (x *HistogramParams) Reset()
func (*HistogramParams) String ¶
func (x *HistogramParams) String() string
type LoadBalancerAccumulatedStatsRequest ¶
type LoadBalancerAccumulatedStatsRequest struct {
// contains filtered or unexported fields
}
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 { // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsStartedByMethod map[string]int32 `` /* 222-byte string literal not displayed */ // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsSucceededByMethod map[string]int32 `` /* 228-byte string literal not displayed */ // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsFailedByMethod map[string]int32 `` /* 219-byte string literal not displayed */ StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 193-byte string literal not displayed */ // contains filtered or unexported fields }
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 { RpcsStarted int32 `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"` Result map[int32]int32 `` /* 155-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 { NumRpcs int32 `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"` TimeoutSec int32 `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"` // contains filtered or unexported fields }
func (*LoadBalancerStatsRequest) Descriptor
deprecated
func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.
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 { RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */ NumFailures int32 `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"` RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `` /* 187-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) 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_RpcsByPeer ¶
type LoadBalancerStatsResponse_RpcsByPeer struct { RpcsByPeer map[string]int32 `` /* 182-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 LoadParams ¶
type LoadParams struct { // Types that are assignable to Load: // // *LoadParams_ClosedLoop // *LoadParams_Poisson Load isLoadParams_Load `protobuf_oneof:"load"` // contains filtered or unexported fields }
func (*LoadParams) Descriptor
deprecated
func (*LoadParams) Descriptor() ([]byte, []int)
Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.
func (*LoadParams) GetClosedLoop ¶
func (x *LoadParams) GetClosedLoop() *ClosedLoopParams
func (*LoadParams) GetLoad ¶
func (m *LoadParams) GetLoad() isLoadParams_Load
func (*LoadParams) GetPoisson ¶
func (x *LoadParams) GetPoisson() *PoissonParams
func (*LoadParams) ProtoMessage ¶
func (*LoadParams) ProtoMessage()
func (*LoadParams) ProtoReflect ¶
func (x *LoadParams) ProtoReflect() protoreflect.Message
func (*LoadParams) Reset ¶
func (x *LoadParams) Reset()
func (*LoadParams) String ¶
func (x *LoadParams) String() string
type LoadParams_ClosedLoop ¶
type LoadParams_ClosedLoop struct {
ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
}
type LoadParams_Poisson ¶
type LoadParams_Poisson struct {
Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
}
type Mark ¶
type Mark struct { Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"` // contains filtered or unexported fields }
func (*Mark) ProtoReflect ¶
func (x *Mark) ProtoReflect() protoreflect.Message
type Payload ¶
type Payload struct { Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"` Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*Payload) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type PayloadConfig ¶
type PayloadConfig struct { // Types that are assignable to Payload: // // *PayloadConfig_BytebufParams // *PayloadConfig_SimpleParams // *PayloadConfig_ComplexParams Payload isPayloadConfig_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*PayloadConfig) Descriptor
deprecated
func (*PayloadConfig) Descriptor() ([]byte, []int)
Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.
func (*PayloadConfig) GetBytebufParams ¶
func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams
func (*PayloadConfig) GetComplexParams ¶
func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams
func (*PayloadConfig) GetPayload ¶
func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
func (*PayloadConfig) GetSimpleParams ¶
func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams
func (*PayloadConfig) ProtoMessage ¶
func (*PayloadConfig) ProtoMessage()
func (*PayloadConfig) ProtoReflect ¶
func (x *PayloadConfig) ProtoReflect() protoreflect.Message
func (*PayloadConfig) Reset ¶
func (x *PayloadConfig) Reset()
func (*PayloadConfig) String ¶
func (x *PayloadConfig) String() string
type PayloadConfig_BytebufParams ¶
type PayloadConfig_BytebufParams struct {
BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,proto3,oneof"`
}
type PayloadConfig_ComplexParams ¶
type PayloadConfig_ComplexParams struct {
ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,proto3,oneof"`
}
type PayloadConfig_SimpleParams ¶
type PayloadConfig_SimpleParams struct {
SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,oneof"`
}
type PayloadType ¶
type PayloadType int32
const (
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 PoissonParams ¶
type PoissonParams struct { OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` // contains filtered or unexported fields }
func (*PoissonParams) Descriptor
deprecated
func (*PoissonParams) Descriptor() ([]byte, []int)
Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.
func (*PoissonParams) GetOfferedLoad ¶
func (x *PoissonParams) GetOfferedLoad() float64
func (*PoissonParams) ProtoMessage ¶
func (*PoissonParams) ProtoMessage()
func (*PoissonParams) ProtoReflect ¶
func (x *PoissonParams) ProtoReflect() protoreflect.Message
func (*PoissonParams) Reset ¶
func (x *PoissonParams) Reset()
func (*PoissonParams) String ¶
func (x *PoissonParams) String() string
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 }
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 }
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 RequestResultCount ¶
type RequestResultCount struct { StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*RequestResultCount) Descriptor
deprecated
func (*RequestResultCount) Descriptor() ([]byte, []int)
Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.
func (*RequestResultCount) GetCount ¶
func (x *RequestResultCount) GetCount() int64
func (*RequestResultCount) GetStatusCode ¶
func (x *RequestResultCount) GetStatusCode() int32
func (*RequestResultCount) ProtoMessage ¶
func (*RequestResultCount) ProtoMessage()
func (*RequestResultCount) ProtoReflect ¶
func (x *RequestResultCount) ProtoReflect() protoreflect.Message
func (*RequestResultCount) Reset ¶
func (x *RequestResultCount) Reset()
func (*RequestResultCount) String ¶
func (x *RequestResultCount) String() string
type ResponseParameters ¶
type ResponseParameters struct { Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"` Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,omitempty"` // contains filtered or unexported fields }
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 RpcType ¶
type RpcType int32
func (RpcType) Descriptor ¶
func (RpcType) Descriptor() protoreflect.EnumDescriptor
func (RpcType) Number ¶
func (x RpcType) Number() protoreflect.EnumNumber
func (RpcType) Type ¶
func (RpcType) Type() protoreflect.EnumType
type Scenario ¶
type Scenario struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"` NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"` NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"` WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"` BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"` SpawnLocalWorkerCount int32 `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Scenario) GetClientConfig ¶
func (x *Scenario) GetClientConfig() *ClientConfig
func (*Scenario) GetServerConfig ¶
func (x *Scenario) GetServerConfig() *ServerConfig
func (*Scenario) ProtoReflect ¶
func (x *Scenario) ProtoReflect() protoreflect.Message
type ScenarioResult ¶
type ScenarioResult struct { Scenario *Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"` Latencies *HistogramData `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"` ClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"` ServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"` ServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"` Summary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"` ClientSuccess []bool `protobuf:"varint,7,rep,packed,name=client_success,json=clientSuccess,proto3" json:"client_success,omitempty"` ServerSuccess []bool `protobuf:"varint,8,rep,packed,name=server_success,json=serverSuccess,proto3" json:"server_success,omitempty"` RequestResults []*RequestResultCount `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"` // contains filtered or unexported fields }
func (*ScenarioResult) Descriptor
deprecated
func (*ScenarioResult) Descriptor() ([]byte, []int)
Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.
func (*ScenarioResult) GetClientStats ¶
func (x *ScenarioResult) GetClientStats() []*ClientStats
func (*ScenarioResult) GetClientSuccess ¶
func (x *ScenarioResult) GetClientSuccess() []bool
func (*ScenarioResult) GetLatencies ¶
func (x *ScenarioResult) GetLatencies() *HistogramData
func (*ScenarioResult) GetRequestResults ¶
func (x *ScenarioResult) GetRequestResults() []*RequestResultCount
func (*ScenarioResult) GetScenario ¶
func (x *ScenarioResult) GetScenario() *Scenario
func (*ScenarioResult) GetServerCores ¶
func (x *ScenarioResult) GetServerCores() []int32
func (*ScenarioResult) GetServerStats ¶
func (x *ScenarioResult) GetServerStats() []*ServerStats
func (*ScenarioResult) GetServerSuccess ¶
func (x *ScenarioResult) GetServerSuccess() []bool
func (*ScenarioResult) GetSummary ¶
func (x *ScenarioResult) GetSummary() *ScenarioResultSummary
func (*ScenarioResult) ProtoMessage ¶
func (*ScenarioResult) ProtoMessage()
func (*ScenarioResult) ProtoReflect ¶
func (x *ScenarioResult) ProtoReflect() protoreflect.Message
func (*ScenarioResult) Reset ¶
func (x *ScenarioResult) Reset()
func (*ScenarioResult) String ¶
func (x *ScenarioResult) String() string
type ScenarioResultSummary ¶
type ScenarioResultSummary struct { Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"` QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"` ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"` ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"` ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"` ClientUserTime float64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"` Latency_50 float64 `protobuf:"fixed64,7,opt,name=latency_50,json=latency50,proto3" json:"latency_50,omitempty"` Latency_90 float64 `protobuf:"fixed64,8,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"` Latency_95 float64 `protobuf:"fixed64,9,opt,name=latency_95,json=latency95,proto3" json:"latency_95,omitempty"` Latency_99 float64 `protobuf:"fixed64,10,opt,name=latency_99,json=latency99,proto3" json:"latency_99,omitempty"` Latency_999 float64 `protobuf:"fixed64,11,opt,name=latency_999,json=latency999,proto3" json:"latency_999,omitempty"` ServerCpuUsage float64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"` SuccessfulRequestsPerSecond float64 `` /* 149-byte string literal not displayed */ FailedRequestsPerSecond float64 `` /* 137-byte string literal not displayed */ ClientPollsPerRequest float64 `` /* 131-byte string literal not displayed */ ServerPollsPerRequest float64 `` /* 131-byte string literal not displayed */ ServerQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */ ClientQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */ StartTime *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // contains filtered or unexported fields }
func (*ScenarioResultSummary) Descriptor
deprecated
func (*ScenarioResultSummary) Descriptor() ([]byte, []int)
Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.
func (*ScenarioResultSummary) GetClientPollsPerRequest ¶
func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64
func (*ScenarioResultSummary) GetClientQueriesPerCpuSec ¶
func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetClientSystemTime ¶
func (x *ScenarioResultSummary) GetClientSystemTime() float64
func (*ScenarioResultSummary) GetClientUserTime ¶
func (x *ScenarioResultSummary) GetClientUserTime() float64
func (*ScenarioResultSummary) GetEndTime ¶
func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp
func (*ScenarioResultSummary) GetFailedRequestsPerSecond ¶
func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64
func (*ScenarioResultSummary) GetLatency_50 ¶
func (x *ScenarioResultSummary) GetLatency_50() float64
func (*ScenarioResultSummary) GetLatency_90 ¶
func (x *ScenarioResultSummary) GetLatency_90() float64
func (*ScenarioResultSummary) GetLatency_95 ¶
func (x *ScenarioResultSummary) GetLatency_95() float64
func (*ScenarioResultSummary) GetLatency_99 ¶
func (x *ScenarioResultSummary) GetLatency_99() float64
func (*ScenarioResultSummary) GetLatency_999 ¶
func (x *ScenarioResultSummary) GetLatency_999() float64
func (*ScenarioResultSummary) GetQps ¶
func (x *ScenarioResultSummary) GetQps() float64
func (*ScenarioResultSummary) GetQpsPerServerCore ¶
func (x *ScenarioResultSummary) GetQpsPerServerCore() float64
func (*ScenarioResultSummary) GetServerCpuUsage ¶
func (x *ScenarioResultSummary) GetServerCpuUsage() float64
func (*ScenarioResultSummary) GetServerPollsPerRequest ¶
func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64
func (*ScenarioResultSummary) GetServerQueriesPerCpuSec ¶
func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetServerSystemTime ¶
func (x *ScenarioResultSummary) GetServerSystemTime() float64
func (*ScenarioResultSummary) GetServerUserTime ¶
func (x *ScenarioResultSummary) GetServerUserTime() float64
func (*ScenarioResultSummary) GetStartTime ¶
func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp
func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond ¶
func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64
func (*ScenarioResultSummary) ProtoMessage ¶
func (*ScenarioResultSummary) ProtoMessage()
func (*ScenarioResultSummary) ProtoReflect ¶
func (x *ScenarioResultSummary) ProtoReflect() protoreflect.Message
func (*ScenarioResultSummary) Reset ¶
func (x *ScenarioResultSummary) Reset()
func (*ScenarioResultSummary) String ¶
func (x *ScenarioResultSummary) String() string
type Scenarios ¶
type Scenarios struct { Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"` // contains filtered or unexported fields }
func (*Scenarios) ProtoReflect ¶
func (x *Scenarios) ProtoReflect() protoreflect.Message
type SecurityParams ¶
type SecurityParams struct { UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"` ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"` CredType string `protobuf:"bytes,3,opt,name=cred_type,json=credType,proto3" json:"cred_type,omitempty"` // contains filtered or unexported fields }
func (*SecurityParams) Descriptor
deprecated
func (*SecurityParams) Descriptor() ([]byte, []int)
Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.
func (*SecurityParams) GetCredType ¶
func (x *SecurityParams) GetCredType() string
func (*SecurityParams) GetServerHostOverride ¶
func (x *SecurityParams) GetServerHostOverride() string
func (*SecurityParams) GetUseTestCa ¶
func (x *SecurityParams) GetUseTestCa() bool
func (*SecurityParams) ProtoMessage ¶
func (*SecurityParams) ProtoMessage()
func (*SecurityParams) ProtoReflect ¶
func (x *SecurityParams) ProtoReflect() protoreflect.Message
func (*SecurityParams) Reset ¶
func (x *SecurityParams) Reset()
func (*SecurityParams) String ¶
func (x *SecurityParams) String() string
type ServerArgs ¶
type ServerArgs struct { // Types that are assignable to Argtype: // // *ServerArgs_Setup // *ServerArgs_Mark Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"` // contains filtered or unexported fields }
func (*ServerArgs) Descriptor
deprecated
func (*ServerArgs) Descriptor() ([]byte, []int)
Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.
func (*ServerArgs) GetArgtype ¶
func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
func (*ServerArgs) GetMark ¶
func (x *ServerArgs) GetMark() *Mark
func (*ServerArgs) GetSetup ¶
func (x *ServerArgs) GetSetup() *ServerConfig
func (*ServerArgs) ProtoMessage ¶
func (*ServerArgs) ProtoMessage()
func (*ServerArgs) ProtoReflect ¶
func (x *ServerArgs) ProtoReflect() protoreflect.Message
func (*ServerArgs) Reset ¶
func (x *ServerArgs) Reset()
func (*ServerArgs) String ¶
func (x *ServerArgs) String() string
type ServerArgs_Mark ¶
type ServerArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ServerArgs_Setup ¶
type ServerArgs_Setup struct {
Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ServerConfig ¶
type ServerConfig struct { ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"` SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"` Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"` CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"` PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"` CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"` OtherServerApi string `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"` ThreadsPerCq int32 `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"` ResourceQuotaSize int32 `protobuf:"varint,1001,opt,name=resource_quota_size,json=resourceQuotaSize,proto3" json:"resource_quota_size,omitempty"` ChannelArgs []*ChannelArg `protobuf:"bytes,1002,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"` ServerProcesses int32 `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"` // contains filtered or unexported fields }
func (*ServerConfig) Descriptor
deprecated
func (*ServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.
func (*ServerConfig) GetAsyncServerThreads ¶
func (x *ServerConfig) GetAsyncServerThreads() int32
func (*ServerConfig) GetChannelArgs ¶
func (x *ServerConfig) GetChannelArgs() []*ChannelArg
func (*ServerConfig) GetCoreLimit ¶
func (x *ServerConfig) GetCoreLimit() int32
func (*ServerConfig) GetCoreList ¶
func (x *ServerConfig) GetCoreList() []int32
func (*ServerConfig) GetOtherServerApi ¶
func (x *ServerConfig) GetOtherServerApi() string
func (*ServerConfig) GetPayloadConfig ¶
func (x *ServerConfig) GetPayloadConfig() *PayloadConfig
func (*ServerConfig) GetPort ¶
func (x *ServerConfig) GetPort() int32
func (*ServerConfig) GetResourceQuotaSize ¶
func (x *ServerConfig) GetResourceQuotaSize() int32
func (*ServerConfig) GetSecurityParams ¶
func (x *ServerConfig) GetSecurityParams() *SecurityParams
func (*ServerConfig) GetServerProcesses ¶
func (x *ServerConfig) GetServerProcesses() int32
func (*ServerConfig) GetServerType ¶
func (x *ServerConfig) GetServerType() ServerType
func (*ServerConfig) GetThreadsPerCq ¶
func (x *ServerConfig) GetThreadsPerCq() int32
func (*ServerConfig) ProtoMessage ¶
func (*ServerConfig) ProtoMessage()
func (*ServerConfig) ProtoReflect ¶
func (x *ServerConfig) ProtoReflect() protoreflect.Message
func (*ServerConfig) Reset ¶
func (x *ServerConfig) Reset()
func (*ServerConfig) String ¶
func (x *ServerConfig) String() string
type ServerStats ¶
type ServerStats struct { TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"` TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"` TimeSystem float64 `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"` TotalCpuTime uint64 `protobuf:"varint,4,opt,name=total_cpu_time,json=totalCpuTime,proto3" json:"total_cpu_time,omitempty"` IdleCpuTime uint64 `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"` CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"` CoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"` // contains filtered or unexported fields }
func (*ServerStats) Descriptor
deprecated
func (*ServerStats) Descriptor() ([]byte, []int)
Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.
func (*ServerStats) GetCoreStats ¶
func (x *ServerStats) GetCoreStats() *core.Stats
func (*ServerStats) GetCqPollCount ¶
func (x *ServerStats) GetCqPollCount() uint64
func (*ServerStats) GetIdleCpuTime ¶
func (x *ServerStats) GetIdleCpuTime() uint64
func (*ServerStats) GetTimeElapsed ¶
func (x *ServerStats) GetTimeElapsed() float64
func (*ServerStats) GetTimeSystem ¶
func (x *ServerStats) GetTimeSystem() float64
func (*ServerStats) GetTimeUser ¶
func (x *ServerStats) GetTimeUser() float64
func (*ServerStats) GetTotalCpuTime ¶
func (x *ServerStats) GetTotalCpuTime() uint64
func (*ServerStats) ProtoMessage ¶
func (*ServerStats) ProtoMessage()
func (*ServerStats) ProtoReflect ¶
func (x *ServerStats) ProtoReflect() protoreflect.Message
func (*ServerStats) Reset ¶
func (x *ServerStats) Reset()
func (*ServerStats) String ¶
func (x *ServerStats) String() string
type ServerStatus ¶
type ServerStatus struct { Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*ServerStatus) Descriptor
deprecated
func (*ServerStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.
func (*ServerStatus) GetCores ¶
func (x *ServerStatus) GetCores() int32
func (*ServerStatus) GetPort ¶
func (x *ServerStatus) GetPort() int32
func (*ServerStatus) GetStats ¶
func (x *ServerStatus) GetStats() *ServerStats
func (*ServerStatus) ProtoMessage ¶
func (*ServerStatus) ProtoMessage()
func (*ServerStatus) ProtoReflect ¶
func (x *ServerStatus) ProtoReflect() protoreflect.Message
func (*ServerStatus) Reset ¶
func (x *ServerStatus) Reset()
func (*ServerStatus) String ¶
func (x *ServerStatus) String() string
type ServerType ¶
type ServerType int32
const ( ServerType_SYNC_SERVER ServerType = 0 ServerType_ASYNC_SERVER ServerType = 1 ServerType_ASYNC_GENERIC_SERVER ServerType = 2 ServerType_OTHER_SERVER ServerType = 3 ServerType_CALLBACK_SERVER ServerType = 4 )
func (ServerType) Descriptor ¶
func (ServerType) Descriptor() protoreflect.EnumDescriptor
func (ServerType) Enum ¶
func (x ServerType) Enum() *ServerType
func (ServerType) EnumDescriptor
deprecated
func (ServerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServerType.Descriptor instead.
func (ServerType) Number ¶
func (x ServerType) Number() protoreflect.EnumNumber
func (ServerType) String ¶
func (x ServerType) String() string
func (ServerType) Type ¶
func (ServerType) Type() protoreflect.EnumType
type SimpleProtoParams ¶
type SimpleProtoParams struct { ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"` // contains filtered or unexported fields }
func (*SimpleProtoParams) Descriptor
deprecated
func (*SimpleProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.
func (*SimpleProtoParams) GetReqSize ¶
func (x *SimpleProtoParams) GetReqSize() int32
func (*SimpleProtoParams) GetRespSize ¶
func (x *SimpleProtoParams) GetRespSize() int32
func (*SimpleProtoParams) ProtoMessage ¶
func (*SimpleProtoParams) ProtoMessage()
func (*SimpleProtoParams) ProtoReflect ¶
func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message
func (*SimpleProtoParams) Reset ¶
func (x *SimpleProtoParams) Reset()
func (*SimpleProtoParams) String ¶
func (x *SimpleProtoParams) String() string
type SimpleRequest ¶
type SimpleRequest struct { ResponseType PayloadType `` /* 128-byte string literal not displayed */ ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"` Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"` FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"` ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"` ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"` FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"` FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"` OrcaPerQueryReport *TestOrcaReport `protobuf:"bytes,11,opt,name=orca_per_query_report,json=orcaPerQueryReport,proto3" json:"orca_per_query_report,omitempty"` OrcaOobReport *TestOrcaReport `protobuf:"bytes,12,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"` // contains filtered or unexported fields }
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) GetOrcaOobReport ¶
func (x *SimpleRequest) GetOrcaOobReport() *TestOrcaReport
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 *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"` ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` GrpclbRouteType GrpclbRouteType `` /* 143-byte string literal not displayed */ Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"` // contains filtered or unexported fields }
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 { Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"` // contains filtered or unexported fields }
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 { AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
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 { ResponseType PayloadType `` /* 128-byte string literal not displayed */ ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"` Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` OrcaOobReport *TestOrcaReport `protobuf:"bytes,8,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"` // contains filtered or unexported fields }
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 *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
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 `` /* 184-byte string literal not displayed */ Utilization map[string]float64 `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
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
type Void ¶
type Void struct {
// contains filtered or unexported fields
}
func (*Void) ProtoReflect ¶
func (x *Void) ProtoReflect() protoreflect.Message