Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
- func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer)
- func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer)
- func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)
- func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)
- func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
- func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)
- func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)
- type BenchmarkServiceClient
- type BenchmarkServiceServer
- type BenchmarkService_StreamingBothWaysClient
- type BenchmarkService_StreamingBothWaysServer
- type BenchmarkService_StreamingCallClient
- type BenchmarkService_StreamingCallServer
- type BenchmarkService_StreamingFromClientClient
- type BenchmarkService_StreamingFromClientServer
- type BenchmarkService_StreamingFromServerClient
- type BenchmarkService_StreamingFromServerServer
- 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 HookRequest
- func (*HookRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand
- func (x *HookRequest) GetGrpcCodeToReturn() int32
- func (x *HookRequest) GetGrpcStatusDescription() string
- func (x *HookRequest) GetServerPort() int32
- func (*HookRequest) ProtoMessage()
- func (x *HookRequest) ProtoReflect() protoreflect.Message
- func (x *HookRequest) Reset()
- func (x *HookRequest) String() string
- type HookRequest_HookRequestCommand
- func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor
- func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand
- func (HookRequest_HookRequestCommand) EnumDescriptor() ([]byte, []int)deprecated
- func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber
- func (x HookRequest_HookRequestCommand) String() string
- func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType
- type HookResponse
- type HookServiceClient
- type HookServiceServer
- type LoadBalancerAccumulatedStatsRequest
- func (*LoadBalancerAccumulatedStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsRequest) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsRequest) Reset()
- func (x *LoadBalancerAccumulatedStatsRequest) String() string
- type LoadBalancerAccumulatedStatsResponse
- func (*LoadBalancerAccumulatedStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32deprecated
- func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats
- func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsResponse) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsResponse) Reset()
- func (x *LoadBalancerAccumulatedStatsResponse) String() string
- type LoadBalancerAccumulatedStatsResponse_MethodStats
- func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32
- func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()
- func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string
- type LoadBalancerStatsRequest
- func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string
- func (x *LoadBalancerStatsRequest) GetNumRpcs() int32
- func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32
- func (*LoadBalancerStatsRequest) ProtoMessage()
- func (x *LoadBalancerStatsRequest) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsRequest) Reset()
- func (x *LoadBalancerStatsRequest) String() string
- type LoadBalancerStatsResponse
- func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer
- func (x *LoadBalancerStatsResponse) GetNumFailures() int32
- func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
- func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse) ProtoMessage()
- func (x *LoadBalancerStatsResponse) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse) Reset()
- func (x *LoadBalancerStatsResponse) String() string
- type LoadBalancerStatsResponse_MetadataByPeer
- func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata
- func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage()
- func (x *LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset()
- func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string
- type LoadBalancerStatsResponse_MetadataEntry
- func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType
- func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string
- func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage()
- func (x *LoadBalancerStatsResponse_MetadataEntry) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_MetadataEntry) Reset()
- func (x *LoadBalancerStatsResponse_MetadataEntry) String() string
- type LoadBalancerStatsResponse_MetadataType
- func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor
- func (x LoadBalancerStatsResponse_MetadataType) Enum() *LoadBalancerStatsResponse_MetadataType
- func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor() ([]byte, []int)deprecated
- func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber
- func (x LoadBalancerStatsResponse_MetadataType) String() string
- func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType
- type LoadBalancerStatsResponse_RpcMetadata
- func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry
- func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()
- func (x *LoadBalancerStatsResponse_RpcMetadata) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_RpcMetadata) Reset()
- func (x *LoadBalancerStatsResponse_RpcMetadata) String() string
- type LoadBalancerStatsResponse_RpcsByPeer
- func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)deprecated
- func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
- func (x *LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect() protoreflect.Message
- func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()
- func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string
- type LoadBalancerStatsServiceClient
- type LoadBalancerStatsServiceServer
- 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 MemorySize
- 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 ReconnectServiceClient
- type ReconnectServiceServer
- type ReportQpsScenarioServiceClient
- type ReportQpsScenarioServiceServer
- 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 SetReturnStatusRequest
- func (*SetReturnStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32
- func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string
- func (*SetReturnStatusRequest) ProtoMessage()
- func (x *SetReturnStatusRequest) ProtoReflect() protoreflect.Message
- func (x *SetReturnStatusRequest) Reset()
- func (x *SetReturnStatusRequest) String() string
- type 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) 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 TestServiceClient
- type TestServiceServer
- type TestService_FullDuplexCallClient
- type TestService_FullDuplexCallServer
- type TestService_HalfDuplexCallClient
- type TestService_HalfDuplexCallServer
- type TestService_StreamingInputCallClient
- type TestService_StreamingInputCallServer
- type TestService_StreamingOutputCallClient
- type TestService_StreamingOutputCallServer
- type UnimplementedBenchmarkServiceServer
- func (UnimplementedBenchmarkServiceServer) StreamingBothWays(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error
- func (UnimplementedBenchmarkServiceServer) StreamingCall(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error
- func (UnimplementedBenchmarkServiceServer) StreamingFromClient(grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]) error
- func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*SimpleRequest, grpc.ServerStreamingServer[SimpleResponse]) error
- func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- type UnimplementedHookServiceServer
- type UnimplementedLoadBalancerStatsServiceServer
- func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error)
- func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)
- type UnimplementedReconnectServiceServer
- type UnimplementedReportQpsScenarioServiceServer
- type UnimplementedServiceClient
- type UnimplementedServiceServer
- type UnimplementedTestServiceServer
- func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- func (UnimplementedTestServiceServer) EmptyCall(context.Context, *Empty) (*Empty, error)
- func (UnimplementedTestServiceServer) FullDuplexCall(...) error
- func (UnimplementedTestServiceServer) HalfDuplexCall(...) error
- func (UnimplementedTestServiceServer) StreamingInputCall(...) error
- func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, ...) error
- func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- func (UnimplementedTestServiceServer) UnimplementedCall(context.Context, *Empty) (*Empty, error)
- type UnimplementedUnimplementedServiceServer
- type UnimplementedWorkerServiceServer
- func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
- func (UnimplementedWorkerServiceServer) QuitWorker(context.Context, *Void) (*Void, error)
- func (UnimplementedWorkerServiceServer) RunClient(grpc.BidiStreamingServer[ClientArgs, ClientStatus]) error
- func (UnimplementedWorkerServiceServer) RunServer(grpc.BidiStreamingServer[ServerArgs, ServerStatus]) error
- type UnimplementedXdsUpdateClientConfigureServiceServer
- type UnimplementedXdsUpdateHealthServiceServer
- func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *HookRequest) (*HookResponse, error)
- func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing(context.Context, *Empty) (*Empty, error)
- func (UnimplementedXdsUpdateHealthServiceServer) SetServing(context.Context, *Empty) (*Empty, error)
- type UnsafeBenchmarkServiceServer
- type UnsafeHookServiceServer
- type UnsafeLoadBalancerStatsServiceServer
- type UnsafeReconnectServiceServer
- type UnsafeReportQpsScenarioServiceServer
- type UnsafeTestServiceServer
- type UnsafeUnimplementedServiceServer
- type UnsafeWorkerServiceServer
- type UnsafeXdsUpdateClientConfigureServiceServer
- type UnsafeXdsUpdateHealthServiceServer
- type Void
- type WorkerServiceClient
- type WorkerServiceServer
- type WorkerService_RunClientClient
- type WorkerService_RunClientServer
- type WorkerService_RunServerClient
- type WorkerService_RunServerServer
- type XdsUpdateClientConfigureServiceClient
- type XdsUpdateClientConfigureServiceServer
- type XdsUpdateHealthServiceClient
- type XdsUpdateHealthServiceServer
Constants ¶
const ( BenchmarkService_UnaryCall_FullMethodName = "/grpc.testing.BenchmarkService/UnaryCall" BenchmarkService_StreamingCall_FullMethodName = "/grpc.testing.BenchmarkService/StreamingCall" BenchmarkService_StreamingFromClient_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromClient" BenchmarkService_StreamingFromServer_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromServer" BenchmarkService_StreamingBothWays_FullMethodName = "/grpc.testing.BenchmarkService/StreamingBothWays" )
const ( TestService_EmptyCall_FullMethodName = "/grpc.testing.TestService/EmptyCall" TestService_UnaryCall_FullMethodName = "/grpc.testing.TestService/UnaryCall" TestService_CacheableUnaryCall_FullMethodName = "/grpc.testing.TestService/CacheableUnaryCall" TestService_StreamingOutputCall_FullMethodName = "/grpc.testing.TestService/StreamingOutputCall" TestService_StreamingInputCall_FullMethodName = "/grpc.testing.TestService/StreamingInputCall" TestService_FullDuplexCall_FullMethodName = "/grpc.testing.TestService/FullDuplexCall" TestService_HalfDuplexCall_FullMethodName = "/grpc.testing.TestService/HalfDuplexCall" TestService_UnimplementedCall_FullMethodName = "/grpc.testing.TestService/UnimplementedCall" )
const ( ReconnectService_Start_FullMethodName = "/grpc.testing.ReconnectService/Start" ReconnectService_Stop_FullMethodName = "/grpc.testing.ReconnectService/Stop" )
const ( LoadBalancerStatsService_GetClientStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientStats" LoadBalancerStatsService_GetClientAccumulatedStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientAccumulatedStats" )
const ( HookService_Hook_FullMethodName = "/grpc.testing.HookService/Hook" HookService_SetReturnStatus_FullMethodName = "/grpc.testing.HookService/SetReturnStatus" HookService_ClearReturnStatus_FullMethodName = "/grpc.testing.HookService/ClearReturnStatus" )
const ( XdsUpdateHealthService_SetServing_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SetServing" XdsUpdateHealthService_SetNotServing_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SetNotServing" XdsUpdateHealthService_SendHookRequest_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SendHookRequest" )
const ( WorkerService_RunServer_FullMethodName = "/grpc.testing.WorkerService/RunServer" WorkerService_RunClient_FullMethodName = "/grpc.testing.WorkerService/RunClient" WorkerService_CoreCount_FullMethodName = "/grpc.testing.WorkerService/CoreCount" WorkerService_QuitWorker_FullMethodName = "/grpc.testing.WorkerService/QuitWorker" )
const (
ReportQpsScenarioService_ReportScenario_FullMethodName = "/grpc.testing.ReportQpsScenarioService/ReportScenario"
)
const (
UnimplementedService_UnimplementedCall_FullMethodName = "/grpc.testing.UnimplementedService/UnimplementedCall"
)
const (
XdsUpdateClientConfigureService_Configure_FullMethodName = "/grpc.testing.XdsUpdateClientConfigureService/Configure"
)
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 ( LoadBalancerStatsResponse_MetadataType_name = map[int32]string{ 0: "UNKNOWN", 1: "INITIAL", 2: "TRAILING", } LoadBalancerStatsResponse_MetadataType_value = map[string]int32{ "UNKNOWN": 0, "INITIAL": 1, "TRAILING": 2, } )
Enum value maps for LoadBalancerStatsResponse_MetadataType.
var ( ClientConfigureRequest_RpcType_name = map[int32]string{ 0: "EMPTY_CALL", 1: "UNARY_CALL", } ClientConfigureRequest_RpcType_value = map[string]int32{ "EMPTY_CALL": 0, "UNARY_CALL": 1, } )
Enum value maps for ClientConfigureRequest_RpcType.
var ( HookRequest_HookRequestCommand_name = map[int32]string{ 0: "UNSPECIFIED", 1: "START", 2: "STOP", 3: "RETURN", } HookRequest_HookRequestCommand_value = map[string]int32{ "UNSPECIFIED": 0, "START": 1, "STOP": 2, "RETURN": 3, } )
Enum value maps for HookRequest_HookRequestCommand.
var BenchmarkService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.BenchmarkService", HandlerType: (*BenchmarkServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UnaryCall", Handler: _BenchmarkService_UnaryCall_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamingCall", Handler: _BenchmarkService_StreamingCall_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "StreamingFromClient", Handler: _BenchmarkService_StreamingFromClient_Handler, ClientStreams: true, }, { StreamName: "StreamingFromServer", Handler: _BenchmarkService_StreamingFromServer_Handler, ServerStreams: true, }, { StreamName: "StreamingBothWays", Handler: _BenchmarkService_StreamingBothWays_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/benchmark_service.proto", }
BenchmarkService_ServiceDesc is the grpc.ServiceDesc for BenchmarkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
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
var HookService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.HookService", HandlerType: (*HookServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hook", Handler: _HookService_Hook_Handler, }, { MethodName: "SetReturnStatus", Handler: _HookService_SetReturnStatus_Handler, }, { MethodName: "ClearReturnStatus", Handler: _HookService_ClearReturnStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
HookService_ServiceDesc is the grpc.ServiceDesc for HookService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LoadBalancerStatsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.LoadBalancerStatsService", HandlerType: (*LoadBalancerStatsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetClientStats", Handler: _LoadBalancerStatsService_GetClientStats_Handler, }, { MethodName: "GetClientAccumulatedStats", Handler: _LoadBalancerStatsService_GetClientAccumulatedStats_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
LoadBalancerStatsService_ServiceDesc is the grpc.ServiceDesc for LoadBalancerStatsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReconnectService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.ReconnectService", HandlerType: (*ReconnectServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _ReconnectService_Start_Handler, }, { MethodName: "Stop", Handler: _ReconnectService_Stop_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
ReconnectService_ServiceDesc is the grpc.ServiceDesc for ReconnectService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReportQpsScenarioService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.ReportQpsScenarioService", HandlerType: (*ReportQpsScenarioServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReportScenario", Handler: _ReportQpsScenarioService_ReportScenario_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/report_qps_scenario_service.proto", }
ReportQpsScenarioService_ServiceDesc is the grpc.ServiceDesc for ReportQpsScenarioService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EmptyCall", Handler: _TestService_EmptyCall_Handler, }, { MethodName: "UnaryCall", Handler: _TestService_UnaryCall_Handler, }, { MethodName: "CacheableUnaryCall", Handler: _TestService_CacheableUnaryCall_Handler, }, { MethodName: "UnimplementedCall", Handler: _TestService_UnimplementedCall_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamingOutputCall", Handler: _TestService_StreamingOutputCall_Handler, ServerStreams: true, }, { StreamName: "StreamingInputCall", Handler: _TestService_StreamingInputCall_Handler, ClientStreams: true, }, { StreamName: "FullDuplexCall", Handler: _TestService_FullDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "HalfDuplexCall", Handler: _TestService_HalfDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/test.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UnimplementedService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.UnimplementedService", HandlerType: (*UnimplementedServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UnimplementedCall", Handler: _UnimplementedService_UnimplementedCall_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
UnimplementedService_ServiceDesc is the grpc.ServiceDesc for UnimplementedService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var WorkerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.WorkerService", HandlerType: (*WorkerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CoreCount", Handler: _WorkerService_CoreCount_Handler, }, { MethodName: "QuitWorker", Handler: _WorkerService_QuitWorker_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RunServer", Handler: _WorkerService_RunServer_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "RunClient", Handler: _WorkerService_RunClient_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/worker_service.proto", }
WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var XdsUpdateClientConfigureService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.XdsUpdateClientConfigureService", HandlerType: (*XdsUpdateClientConfigureServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Configure", Handler: _XdsUpdateClientConfigureService_Configure_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
XdsUpdateClientConfigureService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateClientConfigureService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var XdsUpdateHealthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.XdsUpdateHealthService", HandlerType: (*XdsUpdateHealthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetServing", Handler: _XdsUpdateHealthService_SetServing_Handler, }, { MethodName: "SetNotServing", Handler: _XdsUpdateHealthService_SetNotServing_Handler, }, { MethodName: "SendHookRequest", Handler: _XdsUpdateHealthService_SendHookRequest_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
XdsUpdateHealthService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateHealthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBenchmarkServiceServer ¶ added in v1.35.0
func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
func RegisterHookServiceServer ¶ added in v1.58.0
func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer)
func RegisterLoadBalancerStatsServiceServer ¶ added in v1.28.0
func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer)
func RegisterReconnectServiceServer ¶ added in v1.35.0
func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)
func RegisterReportQpsScenarioServiceServer ¶ added in v1.35.0
func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
func RegisterUnimplementedServiceServer ¶ added in v1.0.5
func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)
func RegisterWorkerServiceServer ¶ added in v1.35.0
func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
func RegisterXdsUpdateClientConfigureServiceServer ¶ added in v1.35.0
func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)
func RegisterXdsUpdateHealthServiceServer ¶ added in v1.35.0
func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)
Types ¶
type BenchmarkServiceClient ¶ added in v1.35.0
type BenchmarkServiceClient interface { // One request followed by one response. // The server returns the client payload as-is. UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) // Repeated sequence of one request followed by one response. // Should be called streaming ping-pong // The server returns the client payload as-is on each response StreamingCall(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest, SimpleResponse], error) // Single-sided unbounded streaming from client to server // The server returns the client payload as-is once the client does WritesDone StreamingFromClient(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SimpleRequest, SimpleResponse], error) // Single-sided unbounded streaming from server to client // The server repeatedly returns the client payload as-is StreamingFromServer(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SimpleResponse], error) // Two-sided unbounded streaming between server to client // Both sides send the content of their own choice to the other StreamingBothWays(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest, SimpleResponse], error) }
BenchmarkServiceClient is the client API for BenchmarkService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewBenchmarkServiceClient ¶ added in v1.35.0
func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient
type BenchmarkServiceServer ¶ added in v1.35.0
type BenchmarkServiceServer interface { // One request followed by one response. // The server returns the client payload as-is. UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) // Repeated sequence of one request followed by one response. // Should be called streaming ping-pong // The server returns the client payload as-is on each response StreamingCall(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error // Single-sided unbounded streaming from client to server // The server returns the client payload as-is once the client does WritesDone StreamingFromClient(grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]) error // Single-sided unbounded streaming from server to client // The server repeatedly returns the client payload as-is StreamingFromServer(*SimpleRequest, grpc.ServerStreamingServer[SimpleResponse]) error // Two-sided unbounded streaming between server to client // Both sides send the content of their own choice to the other StreamingBothWays(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error // contains filtered or unexported methods }
BenchmarkServiceServer is the server API for BenchmarkService service. All implementations must embed UnimplementedBenchmarkServiceServer for forward compatibility.
type BenchmarkService_StreamingBothWaysClient ¶ added in v1.35.0
type BenchmarkService_StreamingBothWaysClient = grpc.BidiStreamingClient[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingBothWaysServer ¶ added in v1.35.0
type BenchmarkService_StreamingBothWaysServer = grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingCallClient ¶ added in v1.35.0
type BenchmarkService_StreamingCallClient = grpc.BidiStreamingClient[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingCallServer ¶ added in v1.35.0
type BenchmarkService_StreamingCallServer = grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingFromClientClient ¶ added in v1.35.0
type BenchmarkService_StreamingFromClientClient = grpc.ClientStreamingClient[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingFromClientServer ¶ added in v1.35.0
type BenchmarkService_StreamingFromClientServer = grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingFromServerClient ¶ added in v1.35.0
type BenchmarkService_StreamingFromServerClient = grpc.ServerStreamingClient[SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BenchmarkService_StreamingFromServerServer ¶ added in v1.35.0
type BenchmarkService_StreamingFromServerServer = grpc.ServerStreamingServer[SimpleResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BoolValue ¶ added in v1.35.0
type BoolValue struct { // The bool value. Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
TODO(dgq): Go back to using well-known types once https://github.com/grpc/grpc/issues/6980 has been fixed. import "google/protobuf/wrappers.proto";
func (*BoolValue) Descriptor
deprecated
added in
v1.35.0
func (*BoolValue) ProtoMessage ¶ added in v1.35.0
func (*BoolValue) ProtoMessage()
func (*BoolValue) ProtoReflect ¶ added in v1.35.0
func (x *BoolValue) ProtoReflect() protoreflect.Message
type ByteBufferParams ¶ added in v1.35.0
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
added in
v1.35.0
func (*ByteBufferParams) Descriptor() ([]byte, []int)
Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.
func (*ByteBufferParams) GetReqSize ¶ added in v1.35.0
func (x *ByteBufferParams) GetReqSize() int32
func (*ByteBufferParams) GetRespSize ¶ added in v1.35.0
func (x *ByteBufferParams) GetRespSize() int32
func (*ByteBufferParams) ProtoMessage ¶ added in v1.35.0
func (*ByteBufferParams) ProtoMessage()
func (*ByteBufferParams) ProtoReflect ¶ added in v1.35.0
func (x *ByteBufferParams) ProtoReflect() protoreflect.Message
func (*ByteBufferParams) Reset ¶ added in v1.35.0
func (x *ByteBufferParams) Reset()
func (*ByteBufferParams) String ¶ added in v1.35.0
func (x *ByteBufferParams) String() string
type ChannelArg ¶ added in v1.35.0
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
added in
v1.35.0
func (*ChannelArg) Descriptor() ([]byte, []int)
Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.
func (*ChannelArg) GetIntValue ¶ added in v1.35.0
func (x *ChannelArg) GetIntValue() int32
func (*ChannelArg) GetName ¶ added in v1.35.0
func (x *ChannelArg) GetName() string
func (*ChannelArg) GetStrValue ¶ added in v1.35.0
func (x *ChannelArg) GetStrValue() string
func (*ChannelArg) GetValue ¶ added in v1.35.0
func (m *ChannelArg) GetValue() isChannelArg_Value
func (*ChannelArg) ProtoMessage ¶ added in v1.35.0
func (*ChannelArg) ProtoMessage()
func (*ChannelArg) ProtoReflect ¶ added in v1.35.0
func (x *ChannelArg) ProtoReflect() protoreflect.Message
func (*ChannelArg) Reset ¶ added in v1.35.0
func (x *ChannelArg) Reset()
func (*ChannelArg) String ¶ added in v1.35.0
func (x *ChannelArg) String() string
type ChannelArg_IntValue ¶ added in v1.35.0
type ChannelArg_IntValue struct {
IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}
type ChannelArg_StrValue ¶ added in v1.35.0
type ChannelArg_StrValue struct {
StrValue string `protobuf:"bytes,2,opt,name=str_value,json=strValue,proto3,oneof"`
}
type ClientArgs ¶ added in v1.35.0
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
added in
v1.35.0
func (*ClientArgs) Descriptor() ([]byte, []int)
Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.
func (*ClientArgs) GetArgtype ¶ added in v1.35.0
func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
func (*ClientArgs) GetMark ¶ added in v1.35.0
func (x *ClientArgs) GetMark() *Mark
func (*ClientArgs) GetSetup ¶ added in v1.35.0
func (x *ClientArgs) GetSetup() *ClientConfig
func (*ClientArgs) ProtoMessage ¶ added in v1.35.0
func (*ClientArgs) ProtoMessage()
func (*ClientArgs) ProtoReflect ¶ added in v1.35.0
func (x *ClientArgs) ProtoReflect() protoreflect.Message
func (*ClientArgs) Reset ¶ added in v1.35.0
func (x *ClientArgs) Reset()
func (*ClientArgs) String ¶ added in v1.35.0
func (x *ClientArgs) String() string
type ClientArgs_Mark ¶ added in v1.35.0
type ClientArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ClientArgs_Setup ¶ added in v1.35.0
type ClientArgs_Setup struct {
Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ClientConfig ¶ added in v1.35.0
type ClientConfig struct { // List of targets to connect to. At least one target needs to be specified. 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"` // How many concurrent RPCs to start for each channel. // For synchronous client, use a separate thread for each outstanding RPC. OutstandingRpcsPerChannel int32 `` /* 141-byte string literal not displayed */ // Number of independent client channels to create. // i-th channel will connect to server_target[i % server_targets.size()] ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"` // Only for async client. Number of threads to use to start/manage RPCs. 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"` // The requested load for the entire client (aggregated over all the threads). 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"` // Specify the cores we should run the client on, if desired 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"` // If we use an OTHER_CLIENT client_type, this string gives more detail 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"` // Number of threads that share each completion queue ThreadsPerCq int32 `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"` // Number of messages on a stream before it gets finished/restarted MessagesPerStream int32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"` // Use coalescing API when possible. UseCoalesceApi bool `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,omitempty"` // If 0, disabled. Else, specifies the period between gathering latency // medians in milliseconds. MedianLatencyCollectionIntervalMillis int32 `` /* 180-byte string literal not displayed */ // Number of client processes. 0 indicates no restriction. 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
added in
v1.35.0
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig) GetAsyncClientThreads ¶ added in v1.35.0
func (x *ClientConfig) GetAsyncClientThreads() int32
func (*ClientConfig) GetChannelArgs ¶ added in v1.35.0
func (x *ClientConfig) GetChannelArgs() []*ChannelArg
func (*ClientConfig) GetClientChannels ¶ added in v1.35.0
func (x *ClientConfig) GetClientChannels() int32
func (*ClientConfig) GetClientProcesses ¶ added in v1.35.0
func (x *ClientConfig) GetClientProcesses() int32
func (*ClientConfig) GetClientType ¶ added in v1.35.0
func (x *ClientConfig) GetClientType() ClientType
func (*ClientConfig) GetCoreLimit ¶ added in v1.35.0
func (x *ClientConfig) GetCoreLimit() int32
func (*ClientConfig) GetCoreList ¶ added in v1.35.0
func (x *ClientConfig) GetCoreList() []int32
func (*ClientConfig) GetHistogramParams ¶ added in v1.35.0
func (x *ClientConfig) GetHistogramParams() *HistogramParams
func (*ClientConfig) GetLoadParams ¶ added in v1.35.0
func (x *ClientConfig) GetLoadParams() *LoadParams
func (*ClientConfig) GetMedianLatencyCollectionIntervalMillis ¶ added in v1.35.0
func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32
func (*ClientConfig) GetMessagesPerStream ¶ added in v1.35.0
func (x *ClientConfig) GetMessagesPerStream() int32
func (*ClientConfig) GetOtherClientApi ¶ added in v1.35.0
func (x *ClientConfig) GetOtherClientApi() string
func (*ClientConfig) GetOutstandingRpcsPerChannel ¶ added in v1.35.0
func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32
func (*ClientConfig) GetPayloadConfig ¶ added in v1.35.0
func (x *ClientConfig) GetPayloadConfig() *PayloadConfig
func (*ClientConfig) GetRpcType ¶ added in v1.35.0
func (x *ClientConfig) GetRpcType() RpcType
func (*ClientConfig) GetSecurityParams ¶ added in v1.35.0
func (x *ClientConfig) GetSecurityParams() *SecurityParams
func (*ClientConfig) GetServerTargets ¶ added in v1.35.0
func (x *ClientConfig) GetServerTargets() []string
func (*ClientConfig) GetThreadsPerCq ¶ added in v1.35.0
func (x *ClientConfig) GetThreadsPerCq() int32
func (*ClientConfig) GetUseCoalesceApi ¶ added in v1.35.0
func (x *ClientConfig) GetUseCoalesceApi() bool
func (*ClientConfig) ProtoMessage ¶ added in v1.35.0
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) ProtoReflect ¶ added in v1.35.0
func (x *ClientConfig) ProtoReflect() protoreflect.Message
func (*ClientConfig) Reset ¶ added in v1.35.0
func (x *ClientConfig) Reset()
func (*ClientConfig) String ¶ added in v1.35.0
func (x *ClientConfig) String() string
type ClientConfigureRequest ¶ added in v1.35.0
type ClientConfigureRequest struct { // The types of RPCs the client sends. Types []ClientConfigureRequest_RpcType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"types,omitempty"` // The collection of custom metadata to be attached to RPCs sent by the client. Metadata []*ClientConfigureRequest_Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"` // The deadline to use, in seconds, for all RPCs. If unset or zero, the // client will use the default from the command-line. TimeoutSec int32 `protobuf:"varint,3,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"` // contains filtered or unexported fields }
Configurations for a test client.
func (*ClientConfigureRequest) Descriptor
deprecated
added in
v1.35.0
func (*ClientConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.
func (*ClientConfigureRequest) GetMetadata ¶ added in v1.35.0
func (x *ClientConfigureRequest) GetMetadata() []*ClientConfigureRequest_Metadata
func (*ClientConfigureRequest) GetTimeoutSec ¶ added in v1.36.0
func (x *ClientConfigureRequest) GetTimeoutSec() int32
func (*ClientConfigureRequest) GetTypes ¶ added in v1.35.0
func (x *ClientConfigureRequest) GetTypes() []ClientConfigureRequest_RpcType
func (*ClientConfigureRequest) ProtoMessage ¶ added in v1.35.0
func (*ClientConfigureRequest) ProtoMessage()
func (*ClientConfigureRequest) ProtoReflect ¶ added in v1.35.0
func (x *ClientConfigureRequest) ProtoReflect() protoreflect.Message
func (*ClientConfigureRequest) Reset ¶ added in v1.35.0
func (x *ClientConfigureRequest) Reset()
func (*ClientConfigureRequest) String ¶ added in v1.35.0
func (x *ClientConfigureRequest) String() string
type ClientConfigureRequest_Metadata ¶ added in v1.35.0
type ClientConfigureRequest_Metadata struct { Type ClientConfigureRequest_RpcType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"type,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Metadata to be attached for the given type of RPCs.
func (*ClientConfigureRequest_Metadata) Descriptor
deprecated
added in
v1.35.0
func (*ClientConfigureRequest_Metadata) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.
func (*ClientConfigureRequest_Metadata) GetKey ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) GetKey() string
func (*ClientConfigureRequest_Metadata) GetType ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType
func (*ClientConfigureRequest_Metadata) GetValue ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) GetValue() string
func (*ClientConfigureRequest_Metadata) ProtoMessage ¶ added in v1.35.0
func (*ClientConfigureRequest_Metadata) ProtoMessage()
func (*ClientConfigureRequest_Metadata) ProtoReflect ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) ProtoReflect() protoreflect.Message
func (*ClientConfigureRequest_Metadata) Reset ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) Reset()
func (*ClientConfigureRequest_Metadata) String ¶ added in v1.35.0
func (x *ClientConfigureRequest_Metadata) String() string
type ClientConfigureRequest_RpcType ¶ added in v1.35.0
type ClientConfigureRequest_RpcType int32
Type of RPCs to send.
const ( ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0 ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1 )
func (ClientConfigureRequest_RpcType) Descriptor ¶ added in v1.35.0
func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor
func (ClientConfigureRequest_RpcType) Enum ¶ added in v1.35.0
func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType
func (ClientConfigureRequest_RpcType) EnumDescriptor
deprecated
added in
v1.35.0
func (ClientConfigureRequest_RpcType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.
func (ClientConfigureRequest_RpcType) Number ¶ added in v1.35.0
func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber
func (ClientConfigureRequest_RpcType) String ¶ added in v1.35.0
func (x ClientConfigureRequest_RpcType) String() string
func (ClientConfigureRequest_RpcType) Type ¶ added in v1.35.0
func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType
type ClientConfigureResponse ¶ added in v1.35.0
type ClientConfigureResponse struct {
// contains filtered or unexported fields
}
Response for updating a test client's configuration.
func (*ClientConfigureResponse) Descriptor
deprecated
added in
v1.35.0
func (*ClientConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.
func (*ClientConfigureResponse) ProtoMessage ¶ added in v1.35.0
func (*ClientConfigureResponse) ProtoMessage()
func (*ClientConfigureResponse) ProtoReflect ¶ added in v1.35.0
func (x *ClientConfigureResponse) ProtoReflect() protoreflect.Message
func (*ClientConfigureResponse) Reset ¶ added in v1.35.0
func (x *ClientConfigureResponse) Reset()
func (*ClientConfigureResponse) String ¶ added in v1.35.0
func (x *ClientConfigureResponse) String() string
type ClientStats ¶ added in v1.35.0
type ClientStats struct { // Latency histogram. Data points are in nanoseconds. Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"` // See ServerStats for details. 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"` // Number of failed requests (one row per status code seen) RequestResults []*RequestResultCount `protobuf:"bytes,5,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"` // Number of polls called inside completion queue CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"` // Core library stats 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
added in
v1.35.0
func (*ClientStats) Descriptor() ([]byte, []int)
Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.
func (*ClientStats) GetCoreStats ¶ added in v1.35.0
func (x *ClientStats) GetCoreStats() *core.Stats
func (*ClientStats) GetCqPollCount ¶ added in v1.35.0
func (x *ClientStats) GetCqPollCount() uint64
func (*ClientStats) GetLatencies ¶ added in v1.35.0
func (x *ClientStats) GetLatencies() *HistogramData
func (*ClientStats) GetRequestResults ¶ added in v1.35.0
func (x *ClientStats) GetRequestResults() []*RequestResultCount
func (*ClientStats) GetTimeElapsed ¶ added in v1.35.0
func (x *ClientStats) GetTimeElapsed() float64
func (*ClientStats) GetTimeSystem ¶ added in v1.35.0
func (x *ClientStats) GetTimeSystem() float64
func (*ClientStats) GetTimeUser ¶ added in v1.35.0
func (x *ClientStats) GetTimeUser() float64
func (*ClientStats) ProtoMessage ¶ added in v1.35.0
func (*ClientStats) ProtoMessage()
func (*ClientStats) ProtoReflect ¶ added in v1.35.0
func (x *ClientStats) ProtoReflect() protoreflect.Message
func (*ClientStats) Reset ¶ added in v1.35.0
func (x *ClientStats) Reset()
func (*ClientStats) String ¶ added in v1.35.0
func (x *ClientStats) String() string
type ClientStatus ¶ added in v1.35.0
type ClientStatus struct { Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // contains filtered or unexported fields }
func (*ClientStatus) Descriptor
deprecated
added in
v1.35.0
func (*ClientStatus) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.
func (*ClientStatus) GetStats ¶ added in v1.35.0
func (x *ClientStatus) GetStats() *ClientStats
func (*ClientStatus) ProtoMessage ¶ added in v1.35.0
func (*ClientStatus) ProtoMessage()
func (*ClientStatus) ProtoReflect ¶ added in v1.35.0
func (x *ClientStatus) ProtoReflect() protoreflect.Message
func (*ClientStatus) Reset ¶ added in v1.35.0
func (x *ClientStatus) Reset()
func (*ClientStatus) String ¶ added in v1.35.0
func (x *ClientStatus) String() string
type ClientType ¶ added in v1.35.0
type ClientType int32
const ( // Many languages support a basic distinction between using // sync or async client, and this allows the specification ClientType_SYNC_CLIENT ClientType = 0 ClientType_ASYNC_CLIENT ClientType = 1 ClientType_OTHER_CLIENT ClientType = 2 // used for some language-specific variants ClientType_CALLBACK_CLIENT ClientType = 3 )
func (ClientType) Descriptor ¶ added in v1.35.0
func (ClientType) Descriptor() protoreflect.EnumDescriptor
func (ClientType) Enum ¶ added in v1.35.0
func (x ClientType) Enum() *ClientType
func (ClientType) EnumDescriptor
deprecated
added in
v1.35.0
func (ClientType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientType.Descriptor instead.
func (ClientType) Number ¶ added in v1.35.0
func (x ClientType) Number() protoreflect.EnumNumber
func (ClientType) String ¶ added in v1.35.0
func (x ClientType) String() string
func (ClientType) Type ¶ added in v1.35.0
func (ClientType) Type() protoreflect.EnumType
type ClosedLoopParams ¶ added in v1.35.0
type ClosedLoopParams struct {
// contains filtered or unexported fields
}
Once an RPC finishes, immediately start a new one. No configuration parameters needed.
func (*ClosedLoopParams) Descriptor
deprecated
added in
v1.35.0
func (*ClosedLoopParams) Descriptor() ([]byte, []int)
Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.
func (*ClosedLoopParams) ProtoMessage ¶ added in v1.35.0
func (*ClosedLoopParams) ProtoMessage()
func (*ClosedLoopParams) ProtoReflect ¶ added in v1.35.0
func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message
func (*ClosedLoopParams) Reset ¶ added in v1.35.0
func (x *ClosedLoopParams) Reset()
func (*ClosedLoopParams) String ¶ added in v1.35.0
func (x *ClosedLoopParams) String() string
type ComplexProtoParams ¶ added in v1.35.0
type ComplexProtoParams struct {
// contains filtered or unexported fields
}
func (*ComplexProtoParams) Descriptor
deprecated
added in
v1.35.0
func (*ComplexProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.
func (*ComplexProtoParams) ProtoMessage ¶ added in v1.35.0
func (*ComplexProtoParams) ProtoMessage()
func (*ComplexProtoParams) ProtoReflect ¶ added in v1.35.0
func (x *ComplexProtoParams) ProtoReflect() protoreflect.Message
func (*ComplexProtoParams) Reset ¶ added in v1.35.0
func (x *ComplexProtoParams) Reset()
func (*ComplexProtoParams) String ¶ added in v1.35.0
func (x *ComplexProtoParams) String() string
type CoreRequest ¶ added in v1.35.0
type CoreRequest struct {
// contains filtered or unexported fields
}
func (*CoreRequest) Descriptor
deprecated
added in
v1.35.0
func (*CoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.
func (*CoreRequest) ProtoMessage ¶ added in v1.35.0
func (*CoreRequest) ProtoMessage()
func (*CoreRequest) ProtoReflect ¶ added in v1.35.0
func (x *CoreRequest) ProtoReflect() protoreflect.Message
func (*CoreRequest) Reset ¶ added in v1.35.0
func (x *CoreRequest) Reset()
func (*CoreRequest) String ¶ added in v1.35.0
func (x *CoreRequest) String() string
type CoreResponse ¶ added in v1.35.0
type CoreResponse struct { // Number of cores available on the server Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*CoreResponse) Descriptor
deprecated
added in
v1.35.0
func (*CoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.
func (*CoreResponse) GetCores ¶ added in v1.35.0
func (x *CoreResponse) GetCores() int32
func (*CoreResponse) ProtoMessage ¶ added in v1.35.0
func (*CoreResponse) ProtoMessage()
func (*CoreResponse) ProtoReflect ¶ added in v1.35.0
func (x *CoreResponse) ProtoReflect() protoreflect.Message
func (*CoreResponse) Reset ¶ added in v1.35.0
func (x *CoreResponse) Reset()
func (*CoreResponse) String ¶ added in v1.35.0
func (x *CoreResponse) String() string
type EchoStatus ¶ added in v1.0.3
type EchoStatus struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.
func (*EchoStatus) Descriptor
deprecated
added in
v1.0.3
func (*EchoStatus) Descriptor() ([]byte, []int)
Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.
func (*EchoStatus) GetCode ¶ added in v1.0.3
func (x *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶ added in v1.0.3
func (x *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶ added in v1.0.3
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) ProtoReflect ¶ added in v1.33.2
func (x *EchoStatus) ProtoReflect() protoreflect.Message
func (*EchoStatus) Reset ¶ added in v1.0.3
func (x *EchoStatus) Reset()
func (*EchoStatus) String ¶ added in v1.0.3
func (x *EchoStatus) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
An empty message that you can re-use to avoid defining duplicated empty messages in your project. A typical example is to use it as argument or the return value of a service API. For instance:
service Foo { rpc Bar (grpc.testing.Empty) returns (grpc.testing.Empty) { }; };
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶ added in v1.33.2
func (x *Empty) ProtoReflect() protoreflect.Message
type GrpclbRouteType ¶ added in v1.26.0
type GrpclbRouteType int32
The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependent.
const ( // Server didn't detect the route that a client took to reach it. GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0 // Indicates that a client reached a server via gRPCLB fallback. GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1 // Indicates that a client reached a server as a gRPCLB-given backend. GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND GrpclbRouteType = 2 )
func (GrpclbRouteType) Descriptor ¶ added in v1.33.2
func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor
func (GrpclbRouteType) Enum ¶ added in v1.33.2
func (x GrpclbRouteType) Enum() *GrpclbRouteType
func (GrpclbRouteType) EnumDescriptor
deprecated
added in
v1.26.0
func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)
Deprecated: Use GrpclbRouteType.Descriptor instead.
func (GrpclbRouteType) Number ¶ added in v1.33.2
func (x GrpclbRouteType) Number() protoreflect.EnumNumber
func (GrpclbRouteType) String ¶ added in v1.26.0
func (x GrpclbRouteType) String() string
func (GrpclbRouteType) Type ¶ added in v1.33.2
func (GrpclbRouteType) Type() protoreflect.EnumType
type HistogramData ¶ added in v1.35.0
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 }
Histogram data based on grpc/support/histogram.c
func (*HistogramData) Descriptor
deprecated
added in
v1.35.0
func (*HistogramData) Descriptor() ([]byte, []int)
Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.
func (*HistogramData) GetBucket ¶ added in v1.35.0
func (x *HistogramData) GetBucket() []uint32
func (*HistogramData) GetCount ¶ added in v1.35.0
func (x *HistogramData) GetCount() float64
func (*HistogramData) GetMaxSeen ¶ added in v1.35.0
func (x *HistogramData) GetMaxSeen() float64
func (*HistogramData) GetMinSeen ¶ added in v1.35.0
func (x *HistogramData) GetMinSeen() float64
func (*HistogramData) GetSum ¶ added in v1.35.0
func (x *HistogramData) GetSum() float64
func (*HistogramData) GetSumOfSquares ¶ added in v1.35.0
func (x *HistogramData) GetSumOfSquares() float64
func (*HistogramData) ProtoMessage ¶ added in v1.35.0
func (*HistogramData) ProtoMessage()
func (*HistogramData) ProtoReflect ¶ added in v1.35.0
func (x *HistogramData) ProtoReflect() protoreflect.Message
func (*HistogramData) Reset ¶ added in v1.35.0
func (x *HistogramData) Reset()
func (*HistogramData) String ¶ added in v1.35.0
func (x *HistogramData) String() string
type HistogramParams ¶ added in v1.35.0
type HistogramParams struct { Resolution float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"` // first bucket is [0, 1 + resolution) MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"` // use enough buckets to allow this value // contains filtered or unexported fields }
Histogram params based on grpc/support/histogram.c
func (*HistogramParams) Descriptor
deprecated
added in
v1.35.0
func (*HistogramParams) Descriptor() ([]byte, []int)
Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.
func (*HistogramParams) GetMaxPossible ¶ added in v1.35.0
func (x *HistogramParams) GetMaxPossible() float64
func (*HistogramParams) GetResolution ¶ added in v1.35.0
func (x *HistogramParams) GetResolution() float64
func (*HistogramParams) ProtoMessage ¶ added in v1.35.0
func (*HistogramParams) ProtoMessage()
func (*HistogramParams) ProtoReflect ¶ added in v1.35.0
func (x *HistogramParams) ProtoReflect() protoreflect.Message
func (*HistogramParams) Reset ¶ added in v1.35.0
func (x *HistogramParams) Reset()
func (*HistogramParams) String ¶ added in v1.35.0
func (x *HistogramParams) String() string
type HookRequest ¶ added in v1.58.0
type HookRequest struct { Command HookRequest_HookRequestCommand `protobuf:"varint,1,opt,name=command,proto3,enum=grpc.testing.HookRequest_HookRequestCommand" json:"command,omitempty"` GrpcCodeToReturn int32 `protobuf:"varint,2,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"` GrpcStatusDescription string `` /* 126-byte string literal not displayed */ // Server port to listen to ServerPort int32 `protobuf:"varint,4,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"` // contains filtered or unexported fields }
func (*HookRequest) Descriptor
deprecated
added in
v1.58.0
func (*HookRequest) Descriptor() ([]byte, []int)
Deprecated: Use HookRequest.ProtoReflect.Descriptor instead.
func (*HookRequest) GetCommand ¶ added in v1.58.0
func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand
func (*HookRequest) GetGrpcCodeToReturn ¶ added in v1.58.0
func (x *HookRequest) GetGrpcCodeToReturn() int32
func (*HookRequest) GetGrpcStatusDescription ¶ added in v1.58.0
func (x *HookRequest) GetGrpcStatusDescription() string
func (*HookRequest) GetServerPort ¶ added in v1.58.0
func (x *HookRequest) GetServerPort() int32
func (*HookRequest) ProtoMessage ¶ added in v1.58.0
func (*HookRequest) ProtoMessage()
func (*HookRequest) ProtoReflect ¶ added in v1.58.0
func (x *HookRequest) ProtoReflect() protoreflect.Message
func (*HookRequest) Reset ¶ added in v1.58.0
func (x *HookRequest) Reset()
func (*HookRequest) String ¶ added in v1.58.0
func (x *HookRequest) String() string
type HookRequest_HookRequestCommand ¶ added in v1.59.0
type HookRequest_HookRequestCommand int32
const ( // Default value HookRequest_UNSPECIFIED HookRequest_HookRequestCommand = 0 // Start the HTTP endpoint HookRequest_START HookRequest_HookRequestCommand = 1 // Stop HookRequest_STOP HookRequest_HookRequestCommand = 2 // Return from HTTP GET/POST HookRequest_RETURN HookRequest_HookRequestCommand = 3 )
func (HookRequest_HookRequestCommand) Descriptor ¶ added in v1.59.0
func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor
func (HookRequest_HookRequestCommand) Enum ¶ added in v1.59.0
func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand
func (HookRequest_HookRequestCommand) EnumDescriptor
deprecated
added in
v1.59.0
func (HookRequest_HookRequestCommand) EnumDescriptor() ([]byte, []int)
Deprecated: Use HookRequest_HookRequestCommand.Descriptor instead.
func (HookRequest_HookRequestCommand) Number ¶ added in v1.59.0
func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber
func (HookRequest_HookRequestCommand) String ¶ added in v1.59.0
func (x HookRequest_HookRequestCommand) String() string
func (HookRequest_HookRequestCommand) Type ¶ added in v1.59.0
func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType
type HookResponse ¶ added in v1.58.0
type HookResponse struct {
// contains filtered or unexported fields
}
func (*HookResponse) Descriptor
deprecated
added in
v1.58.0
func (*HookResponse) Descriptor() ([]byte, []int)
Deprecated: Use HookResponse.ProtoReflect.Descriptor instead.
func (*HookResponse) ProtoMessage ¶ added in v1.58.0
func (*HookResponse) ProtoMessage()
func (*HookResponse) ProtoReflect ¶ added in v1.58.0
func (x *HookResponse) ProtoReflect() protoreflect.Message
func (*HookResponse) Reset ¶ added in v1.58.0
func (x *HookResponse) Reset()
func (*HookResponse) String ¶ added in v1.58.0
func (x *HookResponse) String() string
type HookServiceClient ¶ added in v1.58.0
type HookServiceClient interface { // Sends a request that will "hang" until the return status is set by a call // to a SetReturnStatus Hook(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) // Sets a return status for pending and upcoming calls to Hook SetReturnStatus(ctx context.Context, in *SetReturnStatusRequest, opts ...grpc.CallOption) (*Empty, error) // Clears the return status. Incoming calls to Hook will "hang" ClearReturnStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) }
HookServiceClient is the client API for HookService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Hook service. Used to keep Kubernetes from shutting the pod down.
func NewHookServiceClient ¶ added in v1.58.0
func NewHookServiceClient(cc grpc.ClientConnInterface) HookServiceClient
type HookServiceServer ¶ added in v1.58.0
type HookServiceServer interface { // Sends a request that will "hang" until the return status is set by a call // to a SetReturnStatus Hook(context.Context, *Empty) (*Empty, error) // Sets a return status for pending and upcoming calls to Hook SetReturnStatus(context.Context, *SetReturnStatusRequest) (*Empty, error) // Clears the return status. Incoming calls to Hook will "hang" ClearReturnStatus(context.Context, *Empty) (*Empty, error) // contains filtered or unexported methods }
HookServiceServer is the server API for HookService service. All implementations must embed UnimplementedHookServiceServer for forward compatibility.
Hook service. Used to keep Kubernetes from shutting the pod down.
type LoadBalancerAccumulatedStatsRequest ¶ added in v1.35.0
type LoadBalancerAccumulatedStatsRequest struct {
// contains filtered or unexported fields
}
Request for retrieving a test client's accumulated stats.
func (*LoadBalancerAccumulatedStatsRequest) Descriptor
deprecated
added in
v1.35.0
func (*LoadBalancerAccumulatedStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage ¶ added in v1.35.0
func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()
func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsRequest) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsRequest) Reset ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsRequest) Reset()
func (*LoadBalancerAccumulatedStatsRequest) String ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsRequest) String() string
type LoadBalancerAccumulatedStatsResponse ¶ added in v1.35.0
type LoadBalancerAccumulatedStatsResponse struct { // The total number of RPCs have ever issued for each type. // Deprecated: use stats_per_method.rpcs_started instead. // // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsStartedByMethod map[string]int32 `` /* 222-byte string literal not displayed */ // The total number of RPCs have ever completed successfully for each type. // Deprecated: use stats_per_method.result instead. // // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsSucceededByMethod map[string]int32 `` /* 228-byte string literal not displayed */ // The total number of RPCs have ever failed for each type. // Deprecated: use stats_per_method.result instead. // // Deprecated: Marked as deprecated in grpc/testing/messages.proto. NumRpcsFailedByMethod map[string]int32 `` /* 219-byte string literal not displayed */ // Per-method RPC statistics. The key is the RpcType in string form; e.g. // 'EMPTY_CALL' or 'UNARY_CALL' StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 193-byte string literal not displayed */ // contains filtered or unexported fields }
Accumulated stats for RPCs sent by a test client.
func (*LoadBalancerAccumulatedStatsResponse) Descriptor
deprecated
added in
v1.35.0
func (*LoadBalancerAccumulatedStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod
deprecated
added in
v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod
deprecated
added in
v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod
deprecated
added in
v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32
Deprecated: Marked as deprecated in grpc/testing/messages.proto.
func (*LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats
func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage ¶ added in v1.35.0
func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()
func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsResponse) Reset ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) Reset()
func (*LoadBalancerAccumulatedStatsResponse) String ¶ added in v1.35.0
func (x *LoadBalancerAccumulatedStatsResponse) String() string
type LoadBalancerAccumulatedStatsResponse_MethodStats ¶ added in v1.36.0
type LoadBalancerAccumulatedStatsResponse_MethodStats struct { // The number of RPCs that were started for this method. RpcsStarted int32 `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"` // The number of RPCs that completed with each status for this method. The // key is the integral value of a google.rpc.Code; the value is the count. Result map[int32]int32 `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor
deprecated
added in
v1.36.0
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage ¶ added in v1.36.0
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect() protoreflect.Message
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()
func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String ¶ added in v1.36.0
func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string
type LoadBalancerStatsRequest ¶ added in v1.28.0
type LoadBalancerStatsRequest struct { // Request stats for the next num_rpcs sent by client. NumRpcs int32 `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"` // If num_rpcs have not completed within timeout_sec, return partial results. TimeoutSec int32 `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"` // Response header + trailer metadata entries we want the values of. // Matching of the keys is case-insensitive as per rfc7540#section-8.1.2 // * (asterisk) is a special value that will return all metadata entries MetadataKeys []string `protobuf:"bytes,3,rep,name=metadata_keys,json=metadataKeys,proto3" json:"metadata_keys,omitempty"` // contains filtered or unexported fields }
func (*LoadBalancerStatsRequest) Descriptor
deprecated
added in
v1.28.0
func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsRequest) GetMetadataKeys ¶ added in v1.58.0
func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string
func (*LoadBalancerStatsRequest) GetNumRpcs ¶ added in v1.28.0
func (x *LoadBalancerStatsRequest) GetNumRpcs() int32
func (*LoadBalancerStatsRequest) GetTimeoutSec ¶ added in v1.28.0
func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32
func (*LoadBalancerStatsRequest) ProtoMessage ¶ added in v1.28.0
func (*LoadBalancerStatsRequest) ProtoMessage()
func (*LoadBalancerStatsRequest) ProtoReflect ¶ added in v1.33.2
func (x *LoadBalancerStatsRequest) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsRequest) Reset ¶ added in v1.28.0
func (x *LoadBalancerStatsRequest) Reset()
func (*LoadBalancerStatsRequest) String ¶ added in v1.28.0
func (x *LoadBalancerStatsRequest) String() string
type LoadBalancerStatsResponse ¶ added in v1.28.0
type LoadBalancerStatsResponse struct { // The number of completed RPCs for each peer. RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */ // The number of RPCs that failed to record a remote peer. NumFailures int32 `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"` RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `` /* 187-byte string literal not displayed */ // All the metadata of all RPCs for each peer. MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer `` /* 196-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LoadBalancerStatsResponse) Descriptor
deprecated
added in
v1.28.0
func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse) GetMetadatasByPeer ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer
func (*LoadBalancerStatsResponse) GetNumFailures ¶ added in v1.28.0
func (x *LoadBalancerStatsResponse) GetNumFailures() int32
func (*LoadBalancerStatsResponse) GetRpcsByMethod ¶ added in v1.31.0
func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
func (*LoadBalancerStatsResponse) GetRpcsByPeer ¶ added in v1.28.0
func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse) ProtoMessage ¶ added in v1.28.0
func (*LoadBalancerStatsResponse) ProtoMessage()
func (*LoadBalancerStatsResponse) ProtoReflect ¶ added in v1.33.2
func (x *LoadBalancerStatsResponse) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse) Reset ¶ added in v1.28.0
func (x *LoadBalancerStatsResponse) Reset()
func (*LoadBalancerStatsResponse) String ¶ added in v1.28.0
func (x *LoadBalancerStatsResponse) String() string
type LoadBalancerStatsResponse_MetadataByPeer ¶ added in v1.58.0
type LoadBalancerStatsResponse_MetadataByPeer struct { // List of RpcMetadata in for each RPC with a given peer RpcMetadata []*LoadBalancerStatsResponse_RpcMetadata `protobuf:"bytes,1,rep,name=rpc_metadata,json=rpcMetadata,proto3" json:"rpc_metadata,omitempty"` // contains filtered or unexported fields }
func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor
deprecated
added in
v1.58.0
func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataByPeer.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage ¶ added in v1.58.0
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage()
func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_MetadataByPeer) Reset ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset()
func (*LoadBalancerStatsResponse_MetadataByPeer) String ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string
type LoadBalancerStatsResponse_MetadataEntry ¶ added in v1.58.0
type LoadBalancerStatsResponse_MetadataEntry struct { // Key, exactly as received from the server. Case may be different from what // was requested in the LoadBalancerStatsRequest) Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Value, exactly as received from the server. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Metadata type Type LoadBalancerStatsResponse_MetadataType `protobuf:"varint,3,opt,name=type,proto3,enum=grpc.testing.LoadBalancerStatsResponse_MetadataType" json:"type,omitempty"` // contains filtered or unexported fields }
func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor
deprecated
added in
v1.58.0
func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataEntry.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_MetadataEntry) GetKey ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string
func (*LoadBalancerStatsResponse_MetadataEntry) GetType ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType
func (*LoadBalancerStatsResponse_MetadataEntry) GetValue ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage ¶ added in v1.58.0
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage()
func (*LoadBalancerStatsResponse_MetadataEntry) ProtoReflect ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_MetadataEntry) Reset ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) Reset()
func (*LoadBalancerStatsResponse_MetadataEntry) String ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_MetadataEntry) String() string
type LoadBalancerStatsResponse_MetadataType ¶ added in v1.58.0
type LoadBalancerStatsResponse_MetadataType int32
const ( LoadBalancerStatsResponse_UNKNOWN LoadBalancerStatsResponse_MetadataType = 0 LoadBalancerStatsResponse_INITIAL LoadBalancerStatsResponse_MetadataType = 1 LoadBalancerStatsResponse_TRAILING LoadBalancerStatsResponse_MetadataType = 2 )
func (LoadBalancerStatsResponse_MetadataType) Descriptor ¶ added in v1.58.0
func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor
func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor
deprecated
added in
v1.58.0
func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_MetadataType.Descriptor instead.
func (LoadBalancerStatsResponse_MetadataType) Number ¶ added in v1.58.0
func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber
func (LoadBalancerStatsResponse_MetadataType) String ¶ added in v1.58.0
func (x LoadBalancerStatsResponse_MetadataType) String() string
func (LoadBalancerStatsResponse_MetadataType) Type ¶ added in v1.58.0
func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType
type LoadBalancerStatsResponse_RpcMetadata ¶ added in v1.58.0
type LoadBalancerStatsResponse_RpcMetadata struct { // metadata values for each rpc for the keys specified in // LoadBalancerStatsRequest.metadata_keys. Metadata []*LoadBalancerStatsResponse_MetadataEntry `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor
deprecated
added in
v1.58.0
func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_RpcMetadata.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_RpcMetadata) GetMetadata ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage ¶ added in v1.58.0
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()
func (*LoadBalancerStatsResponse_RpcMetadata) ProtoReflect ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_RpcMetadata) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_RpcMetadata) Reset ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_RpcMetadata) Reset()
func (*LoadBalancerStatsResponse_RpcMetadata) String ¶ added in v1.58.0
func (x *LoadBalancerStatsResponse_RpcMetadata) String() string
type LoadBalancerStatsResponse_RpcsByPeer ¶ added in v1.31.0
type LoadBalancerStatsResponse_RpcsByPeer struct { // The number of completed RPCs for each peer. RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor
deprecated
added in
v1.31.0
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)
Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.
func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer ¶ added in v1.31.0
func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage ¶ added in v1.31.0
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect ¶ added in v1.33.2
func (x *LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect() protoreflect.Message
func (*LoadBalancerStatsResponse_RpcsByPeer) Reset ¶ added in v1.31.0
func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()
func (*LoadBalancerStatsResponse_RpcsByPeer) String ¶ added in v1.31.0
func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string
type LoadBalancerStatsServiceClient ¶ added in v1.28.0
type LoadBalancerStatsServiceClient interface { // Gets the backend distribution for RPCs sent by a test client. GetClientStats(ctx context.Context, in *LoadBalancerStatsRequest, opts ...grpc.CallOption) (*LoadBalancerStatsResponse, error) // Gets the accumulated stats for RPCs sent by a test client. GetClientAccumulatedStats(ctx context.Context, in *LoadBalancerAccumulatedStatsRequest, opts ...grpc.CallOption) (*LoadBalancerAccumulatedStatsResponse, error) }
LoadBalancerStatsServiceClient is the client API for LoadBalancerStatsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A service used to obtain stats for verifying LB behavior.
func NewLoadBalancerStatsServiceClient ¶ added in v1.28.0
func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient
type LoadBalancerStatsServiceServer ¶ added in v1.28.0
type LoadBalancerStatsServiceServer interface { // Gets the backend distribution for RPCs sent by a test client. GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) // Gets the accumulated stats for RPCs sent by a test client. GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error) // contains filtered or unexported methods }
LoadBalancerStatsServiceServer is the server API for LoadBalancerStatsService service. All implementations must embed UnimplementedLoadBalancerStatsServiceServer for forward compatibility.
A service used to obtain stats for verifying LB behavior.
type LoadParams ¶ added in v1.35.0
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
added in
v1.35.0
func (*LoadParams) Descriptor() ([]byte, []int)
Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.
func (*LoadParams) GetClosedLoop ¶ added in v1.35.0
func (x *LoadParams) GetClosedLoop() *ClosedLoopParams
func (*LoadParams) GetLoad ¶ added in v1.35.0
func (m *LoadParams) GetLoad() isLoadParams_Load
func (*LoadParams) GetPoisson ¶ added in v1.35.0
func (x *LoadParams) GetPoisson() *PoissonParams
func (*LoadParams) ProtoMessage ¶ added in v1.35.0
func (*LoadParams) ProtoMessage()
func (*LoadParams) ProtoReflect ¶ added in v1.35.0
func (x *LoadParams) ProtoReflect() protoreflect.Message
func (*LoadParams) Reset ¶ added in v1.35.0
func (x *LoadParams) Reset()
func (*LoadParams) String ¶ added in v1.35.0
func (x *LoadParams) String() string
type LoadParams_ClosedLoop ¶ added in v1.35.0
type LoadParams_ClosedLoop struct {
ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
}
type LoadParams_Poisson ¶ added in v1.35.0
type LoadParams_Poisson struct {
Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
}
type Mark ¶ added in v1.35.0
type Mark struct { // if true, the stats will be reset after taking their snapshot. Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"` // contains filtered or unexported fields }
Request current stats
func (*Mark) Descriptor
deprecated
added in
v1.35.0
func (*Mark) ProtoMessage ¶ added in v1.35.0
func (*Mark) ProtoMessage()
func (*Mark) ProtoReflect ¶ added in v1.35.0
func (x *Mark) ProtoReflect() protoreflect.Message
type MemorySize ¶ added in v1.58.0
type MemorySize struct { Rss int64 `protobuf:"varint,1,opt,name=rss,proto3" json:"rss,omitempty"` // contains filtered or unexported fields }
func (*MemorySize) Descriptor
deprecated
added in
v1.58.0
func (*MemorySize) Descriptor() ([]byte, []int)
Deprecated: Use MemorySize.ProtoReflect.Descriptor instead.
func (*MemorySize) GetRss ¶ added in v1.58.0
func (x *MemorySize) GetRss() int64
func (*MemorySize) ProtoMessage ¶ added in v1.58.0
func (*MemorySize) ProtoMessage()
func (*MemorySize) ProtoReflect ¶ added in v1.58.0
func (x *MemorySize) ProtoReflect() protoreflect.Message
func (*MemorySize) Reset ¶ added in v1.58.0
func (x *MemorySize) Reset()
func (*MemorySize) String ¶ added in v1.58.0
func (x *MemorySize) String() string
type Payload ¶
type Payload struct { // The type of data in body. Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"` // Primary contents of payload. Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor
deprecated
func (*Payload) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶ added in v1.33.2
func (x *Payload) ProtoReflect() protoreflect.Message
type PayloadConfig ¶ added in v1.35.0
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
added in
v1.35.0
func (*PayloadConfig) Descriptor() ([]byte, []int)
Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.
func (*PayloadConfig) GetBytebufParams ¶ added in v1.35.0
func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams
func (*PayloadConfig) GetComplexParams ¶ added in v1.35.0
func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams
func (*PayloadConfig) GetPayload ¶ added in v1.35.0
func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
func (*PayloadConfig) GetSimpleParams ¶ added in v1.35.0
func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams
func (*PayloadConfig) ProtoMessage ¶ added in v1.35.0
func (*PayloadConfig) ProtoMessage()
func (*PayloadConfig) ProtoReflect ¶ added in v1.35.0
func (x *PayloadConfig) ProtoReflect() protoreflect.Message
func (*PayloadConfig) Reset ¶ added in v1.35.0
func (x *PayloadConfig) Reset()
func (*PayloadConfig) String ¶ added in v1.35.0
func (x *PayloadConfig) String() string
type PayloadConfig_BytebufParams ¶ added in v1.35.0
type PayloadConfig_BytebufParams struct {
BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,proto3,oneof"`
}
type PayloadConfig_ComplexParams ¶ added in v1.35.0
type PayloadConfig_ComplexParams struct {
ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,proto3,oneof"`
}
type PayloadConfig_SimpleParams ¶ added in v1.35.0
type PayloadConfig_SimpleParams struct {
SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,oneof"`
}
type PayloadType ¶
type PayloadType int32
The type of payload that should be returned.
const ( // Compressable text format. PayloadType_COMPRESSABLE PayloadType = 0 )
func (PayloadType) Descriptor ¶ added in v1.33.2
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 ¶ added in v1.33.2
func (x PayloadType) Number() protoreflect.EnumNumber
func (PayloadType) String ¶
func (x PayloadType) String() string
func (PayloadType) Type ¶ added in v1.33.2
func (PayloadType) Type() protoreflect.EnumType
type PoissonParams ¶ added in v1.35.0
type PoissonParams struct { // The rate of arrivals (a.k.a. lambda parameter of the exp distribution). OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` // contains filtered or unexported fields }
Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.
func (*PoissonParams) Descriptor
deprecated
added in
v1.35.0
func (*PoissonParams) Descriptor() ([]byte, []int)
Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.
func (*PoissonParams) GetOfferedLoad ¶ added in v1.35.0
func (x *PoissonParams) GetOfferedLoad() float64
func (*PoissonParams) ProtoMessage ¶ added in v1.35.0
func (*PoissonParams) ProtoMessage()
func (*PoissonParams) ProtoReflect ¶ added in v1.35.0
func (x *PoissonParams) ProtoReflect() protoreflect.Message
func (*PoissonParams) Reset ¶ added in v1.35.0
func (x *PoissonParams) Reset()
func (*PoissonParams) String ¶ added in v1.35.0
func (x *PoissonParams) String() string
type ReconnectInfo ¶ added in v1.35.0
type ReconnectInfo struct { Passed bool `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"` BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"` // contains filtered or unexported fields }
For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.
func (*ReconnectInfo) Descriptor
deprecated
added in
v1.35.0
func (*ReconnectInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.
func (*ReconnectInfo) GetBackoffMs ¶ added in v1.35.0
func (x *ReconnectInfo) GetBackoffMs() []int32
func (*ReconnectInfo) GetPassed ¶ added in v1.35.0
func (x *ReconnectInfo) GetPassed() bool
func (*ReconnectInfo) ProtoMessage ¶ added in v1.35.0
func (*ReconnectInfo) ProtoMessage()
func (*ReconnectInfo) ProtoReflect ¶ added in v1.35.0
func (x *ReconnectInfo) ProtoReflect() protoreflect.Message
func (*ReconnectInfo) Reset ¶ added in v1.35.0
func (x *ReconnectInfo) Reset()
func (*ReconnectInfo) String ¶ added in v1.35.0
func (x *ReconnectInfo) String() string
type ReconnectParams ¶ added in v1.35.0
type ReconnectParams struct { MaxReconnectBackoffMs int32 `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
For reconnect interop test only. Client tells server what reconnection parameters it used.
func (*ReconnectParams) Descriptor
deprecated
added in
v1.35.0
func (*ReconnectParams) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.
func (*ReconnectParams) GetMaxReconnectBackoffMs ¶ added in v1.35.0
func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32
func (*ReconnectParams) ProtoMessage ¶ added in v1.35.0
func (*ReconnectParams) ProtoMessage()
func (*ReconnectParams) ProtoReflect ¶ added in v1.35.0
func (x *ReconnectParams) ProtoReflect() protoreflect.Message
func (*ReconnectParams) Reset ¶ added in v1.35.0
func (x *ReconnectParams) Reset()
func (*ReconnectParams) String ¶ added in v1.35.0
func (x *ReconnectParams) String() string
type ReconnectServiceClient ¶ added in v1.35.0
type ReconnectServiceClient interface { Start(ctx context.Context, in *ReconnectParams, opts ...grpc.CallOption) (*Empty, error) Stop(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconnectInfo, error) }
ReconnectServiceClient is the client API for ReconnectService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A service used to control reconnect server.
func NewReconnectServiceClient ¶ added in v1.35.0
func NewReconnectServiceClient(cc grpc.ClientConnInterface) ReconnectServiceClient
type ReconnectServiceServer ¶ added in v1.35.0
type ReconnectServiceServer interface { Start(context.Context, *ReconnectParams) (*Empty, error) Stop(context.Context, *Empty) (*ReconnectInfo, error) // contains filtered or unexported methods }
ReconnectServiceServer is the server API for ReconnectService service. All implementations must embed UnimplementedReconnectServiceServer for forward compatibility.
A service used to control reconnect server.
type ReportQpsScenarioServiceClient ¶ added in v1.35.0
type ReportQpsScenarioServiceClient interface { // Report results of a QPS test benchmark scenario. ReportScenario(ctx context.Context, in *ScenarioResult, opts ...grpc.CallOption) (*Void, error) }
ReportQpsScenarioServiceClient is the client API for ReportQpsScenarioService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewReportQpsScenarioServiceClient ¶ added in v1.35.0
func NewReportQpsScenarioServiceClient(cc grpc.ClientConnInterface) ReportQpsScenarioServiceClient
type ReportQpsScenarioServiceServer ¶ added in v1.35.0
type ReportQpsScenarioServiceServer interface { // Report results of a QPS test benchmark scenario. ReportScenario(context.Context, *ScenarioResult) (*Void, error) // contains filtered or unexported methods }
ReportQpsScenarioServiceServer is the server API for ReportQpsScenarioService service. All implementations must embed UnimplementedReportQpsScenarioServiceServer for forward compatibility.
type RequestResultCount ¶ added in v1.35.0
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
added in
v1.35.0
func (*RequestResultCount) Descriptor() ([]byte, []int)
Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.
func (*RequestResultCount) GetCount ¶ added in v1.35.0
func (x *RequestResultCount) GetCount() int64
func (*RequestResultCount) GetStatusCode ¶ added in v1.35.0
func (x *RequestResultCount) GetStatusCode() int32
func (*RequestResultCount) ProtoMessage ¶ added in v1.35.0
func (*RequestResultCount) ProtoMessage()
func (*RequestResultCount) ProtoReflect ¶ added in v1.35.0
func (x *RequestResultCount) ProtoReflect() protoreflect.Message
func (*RequestResultCount) Reset ¶ added in v1.35.0
func (x *RequestResultCount) Reset()
func (*RequestResultCount) String ¶ added in v1.35.0
func (x *RequestResultCount) String() string
type ResponseParameters ¶
type ResponseParameters struct { // Desired payload sizes in responses from the server. Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` // Desired interval between consecutive responses in the response stream in // microseconds. IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"` // Whether to request the server to compress the response. This field is // "nullable" in order to interoperate seamlessly with clients not able to // implement the full compression tests by introspecting the call to verify // the response's compression status. Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,omitempty"` // contains filtered or unexported fields }
Configuration for a particular response.
func (*ResponseParameters) Descriptor
deprecated
func (*ResponseParameters) Descriptor() ([]byte, []int)
Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.
func (*ResponseParameters) GetCompressed ¶ added in v1.35.0
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 ¶ added in v1.33.2
func (x *ResponseParameters) ProtoReflect() protoreflect.Message
func (*ResponseParameters) Reset ¶
func (x *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (x *ResponseParameters) String() string
type RpcType ¶ added in v1.35.0
type RpcType int32
func (RpcType) Descriptor ¶ added in v1.35.0
func (RpcType) Descriptor() protoreflect.EnumDescriptor
func (RpcType) EnumDescriptor
deprecated
added in
v1.35.0
func (RpcType) Number ¶ added in v1.35.0
func (x RpcType) Number() protoreflect.EnumNumber
func (RpcType) Type ¶ added in v1.35.0
func (RpcType) Type() protoreflect.EnumType
type Scenario ¶ added in v1.35.0
type Scenario struct { // Human readable name for this scenario Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Client configuration ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"` // Number of clients to start for the test NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` // Server configuration ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"` // Number of servers to start for the test NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"` // Warmup period, in seconds WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"` // Benchmark time, in seconds BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"` // Number of workers to spawn locally (usually zero) SpawnLocalWorkerCount int32 `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
A single performance scenario: input to qps_json_driver
func (*Scenario) Descriptor
deprecated
added in
v1.35.0
func (*Scenario) GetBenchmarkSeconds ¶ added in v1.35.0
func (*Scenario) GetClientConfig ¶ added in v1.35.0
func (x *Scenario) GetClientConfig() *ClientConfig
func (*Scenario) GetNumClients ¶ added in v1.35.0
func (*Scenario) GetNumServers ¶ added in v1.35.0
func (*Scenario) GetServerConfig ¶ added in v1.35.0
func (x *Scenario) GetServerConfig() *ServerConfig
func (*Scenario) GetSpawnLocalWorkerCount ¶ added in v1.35.0
func (*Scenario) GetWarmupSeconds ¶ added in v1.35.0
func (*Scenario) ProtoMessage ¶ added in v1.35.0
func (*Scenario) ProtoMessage()
func (*Scenario) ProtoReflect ¶ added in v1.35.0
func (x *Scenario) ProtoReflect() protoreflect.Message
type ScenarioResult ¶ added in v1.35.0
type ScenarioResult struct { // Inputs used to run the scenario. Scenario *Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"` // Histograms from all clients merged into one histogram. Latencies *HistogramData `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"` // Client stats for each client ClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"` // Server stats for each server ServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"` // Number of cores available to each server ServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"` // An after-the-fact computed summary Summary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"` // Information on success or failure of each worker 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"` // Number of failed requests (one row per status code seen) RequestResults []*RequestResultCount `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"` // contains filtered or unexported fields }
Results of a single benchmark scenario.
func (*ScenarioResult) Descriptor
deprecated
added in
v1.35.0
func (*ScenarioResult) Descriptor() ([]byte, []int)
Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.
func (*ScenarioResult) GetClientStats ¶ added in v1.35.0
func (x *ScenarioResult) GetClientStats() []*ClientStats
func (*ScenarioResult) GetClientSuccess ¶ added in v1.35.0
func (x *ScenarioResult) GetClientSuccess() []bool
func (*ScenarioResult) GetLatencies ¶ added in v1.35.0
func (x *ScenarioResult) GetLatencies() *HistogramData
func (*ScenarioResult) GetRequestResults ¶ added in v1.35.0
func (x *ScenarioResult) GetRequestResults() []*RequestResultCount
func (*ScenarioResult) GetScenario ¶ added in v1.35.0
func (x *ScenarioResult) GetScenario() *Scenario
func (*ScenarioResult) GetServerCores ¶ added in v1.35.0
func (x *ScenarioResult) GetServerCores() []int32
func (*ScenarioResult) GetServerStats ¶ added in v1.35.0
func (x *ScenarioResult) GetServerStats() []*ServerStats
func (*ScenarioResult) GetServerSuccess ¶ added in v1.35.0
func (x *ScenarioResult) GetServerSuccess() []bool
func (*ScenarioResult) GetSummary ¶ added in v1.35.0
func (x *ScenarioResult) GetSummary() *ScenarioResultSummary
func (*ScenarioResult) ProtoMessage ¶ added in v1.35.0
func (*ScenarioResult) ProtoMessage()
func (*ScenarioResult) ProtoReflect ¶ added in v1.35.0
func (x *ScenarioResult) ProtoReflect() protoreflect.Message
func (*ScenarioResult) Reset ¶ added in v1.35.0
func (x *ScenarioResult) Reset()
func (*ScenarioResult) String ¶ added in v1.35.0
func (x *ScenarioResult) String() string
type ScenarioResultSummary ¶ added in v1.35.0
type ScenarioResultSummary struct { // Total number of operations per second over all clients. What is counted as 1 'operation' depends on the benchmark scenarios: // For unary benchmarks, an operation is processing of a single unary RPC. // For streaming benchmarks, an operation is processing of a single ping pong of request and response. Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"` // QPS per server core. QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"` // The total server cpu load based on system time across all server processes, expressed as percentage of a single cpu core. // For example, 85 implies 85% of a cpu core, 125 implies 125% of a cpu core. Since we are accumulating the cpu load across all the server // processes, the value could > 100 when there are multiple servers or a single server using multiple threads and cores. // Same explanation for the total client cpu load below. ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"` // The total server cpu load based on user time across all server processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%) ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"` // The total client cpu load based on system time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%) ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"` // The total client cpu load based on user time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%) ClientUserTime float64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"` // X% latency percentiles (in nanoseconds) 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"` // server cpu usage percentage ServerCpuUsage float64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"` // Number of requests that succeeded/failed SuccessfulRequestsPerSecond float64 `` /* 149-byte string literal not displayed */ FailedRequestsPerSecond float64 `` /* 137-byte string literal not displayed */ // Number of polls called inside completion queue per request ClientPollsPerRequest float64 `` /* 131-byte string literal not displayed */ ServerPollsPerRequest float64 `` /* 131-byte string literal not displayed */ // Queries per CPU-sec over all servers or clients ServerQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */ ClientQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */ // Start and end time for the test scenario 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 }
Basic summary that can be computed from ClientStats and ServerStats once the scenario has finished.
func (*ScenarioResultSummary) Descriptor
deprecated
added in
v1.35.0
func (*ScenarioResultSummary) Descriptor() ([]byte, []int)
Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.
func (*ScenarioResultSummary) GetClientPollsPerRequest ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64
func (*ScenarioResultSummary) GetClientQueriesPerCpuSec ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetClientSystemTime ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetClientSystemTime() float64
func (*ScenarioResultSummary) GetClientUserTime ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetClientUserTime() float64
func (*ScenarioResultSummary) GetEndTime ¶ added in v1.48.0
func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp
func (*ScenarioResultSummary) GetFailedRequestsPerSecond ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64
func (*ScenarioResultSummary) GetLatency_50 ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetLatency_50() float64
func (*ScenarioResultSummary) GetLatency_90 ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetLatency_90() float64
func (*ScenarioResultSummary) GetLatency_95 ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetLatency_95() float64
func (*ScenarioResultSummary) GetLatency_99 ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetLatency_99() float64
func (*ScenarioResultSummary) GetLatency_999 ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetLatency_999() float64
func (*ScenarioResultSummary) GetQps ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetQps() float64
func (*ScenarioResultSummary) GetQpsPerServerCore ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetQpsPerServerCore() float64
func (*ScenarioResultSummary) GetServerCpuUsage ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetServerCpuUsage() float64
func (*ScenarioResultSummary) GetServerPollsPerRequest ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64
func (*ScenarioResultSummary) GetServerQueriesPerCpuSec ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetServerSystemTime ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetServerSystemTime() float64
func (*ScenarioResultSummary) GetServerUserTime ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetServerUserTime() float64
func (*ScenarioResultSummary) GetStartTime ¶ added in v1.48.0
func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp
func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond ¶ added in v1.35.0
func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64
func (*ScenarioResultSummary) ProtoMessage ¶ added in v1.35.0
func (*ScenarioResultSummary) ProtoMessage()
func (*ScenarioResultSummary) ProtoReflect ¶ added in v1.35.0
func (x *ScenarioResultSummary) ProtoReflect() protoreflect.Message
func (*ScenarioResultSummary) Reset ¶ added in v1.35.0
func (x *ScenarioResultSummary) Reset()
func (*ScenarioResultSummary) String ¶ added in v1.35.0
func (x *ScenarioResultSummary) String() string
type Scenarios ¶ added in v1.35.0
type Scenarios struct { Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"` // contains filtered or unexported fields }
A set of scenarios to be run with qps_json_driver
func (*Scenarios) Descriptor
deprecated
added in
v1.35.0
func (*Scenarios) GetScenarios ¶ added in v1.35.0
func (*Scenarios) ProtoMessage ¶ added in v1.35.0
func (*Scenarios) ProtoMessage()
func (*Scenarios) ProtoReflect ¶ added in v1.35.0
func (x *Scenarios) ProtoReflect() protoreflect.Message
type SecurityParams ¶ added in v1.35.0
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 }
presence of SecurityParams implies use of TLS
func (*SecurityParams) Descriptor
deprecated
added in
v1.35.0
func (*SecurityParams) Descriptor() ([]byte, []int)
Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.
func (*SecurityParams) GetCredType ¶ added in v1.35.0
func (x *SecurityParams) GetCredType() string
func (*SecurityParams) GetServerHostOverride ¶ added in v1.35.0
func (x *SecurityParams) GetServerHostOverride() string
func (*SecurityParams) GetUseTestCa ¶ added in v1.35.0
func (x *SecurityParams) GetUseTestCa() bool
func (*SecurityParams) ProtoMessage ¶ added in v1.35.0
func (*SecurityParams) ProtoMessage()
func (*SecurityParams) ProtoReflect ¶ added in v1.35.0
func (x *SecurityParams) ProtoReflect() protoreflect.Message
func (*SecurityParams) Reset ¶ added in v1.35.0
func (x *SecurityParams) Reset()
func (*SecurityParams) String ¶ added in v1.35.0
func (x *SecurityParams) String() string
type ServerArgs ¶ added in v1.35.0
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
added in
v1.35.0
func (*ServerArgs) Descriptor() ([]byte, []int)
Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.
func (*ServerArgs) GetArgtype ¶ added in v1.35.0
func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
func (*ServerArgs) GetMark ¶ added in v1.35.0
func (x *ServerArgs) GetMark() *Mark
func (*ServerArgs) GetSetup ¶ added in v1.35.0
func (x *ServerArgs) GetSetup() *ServerConfig
func (*ServerArgs) ProtoMessage ¶ added in v1.35.0
func (*ServerArgs) ProtoMessage()
func (*ServerArgs) ProtoReflect ¶ added in v1.35.0
func (x *ServerArgs) ProtoReflect() protoreflect.Message
func (*ServerArgs) Reset ¶ added in v1.35.0
func (x *ServerArgs) Reset()
func (*ServerArgs) String ¶ added in v1.35.0
func (x *ServerArgs) String() string
type ServerArgs_Mark ¶ added in v1.35.0
type ServerArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ServerArgs_Setup ¶ added in v1.35.0
type ServerArgs_Setup struct {
Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ServerConfig ¶ added in v1.35.0
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 on which to listen. Zero means pick unused port. Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` // Only for async server. Number of threads used to serve the requests. AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"` // Specify the number of cores to limit server to, if desired CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"` // payload config, used in generic server. // Note this must NOT be used in proto (non-generic) servers. For proto servers, // 'response sizes' must be configured from the 'response_size' field of the // 'SimpleRequest' objects in RPC requests. PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"` // Specify the cores we should run the server on, if desired CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"` // If we use an OTHER_SERVER client_type, this string gives more detail OtherServerApi string `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"` // Number of threads that share each completion queue ThreadsPerCq int32 `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"` // Buffer pool size (no buffer pool specified if unset) 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"` // Number of server processes. 0 indicates no restriction. 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
added in
v1.35.0
func (*ServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.
func (*ServerConfig) GetAsyncServerThreads ¶ added in v1.35.0
func (x *ServerConfig) GetAsyncServerThreads() int32
func (*ServerConfig) GetChannelArgs ¶ added in v1.35.0
func (x *ServerConfig) GetChannelArgs() []*ChannelArg
func (*ServerConfig) GetCoreLimit ¶ added in v1.35.0
func (x *ServerConfig) GetCoreLimit() int32
func (*ServerConfig) GetCoreList ¶ added in v1.35.0
func (x *ServerConfig) GetCoreList() []int32
func (*ServerConfig) GetOtherServerApi ¶ added in v1.35.0
func (x *ServerConfig) GetOtherServerApi() string
func (*ServerConfig) GetPayloadConfig ¶ added in v1.35.0
func (x *ServerConfig) GetPayloadConfig() *PayloadConfig
func (*ServerConfig) GetPort ¶ added in v1.35.0
func (x *ServerConfig) GetPort() int32
func (*ServerConfig) GetResourceQuotaSize ¶ added in v1.35.0
func (x *ServerConfig) GetResourceQuotaSize() int32
func (*ServerConfig) GetSecurityParams ¶ added in v1.35.0
func (x *ServerConfig) GetSecurityParams() *SecurityParams
func (*ServerConfig) GetServerProcesses ¶ added in v1.35.0
func (x *ServerConfig) GetServerProcesses() int32
func (*ServerConfig) GetServerType ¶ added in v1.35.0
func (x *ServerConfig) GetServerType() ServerType
func (*ServerConfig) GetThreadsPerCq ¶ added in v1.35.0
func (x *ServerConfig) GetThreadsPerCq() int32
func (*ServerConfig) ProtoMessage ¶ added in v1.35.0
func (*ServerConfig) ProtoMessage()
func (*ServerConfig) ProtoReflect ¶ added in v1.35.0
func (x *ServerConfig) ProtoReflect() protoreflect.Message
func (*ServerConfig) Reset ¶ added in v1.35.0
func (x *ServerConfig) Reset()
func (*ServerConfig) String ¶ added in v1.35.0
func (x *ServerConfig) String() string
type ServerStats ¶ added in v1.35.0
type ServerStats struct { // wall clock time change in seconds since last reset TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"` // change in user time (in seconds) used by the server since last reset TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"` // change in server time (in seconds) used by the server process and all // threads since last reset TimeSystem float64 `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"` // change in total cpu time of the server (data from proc/stat) TotalCpuTime uint64 `protobuf:"varint,4,opt,name=total_cpu_time,json=totalCpuTime,proto3" json:"total_cpu_time,omitempty"` // change in idle time of the server (data from proc/stat) IdleCpuTime uint64 `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"` // Number of polls called inside completion queue CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"` // Core library stats 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
added in
v1.35.0
func (*ServerStats) Descriptor() ([]byte, []int)
Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.
func (*ServerStats) GetCoreStats ¶ added in v1.35.0
func (x *ServerStats) GetCoreStats() *core.Stats
func (*ServerStats) GetCqPollCount ¶ added in v1.35.0
func (x *ServerStats) GetCqPollCount() uint64
func (*ServerStats) GetIdleCpuTime ¶ added in v1.35.0
func (x *ServerStats) GetIdleCpuTime() uint64
func (*ServerStats) GetTimeElapsed ¶ added in v1.35.0
func (x *ServerStats) GetTimeElapsed() float64
func (*ServerStats) GetTimeSystem ¶ added in v1.35.0
func (x *ServerStats) GetTimeSystem() float64
func (*ServerStats) GetTimeUser ¶ added in v1.35.0
func (x *ServerStats) GetTimeUser() float64
func (*ServerStats) GetTotalCpuTime ¶ added in v1.35.0
func (x *ServerStats) GetTotalCpuTime() uint64
func (*ServerStats) ProtoMessage ¶ added in v1.35.0
func (*ServerStats) ProtoMessage()
func (*ServerStats) ProtoReflect ¶ added in v1.35.0
func (x *ServerStats) ProtoReflect() protoreflect.Message
func (*ServerStats) Reset ¶ added in v1.35.0
func (x *ServerStats) Reset()
func (*ServerStats) String ¶ added in v1.35.0
func (x *ServerStats) String() string
type ServerStatus ¶ added in v1.35.0
type ServerStatus struct { Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // the port bound by the server Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Number of cores available to the server Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*ServerStatus) Descriptor
deprecated
added in
v1.35.0
func (*ServerStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.
func (*ServerStatus) GetCores ¶ added in v1.35.0
func (x *ServerStatus) GetCores() int32
func (*ServerStatus) GetPort ¶ added in v1.35.0
func (x *ServerStatus) GetPort() int32
func (*ServerStatus) GetStats ¶ added in v1.35.0
func (x *ServerStatus) GetStats() *ServerStats
func (*ServerStatus) ProtoMessage ¶ added in v1.35.0
func (*ServerStatus) ProtoMessage()
func (*ServerStatus) ProtoReflect ¶ added in v1.35.0
func (x *ServerStatus) ProtoReflect() protoreflect.Message
func (*ServerStatus) Reset ¶ added in v1.35.0
func (x *ServerStatus) Reset()
func (*ServerStatus) String ¶ added in v1.35.0
func (x *ServerStatus) String() string
type ServerType ¶ added in v1.35.0
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 // used for some language-specific variants ServerType_CALLBACK_SERVER ServerType = 4 )
func (ServerType) Descriptor ¶ added in v1.35.0
func (ServerType) Descriptor() protoreflect.EnumDescriptor
func (ServerType) Enum ¶ added in v1.35.0
func (x ServerType) Enum() *ServerType
func (ServerType) EnumDescriptor
deprecated
added in
v1.35.0
func (ServerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServerType.Descriptor instead.
func (ServerType) Number ¶ added in v1.35.0
func (x ServerType) Number() protoreflect.EnumNumber
func (ServerType) String ¶ added in v1.35.0
func (x ServerType) String() string
func (ServerType) Type ¶ added in v1.35.0
func (ServerType) Type() protoreflect.EnumType
type SetReturnStatusRequest ¶ added in v1.59.0
type SetReturnStatusRequest struct { GrpcCodeToReturn int32 `protobuf:"varint,1,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"` GrpcStatusDescription string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
Status that will be return to callers of the Hook method
func (*SetReturnStatusRequest) Descriptor
deprecated
added in
v1.59.0
func (*SetReturnStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetReturnStatusRequest.ProtoReflect.Descriptor instead.
func (*SetReturnStatusRequest) GetGrpcCodeToReturn ¶ added in v1.59.0
func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32
func (*SetReturnStatusRequest) GetGrpcStatusDescription ¶ added in v1.59.0
func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string
func (*SetReturnStatusRequest) ProtoMessage ¶ added in v1.59.0
func (*SetReturnStatusRequest) ProtoMessage()
func (*SetReturnStatusRequest) ProtoReflect ¶ added in v1.59.0
func (x *SetReturnStatusRequest) ProtoReflect() protoreflect.Message
func (*SetReturnStatusRequest) Reset ¶ added in v1.59.0
func (x *SetReturnStatusRequest) Reset()
func (*SetReturnStatusRequest) String ¶ added in v1.59.0
func (x *SetReturnStatusRequest) String() string
type SimpleProtoParams ¶ added in v1.35.0
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
added in
v1.35.0
func (*SimpleProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.
func (*SimpleProtoParams) GetReqSize ¶ added in v1.35.0
func (x *SimpleProtoParams) GetReqSize() int32
func (*SimpleProtoParams) GetRespSize ¶ added in v1.35.0
func (x *SimpleProtoParams) GetRespSize() int32
func (*SimpleProtoParams) ProtoMessage ¶ added in v1.35.0
func (*SimpleProtoParams) ProtoMessage()
func (*SimpleProtoParams) ProtoReflect ¶ added in v1.35.0
func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message
func (*SimpleProtoParams) Reset ¶ added in v1.35.0
func (x *SimpleProtoParams) Reset()
func (*SimpleProtoParams) String ¶ added in v1.35.0
func (x *SimpleProtoParams) String() string
type SimpleRequest ¶
type SimpleRequest struct { // Desired payload type in the response from the server. // If response_type is RANDOM, server randomly chooses one from other formats. ResponseType PayloadType `` /* 128-byte string literal not displayed */ // Desired payload size in the response from the server. ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"` // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // Whether SimpleResponse should include username. FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"` // Whether SimpleResponse should include OAuth scope. FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"` // Whether to request the server to compress the response. This field is // "nullable" in order to interoperate seamlessly with clients not able to // implement the full compression tests by introspecting the call to verify // the response's compression status. ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"` // Whether server should return a given status ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` // Whether the server should expect this request to be compressed. ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"` // Whether SimpleResponse should include server_id. FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"` // Whether SimpleResponse should include grpclb_route_type. FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"` // If set the server should record this metrics report data for the current RPC. OrcaPerQueryReport *TestOrcaReport `protobuf:"bytes,11,opt,name=orca_per_query_report,json=orcaPerQueryReport,proto3" json:"orca_per_query_report,omitempty"` // contains filtered or unexported fields }
Unary request.
func (*SimpleRequest) Descriptor
deprecated
func (*SimpleRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.
func (*SimpleRequest) GetExpectCompressed ¶ added in v1.35.0
func (x *SimpleRequest) GetExpectCompressed() *BoolValue
func (*SimpleRequest) GetFillGrpclbRouteType ¶ added in v1.26.0
func (x *SimpleRequest) GetFillGrpclbRouteType() bool
func (*SimpleRequest) GetFillOauthScope ¶
func (x *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillServerId ¶ added in v1.21.0
func (x *SimpleRequest) GetFillServerId() bool
func (*SimpleRequest) GetFillUsername ¶
func (x *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetOrcaPerQueryReport ¶ added in v1.48.0
func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport
func (*SimpleRequest) GetPayload ¶
func (x *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompressed ¶ added in v1.35.0
func (x *SimpleRequest) GetResponseCompressed() *BoolValue
func (*SimpleRequest) GetResponseSize ¶
func (x *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶ added in v1.0.3
func (x *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (x *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) ProtoReflect ¶ added in v1.33.2
func (x *SimpleRequest) ProtoReflect() protoreflect.Message
func (*SimpleRequest) Reset ¶
func (x *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (x *SimpleRequest) String() string
type SimpleResponse ¶
type SimpleResponse struct { // Payload to increase message size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // The user the request came from, for verifying authentication was // successful when the client expected it. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` // OAuth scope. OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"` // Server ID. This must be unique among different server instances, // but the same across all RPC's made to a particular server instance. ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` // gRPCLB Path. GrpclbRouteType GrpclbRouteType `` /* 143-byte string literal not displayed */ // Server hostname. Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"` // contains filtered or unexported fields }
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor
deprecated
func (*SimpleResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.
func (*SimpleResponse) GetGrpclbRouteType ¶ added in v1.26.0
func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
func (*SimpleResponse) GetHostname ¶ added in v1.28.0
func (x *SimpleResponse) GetHostname() string
func (*SimpleResponse) GetOauthScope ¶
func (x *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (x *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetServerId ¶ added in v1.21.0
func (x *SimpleResponse) GetServerId() string
func (*SimpleResponse) GetUsername ¶
func (x *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) ProtoReflect ¶ added in v1.33.2
func (x *SimpleResponse) ProtoReflect() protoreflect.Message
func (*SimpleResponse) Reset ¶
func (x *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (x *SimpleResponse) String() string
type StreamingInputCallRequest ¶
type StreamingInputCallRequest struct { // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // Whether the server should expect this request to be compressed. This field // is "nullable" in order to interoperate seamlessly with servers not able to // implement the full compression tests by introspecting the call to verify // the request's compression status. ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"` // contains filtered or unexported fields }
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor
deprecated
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingInputCallRequest) GetExpectCompressed ¶ added in v1.35.0
func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
func (*StreamingInputCallRequest) GetPayload ¶
func (x *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) ProtoReflect ¶ added in v1.33.2
func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingInputCallRequest) Reset ¶
func (x *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (x *StreamingInputCallRequest) String() string
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct { // Aggregated size of payloads received from the client. AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor
deprecated
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingInputCallResponse) GetAggregatedPayloadSize ¶
func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage ¶
func (*StreamingInputCallResponse) ProtoMessage()
func (*StreamingInputCallResponse) ProtoReflect ¶ added in v1.33.2
func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingInputCallResponse) Reset ¶
func (x *StreamingInputCallResponse) Reset()
func (*StreamingInputCallResponse) String ¶
func (x *StreamingInputCallResponse) String() string
type StreamingOutputCallRequest ¶
type StreamingOutputCallRequest struct { // Desired payload type in the response from the server. // If response_type is RANDOM, the payload from each response in the stream // might be of different types. This is to simulate a mixed type of payload // stream. ResponseType PayloadType `` /* 128-byte string literal not displayed */ // Configuration for each expected response message. ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"` // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // Whether server should return a given status ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` // If set the server should update this metrics report data at the OOB server. OrcaOobReport *TestOrcaReport `protobuf:"bytes,8,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"` // contains filtered or unexported fields }
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor
deprecated
func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallRequest) GetOrcaOobReport ¶ added in v1.48.0
func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport
func (*StreamingOutputCallRequest) GetPayload ¶
func (x *StreamingOutputCallRequest) GetPayload() *Payload
func (*StreamingOutputCallRequest) GetResponseParameters ¶
func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶ added in v1.0.3
func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) ProtoReflect ¶ added in v1.33.2
func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallRequest) Reset ¶
func (x *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (x *StreamingOutputCallRequest) String() string
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct { // Payload to increase response size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor
deprecated
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallResponse) GetPayload ¶
func (x *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage ¶
func (*StreamingOutputCallResponse) ProtoMessage()
func (*StreamingOutputCallResponse) ProtoReflect ¶ added in v1.33.2
func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallResponse) Reset ¶
func (x *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (x *StreamingOutputCallResponse) String() string
type TestOrcaReport ¶ added in v1.48.0
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 }
Metrics data the server will update and send to the client. It mirrors orca load report https://github.com/cncf/xds/blob/eded343319d09f30032952beda9840bbd3dcf7ac/xds/data/orca/v3/orca_load_report.proto#L15, but avoids orca dependency. Used by both per-query and out-of-band reporting tests.
func (*TestOrcaReport) Descriptor
deprecated
added in
v1.48.0
func (*TestOrcaReport) Descriptor() ([]byte, []int)
Deprecated: Use TestOrcaReport.ProtoReflect.Descriptor instead.
func (*TestOrcaReport) GetCpuUtilization ¶ added in v1.48.0
func (x *TestOrcaReport) GetCpuUtilization() float64
func (*TestOrcaReport) GetMemoryUtilization ¶ added in v1.48.0
func (x *TestOrcaReport) GetMemoryUtilization() float64
func (*TestOrcaReport) GetRequestCost ¶ added in v1.48.0
func (x *TestOrcaReport) GetRequestCost() map[string]float64
func (*TestOrcaReport) GetUtilization ¶ added in v1.48.0
func (x *TestOrcaReport) GetUtilization() map[string]float64
func (*TestOrcaReport) ProtoMessage ¶ added in v1.48.0
func (*TestOrcaReport) ProtoMessage()
func (*TestOrcaReport) ProtoReflect ¶ added in v1.48.0
func (x *TestOrcaReport) ProtoReflect() protoreflect.Message
func (*TestOrcaReport) Reset ¶ added in v1.48.0
func (x *TestOrcaReport) Reset()
func (*TestOrcaReport) String ¶ added in v1.48.0
func (x *TestOrcaReport) String() string
type TestServiceClient ¶
type TestServiceClient interface { // One empty request followed by one empty response. EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) // One request followed by one response. UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) // One request followed by one response. Response has cache control // headers set such that a caching HTTP proxy (such as GFE) can // satisfy subsequent requests. CacheableUnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamingOutputCallResponse], error) // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StreamingInputCallRequest, StreamingInputCallResponse], error) // A sequence of requests with each request served by the server immediately. // As one request could lead to multiple responses, this interface // demonstrates the idea of full duplexing. FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse], error) // A sequence of requests followed by a sequence of responses. // The server buffers all the client requests and then serves them in order. A // stream of responses are returned to the client when the server starts with // first request. HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse], error) // The test server will not implement this method. It will be used // to test the behavior when clients call unimplemented methods. UnimplementedCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) }
TestServiceClient is the client API for TestService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A simple service to test the various types of RPCs and experiment with performance with various types of payload.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { // One empty request followed by one empty response. EmptyCall(context.Context, *Empty) (*Empty, error) // One request followed by one response. UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) // One request followed by one response. Response has cache control // headers set such that a caching HTTP proxy (such as GFE) can // satisfy subsequent requests. CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(*StreamingOutputCallRequest, grpc.ServerStreamingServer[StreamingOutputCallResponse]) error // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]) error // A sequence of requests with each request served by the server immediately. // As one request could lead to multiple responses, this interface // demonstrates the idea of full duplexing. FullDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error // A sequence of requests followed by a sequence of responses. // The server buffers all the client requests and then serves them in order. A // stream of responses are returned to the client when the server starts with // first request. HalfDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error // The test server will not implement this method. It will be used // to test the behavior when clients call unimplemented methods. UnimplementedCall(context.Context, *Empty) (*Empty, error) // contains filtered or unexported methods }
TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility.
A simple service to test the various types of RPCs and experiment with performance with various types of payload.
type TestService_FullDuplexCallClient ¶
type TestService_FullDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_FullDuplexCallServer ¶
type TestService_FullDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_HalfDuplexCallClient ¶
type TestService_HalfDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_HalfDuplexCallServer ¶
type TestService_HalfDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingInputCallClient ¶
type TestService_StreamingInputCallClient = grpc.ClientStreamingClient[StreamingInputCallRequest, StreamingInputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingInputCallServer ¶
type TestService_StreamingInputCallServer = grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingOutputCallClient ¶
type TestService_StreamingOutputCallClient = grpc.ServerStreamingClient[StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingOutputCallServer ¶
type TestService_StreamingOutputCallServer = grpc.ServerStreamingServer[StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedBenchmarkServiceServer ¶ added in v1.35.0
type UnimplementedBenchmarkServiceServer struct{}
UnimplementedBenchmarkServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedBenchmarkServiceServer) StreamingBothWays ¶ added in v1.35.0
func (UnimplementedBenchmarkServiceServer) StreamingBothWays(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error
func (UnimplementedBenchmarkServiceServer) StreamingCall ¶ added in v1.35.0
func (UnimplementedBenchmarkServiceServer) StreamingCall(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error
func (UnimplementedBenchmarkServiceServer) StreamingFromClient ¶ added in v1.35.0
func (UnimplementedBenchmarkServiceServer) StreamingFromClient(grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]) error
func (UnimplementedBenchmarkServiceServer) StreamingFromServer ¶ added in v1.35.0
func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*SimpleRequest, grpc.ServerStreamingServer[SimpleResponse]) error
func (UnimplementedBenchmarkServiceServer) UnaryCall ¶ added in v1.35.0
func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
type UnimplementedHookServiceServer ¶ added in v1.58.0
type UnimplementedHookServiceServer struct{}
UnimplementedHookServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedHookServiceServer) ClearReturnStatus ¶ added in v1.59.0
func (UnimplementedHookServiceServer) SetReturnStatus ¶ added in v1.59.0
func (UnimplementedHookServiceServer) SetReturnStatus(context.Context, *SetReturnStatusRequest) (*Empty, error)
type UnimplementedLoadBalancerStatsServiceServer ¶ added in v1.28.0
type UnimplementedLoadBalancerStatsServiceServer struct{}
UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats ¶ added in v1.35.0
func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error)
func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats ¶ added in v1.28.0
func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)
type UnimplementedReconnectServiceServer ¶ added in v1.35.0
type UnimplementedReconnectServiceServer struct{}
UnimplementedReconnectServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedReconnectServiceServer) Start ¶ added in v1.35.0
func (UnimplementedReconnectServiceServer) Start(context.Context, *ReconnectParams) (*Empty, error)
func (UnimplementedReconnectServiceServer) Stop ¶ added in v1.35.0
func (UnimplementedReconnectServiceServer) Stop(context.Context, *Empty) (*ReconnectInfo, error)
type UnimplementedReportQpsScenarioServiceServer ¶ added in v1.35.0
type UnimplementedReportQpsScenarioServiceServer struct{}
UnimplementedReportQpsScenarioServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedReportQpsScenarioServiceServer) ReportScenario ¶ added in v1.35.0
func (UnimplementedReportQpsScenarioServiceServer) ReportScenario(context.Context, *ScenarioResult) (*Void, error)
type UnimplementedServiceClient ¶ added in v1.0.5
type UnimplementedServiceClient interface { // A call that no server should implement UnimplementedCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) }
UnimplementedServiceClient is the client API for UnimplementedService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A simple service NOT implemented at servers so clients can test for that case.
func NewUnimplementedServiceClient ¶ added in v1.0.5
func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient
type UnimplementedServiceServer ¶ added in v1.0.5
type UnimplementedServiceServer interface { // A call that no server should implement UnimplementedCall(context.Context, *Empty) (*Empty, error) // contains filtered or unexported methods }
UnimplementedServiceServer is the server API for UnimplementedService service. All implementations must embed UnimplementedUnimplementedServiceServer for forward compatibility.
A simple service NOT implemented at servers so clients can test for that case.
type UnimplementedTestServiceServer ¶ added in v1.24.0
type UnimplementedTestServiceServer struct{}
UnimplementedTestServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedTestServiceServer) CacheableUnaryCall ¶ added in v1.35.0
func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
func (UnimplementedTestServiceServer) FullDuplexCall ¶ added in v1.24.0
func (UnimplementedTestServiceServer) FullDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) HalfDuplexCall ¶ added in v1.24.0
func (UnimplementedTestServiceServer) HalfDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) StreamingInputCall ¶ added in v1.24.0
func (UnimplementedTestServiceServer) StreamingInputCall(grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]) error
func (UnimplementedTestServiceServer) StreamingOutputCall ¶ added in v1.24.0
func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, grpc.ServerStreamingServer[StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) UnaryCall ¶ added in v1.24.0
func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
func (UnimplementedTestServiceServer) UnimplementedCall ¶ added in v1.35.0
type UnimplementedUnimplementedServiceServer ¶ added in v1.24.0
type UnimplementedUnimplementedServiceServer struct{}
UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedUnimplementedServiceServer) UnimplementedCall ¶ added in v1.24.0
type UnimplementedWorkerServiceServer ¶ added in v1.35.0
type UnimplementedWorkerServiceServer struct{}
UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedWorkerServiceServer) CoreCount ¶ added in v1.35.0
func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
func (UnimplementedWorkerServiceServer) QuitWorker ¶ added in v1.35.0
func (UnimplementedWorkerServiceServer) RunClient ¶ added in v1.35.0
func (UnimplementedWorkerServiceServer) RunClient(grpc.BidiStreamingServer[ClientArgs, ClientStatus]) error
func (UnimplementedWorkerServiceServer) RunServer ¶ added in v1.35.0
func (UnimplementedWorkerServiceServer) RunServer(grpc.BidiStreamingServer[ServerArgs, ServerStatus]) error
type UnimplementedXdsUpdateClientConfigureServiceServer ¶ added in v1.35.0
type UnimplementedXdsUpdateClientConfigureServiceServer struct{}
UnimplementedXdsUpdateClientConfigureServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure ¶ added in v1.35.0
func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse, error)
type UnimplementedXdsUpdateHealthServiceServer ¶ added in v1.35.0
type UnimplementedXdsUpdateHealthServiceServer struct{}
UnimplementedXdsUpdateHealthServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest ¶ added in v1.58.0
func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *HookRequest) (*HookResponse, error)
func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing ¶ added in v1.35.0
func (UnimplementedXdsUpdateHealthServiceServer) SetServing ¶ added in v1.35.0
type UnsafeBenchmarkServiceServer ¶ added in v1.35.0
type UnsafeBenchmarkServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBenchmarkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BenchmarkServiceServer will result in compilation errors.
type UnsafeHookServiceServer ¶ added in v1.58.0
type UnsafeHookServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHookServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HookServiceServer will result in compilation errors.
type UnsafeLoadBalancerStatsServiceServer ¶ added in v1.33.0
type UnsafeLoadBalancerStatsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLoadBalancerStatsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LoadBalancerStatsServiceServer will result in compilation errors.
type UnsafeReconnectServiceServer ¶ added in v1.35.0
type UnsafeReconnectServiceServer interface {
// contains filtered or unexported methods
}
UnsafeReconnectServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReconnectServiceServer will result in compilation errors.
type UnsafeReportQpsScenarioServiceServer ¶ added in v1.35.0
type UnsafeReportQpsScenarioServiceServer interface {
// contains filtered or unexported methods
}
UnsafeReportQpsScenarioServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReportQpsScenarioServiceServer will result in compilation errors.
type UnsafeTestServiceServer ¶ added in v1.33.0
type UnsafeTestServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.
type UnsafeUnimplementedServiceServer ¶ added in v1.33.0
type UnsafeUnimplementedServiceServer interface {
// contains filtered or unexported methods
}
UnsafeUnimplementedServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UnimplementedServiceServer will result in compilation errors.
type UnsafeWorkerServiceServer ¶ added in v1.35.0
type UnsafeWorkerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.
type UnsafeXdsUpdateClientConfigureServiceServer ¶ added in v1.35.0
type UnsafeXdsUpdateClientConfigureServiceServer interface {
// contains filtered or unexported methods
}
UnsafeXdsUpdateClientConfigureServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to XdsUpdateClientConfigureServiceServer will result in compilation errors.
type UnsafeXdsUpdateHealthServiceServer ¶ added in v1.35.0
type UnsafeXdsUpdateHealthServiceServer interface {
// contains filtered or unexported methods
}
UnsafeXdsUpdateHealthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to XdsUpdateHealthServiceServer will result in compilation errors.
type Void ¶ added in v1.35.0
type Void struct {
// contains filtered or unexported fields
}
func (*Void) Descriptor
deprecated
added in
v1.35.0
func (*Void) ProtoMessage ¶ added in v1.35.0
func (*Void) ProtoMessage()
func (*Void) ProtoReflect ¶ added in v1.35.0
func (x *Void) ProtoReflect() protoreflect.Message
type WorkerServiceClient ¶ added in v1.35.0
type WorkerServiceClient interface { // Start server with specified workload. // First request sent specifies the ServerConfig followed by ServerStatus // response. After that, a "Mark" can be sent anytime to request the latest // stats. Closing the stream will initiate shutdown of the test server // and once the shutdown has finished, the OK status is sent to terminate // this RPC. RunServer(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ServerArgs, ServerStatus], error) // Start client with specified workload. // First request sent specifies the ClientConfig followed by ClientStatus // response. After that, a "Mark" can be sent anytime to request the latest // stats. Closing the stream will initiate shutdown of the test client // and once the shutdown has finished, the OK status is sent to terminate // this RPC. RunClient(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClientArgs, ClientStatus], error) // Just return the core count - unary call CoreCount(ctx context.Context, in *CoreRequest, opts ...grpc.CallOption) (*CoreResponse, error) // Quit this worker QuitWorker(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) }
WorkerServiceClient is the client API for WorkerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWorkerServiceClient ¶ added in v1.35.0
func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
type WorkerServiceServer ¶ added in v1.35.0
type WorkerServiceServer interface { // Start server with specified workload. // First request sent specifies the ServerConfig followed by ServerStatus // response. After that, a "Mark" can be sent anytime to request the latest // stats. Closing the stream will initiate shutdown of the test server // and once the shutdown has finished, the OK status is sent to terminate // this RPC. RunServer(grpc.BidiStreamingServer[ServerArgs, ServerStatus]) error // Start client with specified workload. // First request sent specifies the ClientConfig followed by ClientStatus // response. After that, a "Mark" can be sent anytime to request the latest // stats. Closing the stream will initiate shutdown of the test client // and once the shutdown has finished, the OK status is sent to terminate // this RPC. RunClient(grpc.BidiStreamingServer[ClientArgs, ClientStatus]) error // Just return the core count - unary call CoreCount(context.Context, *CoreRequest) (*CoreResponse, error) // Quit this worker QuitWorker(context.Context, *Void) (*Void, error) // contains filtered or unexported methods }
WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility.
type WorkerService_RunClientClient ¶ added in v1.35.0
type WorkerService_RunClientClient = grpc.BidiStreamingClient[ClientArgs, ClientStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type WorkerService_RunClientServer ¶ added in v1.35.0
type WorkerService_RunClientServer = grpc.BidiStreamingServer[ClientArgs, ClientStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type WorkerService_RunServerClient ¶ added in v1.35.0
type WorkerService_RunServerClient = grpc.BidiStreamingClient[ServerArgs, ServerStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type WorkerService_RunServerServer ¶ added in v1.35.0
type WorkerService_RunServerServer = grpc.BidiStreamingServer[ServerArgs, ServerStatus]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type XdsUpdateClientConfigureServiceClient ¶ added in v1.35.0
type XdsUpdateClientConfigureServiceClient interface { // Update the tes client's configuration. Configure(ctx context.Context, in *ClientConfigureRequest, opts ...grpc.CallOption) (*ClientConfigureResponse, error) }
XdsUpdateClientConfigureServiceClient is the client API for XdsUpdateClientConfigureService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A service to dynamically update the configuration of an xDS test client.
func NewXdsUpdateClientConfigureServiceClient ¶ added in v1.35.0
func NewXdsUpdateClientConfigureServiceClient(cc grpc.ClientConnInterface) XdsUpdateClientConfigureServiceClient
type XdsUpdateClientConfigureServiceServer ¶ added in v1.35.0
type XdsUpdateClientConfigureServiceServer interface { // Update the tes client's configuration. Configure(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse, error) // contains filtered or unexported methods }
XdsUpdateClientConfigureServiceServer is the server API for XdsUpdateClientConfigureService service. All implementations must embed UnimplementedXdsUpdateClientConfigureServiceServer for forward compatibility.
A service to dynamically update the configuration of an xDS test client.
type XdsUpdateHealthServiceClient ¶ added in v1.35.0
type XdsUpdateHealthServiceClient interface { SetServing(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) SetNotServing(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) SendHookRequest(ctx context.Context, in *HookRequest, opts ...grpc.CallOption) (*HookResponse, error) }
XdsUpdateHealthServiceClient is the client API for XdsUpdateHealthService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
A service to remotely control health status of an xDS test server.
func NewXdsUpdateHealthServiceClient ¶ added in v1.35.0
func NewXdsUpdateHealthServiceClient(cc grpc.ClientConnInterface) XdsUpdateHealthServiceClient
type XdsUpdateHealthServiceServer ¶ added in v1.35.0
type XdsUpdateHealthServiceServer interface { SetServing(context.Context, *Empty) (*Empty, error) SetNotServing(context.Context, *Empty) (*Empty, error) SendHookRequest(context.Context, *HookRequest) (*HookResponse, error) // contains filtered or unexported methods }
XdsUpdateHealthServiceServer is the server API for XdsUpdateHealthService service. All implementations must embed UnimplementedXdsUpdateHealthServiceServer for forward compatibility.
A service to remotely control health status of an xDS test server.