Documentation
¶
Index ¶
- Variables
- func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)
- func RegisterReportQpsScenarioServiceServer(s *grpc.Server, srv ReportQpsScenarioServiceServer)
- func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)
- 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
- func (*BoolValue) Descriptor() ([]byte, []int)
- func (m *BoolValue) GetValue() bool
- func (*BoolValue) ProtoMessage()
- func (m *BoolValue) Reset()
- func (m *BoolValue) String() string
- func (m *BoolValue) XXX_DiscardUnknown()
- func (m *BoolValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BoolValue) XXX_Merge(src proto.Message)
- func (m *BoolValue) XXX_Size() int
- func (m *BoolValue) XXX_Unmarshal(b []byte) error
- type ByteBufferParams
- func (*ByteBufferParams) Descriptor() ([]byte, []int)
- func (m *ByteBufferParams) GetReqSize() int32
- func (m *ByteBufferParams) GetRespSize() int32
- func (*ByteBufferParams) ProtoMessage()
- func (m *ByteBufferParams) Reset()
- func (m *ByteBufferParams) String() string
- func (m *ByteBufferParams) XXX_DiscardUnknown()
- func (m *ByteBufferParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ByteBufferParams) XXX_Merge(src proto.Message)
- func (m *ByteBufferParams) XXX_Size() int
- func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error
- type ChannelArg
- func (*ChannelArg) Descriptor() ([]byte, []int)
- func (m *ChannelArg) GetIntValue() int32
- func (m *ChannelArg) GetName() string
- func (m *ChannelArg) GetStrValue() string
- func (m *ChannelArg) GetValue() isChannelArg_Value
- func (*ChannelArg) ProtoMessage()
- func (m *ChannelArg) Reset()
- func (m *ChannelArg) String() string
- func (m *ChannelArg) XXX_DiscardUnknown()
- func (m *ChannelArg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelArg) XXX_Merge(src proto.Message)
- func (*ChannelArg) XXX_OneofWrappers() []interface{}
- func (m *ChannelArg) XXX_Size() int
- func (m *ChannelArg) XXX_Unmarshal(b []byte) error
- type ChannelArg_IntValue
- type ChannelArg_StrValue
- type ClientArgs
- func (*ClientArgs) Descriptor() ([]byte, []int)
- func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
- func (m *ClientArgs) GetMark() *Mark
- func (m *ClientArgs) GetSetup() *ClientConfig
- func (*ClientArgs) ProtoMessage()
- func (m *ClientArgs) Reset()
- func (m *ClientArgs) String() string
- func (m *ClientArgs) XXX_DiscardUnknown()
- func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientArgs) XXX_Merge(src proto.Message)
- func (*ClientArgs) XXX_OneofWrappers() []interface{}
- func (m *ClientArgs) XXX_Size() int
- func (m *ClientArgs) XXX_Unmarshal(b []byte) error
- type ClientArgs_Mark
- type ClientArgs_Setup
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)
- func (m *ClientConfig) GetAsyncClientThreads() int32
- func (m *ClientConfig) GetChannelArgs() []*ChannelArg
- func (m *ClientConfig) GetClientChannels() int32
- func (m *ClientConfig) GetClientType() ClientType
- func (m *ClientConfig) GetCoreLimit() int32
- func (m *ClientConfig) GetCoreList() []int32
- func (m *ClientConfig) GetHistogramParams() *HistogramParams
- func (m *ClientConfig) GetLoadParams() *LoadParams
- func (m *ClientConfig) GetMessagesPerStream() int32
- func (m *ClientConfig) GetOtherClientApi() string
- func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32
- func (m *ClientConfig) GetPayloadConfig() *PayloadConfig
- func (m *ClientConfig) GetRpcType() RpcType
- func (m *ClientConfig) GetSecurityParams() *SecurityParams
- func (m *ClientConfig) GetServerTargets() []string
- func (m *ClientConfig) GetThreadsPerCq() int32
- func (m *ClientConfig) GetUseCoalesceApi() bool
- func (*ClientConfig) ProtoMessage()
- func (m *ClientConfig) Reset()
- func (m *ClientConfig) String() string
- func (m *ClientConfig) XXX_DiscardUnknown()
- func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientConfig) XXX_Merge(src proto.Message)
- func (m *ClientConfig) XXX_Size() int
- func (m *ClientConfig) XXX_Unmarshal(b []byte) error
- type ClientStats
- func (*ClientStats) Descriptor() ([]byte, []int)
- func (m *ClientStats) GetCoreStats() *core.Stats
- func (m *ClientStats) GetCqPollCount() uint64
- func (m *ClientStats) GetLatencies() *HistogramData
- func (m *ClientStats) GetRequestResults() []*RequestResultCount
- func (m *ClientStats) GetTimeElapsed() float64
- func (m *ClientStats) GetTimeSystem() float64
- func (m *ClientStats) GetTimeUser() float64
- func (*ClientStats) ProtoMessage()
- func (m *ClientStats) Reset()
- func (m *ClientStats) String() string
- func (m *ClientStats) XXX_DiscardUnknown()
- func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientStats) XXX_Merge(src proto.Message)
- func (m *ClientStats) XXX_Size() int
- func (m *ClientStats) XXX_Unmarshal(b []byte) error
- type ClientStatus
- func (*ClientStatus) Descriptor() ([]byte, []int)
- func (m *ClientStatus) GetStats() *ClientStats
- func (*ClientStatus) ProtoMessage()
- func (m *ClientStatus) Reset()
- func (m *ClientStatus) String() string
- func (m *ClientStatus) XXX_DiscardUnknown()
- func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientStatus) XXX_Merge(src proto.Message)
- func (m *ClientStatus) XXX_Size() int
- func (m *ClientStatus) XXX_Unmarshal(b []byte) error
- type ClientType
- type ClosedLoopParams
- func (*ClosedLoopParams) Descriptor() ([]byte, []int)
- func (*ClosedLoopParams) ProtoMessage()
- func (m *ClosedLoopParams) Reset()
- func (m *ClosedLoopParams) String() string
- func (m *ClosedLoopParams) XXX_DiscardUnknown()
- func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClosedLoopParams) XXX_Merge(src proto.Message)
- func (m *ClosedLoopParams) XXX_Size() int
- func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error
- type ComplexProtoParams
- func (*ComplexProtoParams) Descriptor() ([]byte, []int)
- func (*ComplexProtoParams) ProtoMessage()
- func (m *ComplexProtoParams) Reset()
- func (m *ComplexProtoParams) String() string
- func (m *ComplexProtoParams) XXX_DiscardUnknown()
- func (m *ComplexProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ComplexProtoParams) XXX_Merge(src proto.Message)
- func (m *ComplexProtoParams) XXX_Size() int
- func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error
- type CoreRequest
- func (*CoreRequest) Descriptor() ([]byte, []int)
- func (*CoreRequest) ProtoMessage()
- func (m *CoreRequest) Reset()
- func (m *CoreRequest) String() string
- func (m *CoreRequest) XXX_DiscardUnknown()
- func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoreRequest) XXX_Merge(src proto.Message)
- func (m *CoreRequest) XXX_Size() int
- func (m *CoreRequest) XXX_Unmarshal(b []byte) error
- type CoreResponse
- func (*CoreResponse) Descriptor() ([]byte, []int)
- func (m *CoreResponse) GetCores() int32
- func (*CoreResponse) ProtoMessage()
- func (m *CoreResponse) Reset()
- func (m *CoreResponse) String() string
- func (m *CoreResponse) XXX_DiscardUnknown()
- func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoreResponse) XXX_Merge(src proto.Message)
- func (m *CoreResponse) XXX_Size() int
- func (m *CoreResponse) XXX_Unmarshal(b []byte) error
- type EchoStatus
- func (*EchoStatus) Descriptor() ([]byte, []int)
- func (m *EchoStatus) GetCode() int32
- func (m *EchoStatus) GetMessage() string
- func (*EchoStatus) ProtoMessage()
- func (m *EchoStatus) Reset()
- func (m *EchoStatus) String() string
- func (m *EchoStatus) XXX_DiscardUnknown()
- func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoStatus) XXX_Merge(src proto.Message)
- func (m *EchoStatus) XXX_Size() int
- func (m *EchoStatus) XXX_Unmarshal(b []byte) error
- type GrpclbRouteType
- type HistogramData
- func (*HistogramData) Descriptor() ([]byte, []int)
- func (m *HistogramData) GetBucket() []uint32
- func (m *HistogramData) GetCount() float64
- func (m *HistogramData) GetMaxSeen() float64
- func (m *HistogramData) GetMinSeen() float64
- func (m *HistogramData) GetSum() float64
- func (m *HistogramData) GetSumOfSquares() float64
- func (*HistogramData) ProtoMessage()
- func (m *HistogramData) Reset()
- func (m *HistogramData) String() string
- func (m *HistogramData) XXX_DiscardUnknown()
- func (m *HistogramData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HistogramData) XXX_Merge(src proto.Message)
- func (m *HistogramData) XXX_Size() int
- func (m *HistogramData) XXX_Unmarshal(b []byte) error
- type HistogramParams
- func (*HistogramParams) Descriptor() ([]byte, []int)
- func (m *HistogramParams) GetMaxPossible() float64
- func (m *HistogramParams) GetResolution() float64
- func (*HistogramParams) ProtoMessage()
- func (m *HistogramParams) Reset()
- func (m *HistogramParams) String() string
- func (m *HistogramParams) XXX_DiscardUnknown()
- func (m *HistogramParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HistogramParams) XXX_Merge(src proto.Message)
- func (m *HistogramParams) XXX_Size() int
- func (m *HistogramParams) XXX_Unmarshal(b []byte) error
- type LoadParams
- func (*LoadParams) Descriptor() ([]byte, []int)
- func (m *LoadParams) GetClosedLoop() *ClosedLoopParams
- func (m *LoadParams) GetLoad() isLoadParams_Load
- func (m *LoadParams) GetPoisson() *PoissonParams
- func (*LoadParams) ProtoMessage()
- func (m *LoadParams) Reset()
- func (m *LoadParams) String() string
- func (m *LoadParams) XXX_DiscardUnknown()
- func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadParams) XXX_Merge(src proto.Message)
- func (*LoadParams) XXX_OneofWrappers() []interface{}
- func (m *LoadParams) XXX_Size() int
- func (m *LoadParams) XXX_Unmarshal(b []byte) error
- type LoadParams_ClosedLoop
- type LoadParams_Poisson
- type Mark
- func (*Mark) Descriptor() ([]byte, []int)
- func (m *Mark) GetReset_() bool
- func (*Mark) ProtoMessage()
- func (m *Mark) Reset()
- func (m *Mark) String() string
- func (m *Mark) XXX_DiscardUnknown()
- func (m *Mark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Mark) XXX_Merge(src proto.Message)
- func (m *Mark) XXX_Size() int
- func (m *Mark) XXX_Unmarshal(b []byte) error
- type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (m *Payload) GetBody() []byte
- func (m *Payload) GetType() PayloadType
- func (*Payload) ProtoMessage()
- func (m *Payload) Reset()
- func (m *Payload) String() string
- func (m *Payload) XXX_DiscardUnknown()
- func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payload) XXX_Merge(src proto.Message)
- func (m *Payload) XXX_Size() int
- func (m *Payload) XXX_Unmarshal(b []byte) error
- type PayloadConfig
- func (*PayloadConfig) Descriptor() ([]byte, []int)
- func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams
- func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams
- func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
- func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams
- func (*PayloadConfig) ProtoMessage()
- func (m *PayloadConfig) Reset()
- func (m *PayloadConfig) String() string
- func (m *PayloadConfig) XXX_DiscardUnknown()
- func (m *PayloadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayloadConfig) XXX_Merge(src proto.Message)
- func (*PayloadConfig) XXX_OneofWrappers() []interface{}
- func (m *PayloadConfig) XXX_Size() int
- func (m *PayloadConfig) XXX_Unmarshal(b []byte) error
- type PayloadConfig_BytebufParams
- type PayloadConfig_ComplexParams
- type PayloadConfig_SimpleParams
- type PayloadType
- type PoissonParams
- func (*PoissonParams) Descriptor() ([]byte, []int)
- func (m *PoissonParams) GetOfferedLoad() float64
- func (*PoissonParams) ProtoMessage()
- func (m *PoissonParams) Reset()
- func (m *PoissonParams) String() string
- func (m *PoissonParams) XXX_DiscardUnknown()
- func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PoissonParams) XXX_Merge(src proto.Message)
- func (m *PoissonParams) XXX_Size() int
- func (m *PoissonParams) XXX_Unmarshal(b []byte) error
- type ReconnectInfo
- func (*ReconnectInfo) Descriptor() ([]byte, []int)
- func (m *ReconnectInfo) GetBackoffMs() []int32
- func (m *ReconnectInfo) GetPassed() bool
- func (*ReconnectInfo) ProtoMessage()
- func (m *ReconnectInfo) Reset()
- func (m *ReconnectInfo) String() string
- func (m *ReconnectInfo) XXX_DiscardUnknown()
- func (m *ReconnectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReconnectInfo) XXX_Merge(src proto.Message)
- func (m *ReconnectInfo) XXX_Size() int
- func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error
- type ReconnectParams
- func (*ReconnectParams) Descriptor() ([]byte, []int)
- func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32
- func (*ReconnectParams) ProtoMessage()
- func (m *ReconnectParams) Reset()
- func (m *ReconnectParams) String() string
- func (m *ReconnectParams) XXX_DiscardUnknown()
- func (m *ReconnectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReconnectParams) XXX_Merge(src proto.Message)
- func (m *ReconnectParams) XXX_Size() int
- func (m *ReconnectParams) XXX_Unmarshal(b []byte) error
- type ReportQpsScenarioServiceClient
- type ReportQpsScenarioServiceServer
- type RequestResultCount
- func (*RequestResultCount) Descriptor() ([]byte, []int)
- func (m *RequestResultCount) GetCount() int64
- func (m *RequestResultCount) GetStatusCode() int32
- func (*RequestResultCount) ProtoMessage()
- func (m *RequestResultCount) Reset()
- func (m *RequestResultCount) String() string
- func (m *RequestResultCount) XXX_DiscardUnknown()
- func (m *RequestResultCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestResultCount) XXX_Merge(src proto.Message)
- func (m *RequestResultCount) XXX_Size() int
- func (m *RequestResultCount) XXX_Unmarshal(b []byte) error
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)
- func (m *ResponseParameters) GetCompressed() *BoolValue
- func (m *ResponseParameters) GetIntervalUs() int32
- func (m *ResponseParameters) GetSize() int32
- func (*ResponseParameters) ProtoMessage()
- func (m *ResponseParameters) Reset()
- func (m *ResponseParameters) String() string
- func (m *ResponseParameters) XXX_DiscardUnknown()
- func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseParameters) XXX_Merge(src proto.Message)
- func (m *ResponseParameters) XXX_Size() int
- func (m *ResponseParameters) XXX_Unmarshal(b []byte) error
- type RpcType
- type Scenario
- func (*Scenario) Descriptor() ([]byte, []int)
- func (m *Scenario) GetBenchmarkSeconds() int32
- func (m *Scenario) GetClientConfig() *ClientConfig
- func (m *Scenario) GetName() string
- func (m *Scenario) GetNumClients() int32
- func (m *Scenario) GetNumServers() int32
- func (m *Scenario) GetServerConfig() *ServerConfig
- func (m *Scenario) GetSpawnLocalWorkerCount() int32
- func (m *Scenario) GetWarmupSeconds() int32
- func (*Scenario) ProtoMessage()
- func (m *Scenario) Reset()
- func (m *Scenario) String() string
- func (m *Scenario) XXX_DiscardUnknown()
- func (m *Scenario) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Scenario) XXX_Merge(src proto.Message)
- func (m *Scenario) XXX_Size() int
- func (m *Scenario) XXX_Unmarshal(b []byte) error
- type ScenarioResult
- func (*ScenarioResult) Descriptor() ([]byte, []int)
- func (m *ScenarioResult) GetClientStats() []*ClientStats
- func (m *ScenarioResult) GetClientSuccess() []bool
- func (m *ScenarioResult) GetLatencies() *HistogramData
- func (m *ScenarioResult) GetRequestResults() []*RequestResultCount
- func (m *ScenarioResult) GetScenario() *Scenario
- func (m *ScenarioResult) GetServerCores() []int32
- func (m *ScenarioResult) GetServerStats() []*ServerStats
- func (m *ScenarioResult) GetServerSuccess() []bool
- func (m *ScenarioResult) GetSummary() *ScenarioResultSummary
- func (*ScenarioResult) ProtoMessage()
- func (m *ScenarioResult) Reset()
- func (m *ScenarioResult) String() string
- func (m *ScenarioResult) XXX_DiscardUnknown()
- func (m *ScenarioResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScenarioResult) XXX_Merge(src proto.Message)
- func (m *ScenarioResult) XXX_Size() int
- func (m *ScenarioResult) XXX_Unmarshal(b []byte) error
- type ScenarioResultSummary
- func (*ScenarioResultSummary) Descriptor() ([]byte, []int)
- func (m *ScenarioResultSummary) GetClientPollsPerRequest() float64
- func (m *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64
- func (m *ScenarioResultSummary) GetClientSystemTime() float64
- func (m *ScenarioResultSummary) GetClientUserTime() float64
- func (m *ScenarioResultSummary) GetFailedRequestsPerSecond() float64
- func (m *ScenarioResultSummary) GetLatency_50() float64
- func (m *ScenarioResultSummary) GetLatency_90() float64
- func (m *ScenarioResultSummary) GetLatency_95() float64
- func (m *ScenarioResultSummary) GetLatency_99() float64
- func (m *ScenarioResultSummary) GetLatency_999() float64
- func (m *ScenarioResultSummary) GetQps() float64
- func (m *ScenarioResultSummary) GetQpsPerServerCore() float64
- func (m *ScenarioResultSummary) GetServerCpuUsage() float64
- func (m *ScenarioResultSummary) GetServerPollsPerRequest() float64
- func (m *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64
- func (m *ScenarioResultSummary) GetServerSystemTime() float64
- func (m *ScenarioResultSummary) GetServerUserTime() float64
- func (m *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64
- func (*ScenarioResultSummary) ProtoMessage()
- func (m *ScenarioResultSummary) Reset()
- func (m *ScenarioResultSummary) String() string
- func (m *ScenarioResultSummary) XXX_DiscardUnknown()
- func (m *ScenarioResultSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScenarioResultSummary) XXX_Merge(src proto.Message)
- func (m *ScenarioResultSummary) XXX_Size() int
- func (m *ScenarioResultSummary) XXX_Unmarshal(b []byte) error
- type Scenarios
- func (*Scenarios) Descriptor() ([]byte, []int)
- func (m *Scenarios) GetScenarios() []*Scenario
- func (*Scenarios) ProtoMessage()
- func (m *Scenarios) Reset()
- func (m *Scenarios) String() string
- func (m *Scenarios) XXX_DiscardUnknown()
- func (m *Scenarios) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Scenarios) XXX_Merge(src proto.Message)
- func (m *Scenarios) XXX_Size() int
- func (m *Scenarios) XXX_Unmarshal(b []byte) error
- type SecurityParams
- func (*SecurityParams) Descriptor() ([]byte, []int)
- func (m *SecurityParams) GetCredType() string
- func (m *SecurityParams) GetServerHostOverride() string
- func (m *SecurityParams) GetUseTestCa() bool
- func (*SecurityParams) ProtoMessage()
- func (m *SecurityParams) Reset()
- func (m *SecurityParams) String() string
- func (m *SecurityParams) XXX_DiscardUnknown()
- func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SecurityParams) XXX_Merge(src proto.Message)
- func (m *SecurityParams) XXX_Size() int
- func (m *SecurityParams) XXX_Unmarshal(b []byte) error
- type ServerArgs
- func (*ServerArgs) Descriptor() ([]byte, []int)
- func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
- func (m *ServerArgs) GetMark() *Mark
- func (m *ServerArgs) GetSetup() *ServerConfig
- func (*ServerArgs) ProtoMessage()
- func (m *ServerArgs) Reset()
- func (m *ServerArgs) String() string
- func (m *ServerArgs) XXX_DiscardUnknown()
- func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerArgs) XXX_Merge(src proto.Message)
- func (*ServerArgs) XXX_OneofWrappers() []interface{}
- func (m *ServerArgs) XXX_Size() int
- func (m *ServerArgs) XXX_Unmarshal(b []byte) error
- type ServerArgs_Mark
- type ServerArgs_Setup
- type ServerConfig
- func (*ServerConfig) Descriptor() ([]byte, []int)
- func (m *ServerConfig) GetAsyncServerThreads() int32
- func (m *ServerConfig) GetChannelArgs() []*ChannelArg
- func (m *ServerConfig) GetCoreLimit() int32
- func (m *ServerConfig) GetCoreList() []int32
- func (m *ServerConfig) GetOtherServerApi() string
- func (m *ServerConfig) GetPayloadConfig() *PayloadConfig
- func (m *ServerConfig) GetPort() int32
- func (m *ServerConfig) GetResourceQuotaSize() int32
- func (m *ServerConfig) GetSecurityParams() *SecurityParams
- func (m *ServerConfig) GetServerType() ServerType
- func (m *ServerConfig) GetThreadsPerCq() int32
- func (*ServerConfig) ProtoMessage()
- func (m *ServerConfig) Reset()
- func (m *ServerConfig) String() string
- func (m *ServerConfig) XXX_DiscardUnknown()
- func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerConfig) XXX_Merge(src proto.Message)
- func (m *ServerConfig) XXX_Size() int
- func (m *ServerConfig) XXX_Unmarshal(b []byte) error
- type ServerStats
- func (*ServerStats) Descriptor() ([]byte, []int)
- func (m *ServerStats) GetCoreStats() *core.Stats
- func (m *ServerStats) GetCqPollCount() uint64
- func (m *ServerStats) GetIdleCpuTime() uint64
- func (m *ServerStats) GetTimeElapsed() float64
- func (m *ServerStats) GetTimeSystem() float64
- func (m *ServerStats) GetTimeUser() float64
- func (m *ServerStats) GetTotalCpuTime() uint64
- func (*ServerStats) ProtoMessage()
- func (m *ServerStats) Reset()
- func (m *ServerStats) String() string
- func (m *ServerStats) XXX_DiscardUnknown()
- func (m *ServerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerStats) XXX_Merge(src proto.Message)
- func (m *ServerStats) XXX_Size() int
- func (m *ServerStats) XXX_Unmarshal(b []byte) error
- type ServerStatus
- func (*ServerStatus) Descriptor() ([]byte, []int)
- func (m *ServerStatus) GetCores() int32
- func (m *ServerStatus) GetPort() int32
- func (m *ServerStatus) GetStats() *ServerStats
- func (*ServerStatus) ProtoMessage()
- func (m *ServerStatus) Reset()
- func (m *ServerStatus) String() string
- func (m *ServerStatus) XXX_DiscardUnknown()
- func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerStatus) XXX_Merge(src proto.Message)
- func (m *ServerStatus) XXX_Size() int
- func (m *ServerStatus) XXX_Unmarshal(b []byte) error
- type ServerType
- type SimpleProtoParams
- func (*SimpleProtoParams) Descriptor() ([]byte, []int)
- func (m *SimpleProtoParams) GetReqSize() int32
- func (m *SimpleProtoParams) GetRespSize() int32
- func (*SimpleProtoParams) ProtoMessage()
- func (m *SimpleProtoParams) Reset()
- func (m *SimpleProtoParams) String() string
- func (m *SimpleProtoParams) XXX_DiscardUnknown()
- func (m *SimpleProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleProtoParams) XXX_Merge(src proto.Message)
- func (m *SimpleProtoParams) XXX_Size() int
- func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)
- func (m *SimpleRequest) GetExpectCompressed() *BoolValue
- func (m *SimpleRequest) GetFillGrpclbRouteType() bool
- func (m *SimpleRequest) GetFillOauthScope() bool
- func (m *SimpleRequest) GetFillServerId() bool
- func (m *SimpleRequest) GetFillUsername() bool
- func (m *SimpleRequest) GetPayload() *Payload
- func (m *SimpleRequest) GetResponseCompressed() *BoolValue
- func (m *SimpleRequest) GetResponseSize() int32
- func (m *SimpleRequest) GetResponseStatus() *EchoStatus
- func (m *SimpleRequest) GetResponseType() PayloadType
- func (*SimpleRequest) ProtoMessage()
- func (m *SimpleRequest) Reset()
- func (m *SimpleRequest) String() string
- func (m *SimpleRequest) XXX_DiscardUnknown()
- func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleRequest) XXX_Merge(src proto.Message)
- func (m *SimpleRequest) XXX_Size() int
- func (m *SimpleRequest) XXX_Unmarshal(b []byte) error
- type SimpleResponse
- func (*SimpleResponse) Descriptor() ([]byte, []int)
- func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
- func (m *SimpleResponse) GetOauthScope() string
- func (m *SimpleResponse) GetPayload() *Payload
- func (m *SimpleResponse) GetServerId() string
- func (m *SimpleResponse) GetUsername() string
- func (*SimpleResponse) ProtoMessage()
- func (m *SimpleResponse) Reset()
- func (m *SimpleResponse) String() string
- func (m *SimpleResponse) XXX_DiscardUnknown()
- func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleResponse) XXX_Merge(src proto.Message)
- func (m *SimpleResponse) XXX_Size() int
- func (m *SimpleResponse) XXX_Unmarshal(b []byte) error
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
- func (m *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
- func (m *StreamingInputCallRequest) GetPayload() *Payload
- func (*StreamingInputCallRequest) ProtoMessage()
- func (m *StreamingInputCallRequest) Reset()
- func (m *StreamingInputCallRequest) String() string
- func (m *StreamingInputCallRequest) XXX_DiscardUnknown()
- func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)
- func (m *StreamingInputCallRequest) XXX_Size() int
- func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error
- type StreamingInputCallResponse
- func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
- func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
- func (*StreamingInputCallResponse) ProtoMessage()
- func (m *StreamingInputCallResponse) Reset()
- func (m *StreamingInputCallResponse) String() string
- func (m *StreamingInputCallResponse) XXX_DiscardUnknown()
- func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)
- func (m *StreamingInputCallResponse) XXX_Size() int
- func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error
- type StreamingOutputCallRequest
- func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
- func (m *StreamingOutputCallRequest) GetPayload() *Payload
- func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (m *StreamingOutputCallRequest) GetResponseType() PayloadType
- func (*StreamingOutputCallRequest) ProtoMessage()
- func (m *StreamingOutputCallRequest) Reset()
- func (m *StreamingOutputCallRequest) String() string
- func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()
- func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)
- func (m *StreamingOutputCallRequest) XXX_Size() int
- func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error
- type StreamingOutputCallResponse
- func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
- func (m *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (m *StreamingOutputCallResponse) Reset()
- func (m *StreamingOutputCallResponse) String() string
- func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()
- func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)
- func (m *StreamingOutputCallResponse) XXX_Size() int
- func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedBenchmarkServiceServer
- func (*UnimplementedBenchmarkServiceServer) StreamingBothWays(srv BenchmarkService_StreamingBothWaysServer) error
- func (*UnimplementedBenchmarkServiceServer) StreamingCall(srv BenchmarkService_StreamingCallServer) error
- func (*UnimplementedBenchmarkServiceServer) StreamingFromClient(srv BenchmarkService_StreamingFromClientServer) error
- func (*UnimplementedBenchmarkServiceServer) StreamingFromServer(req *SimpleRequest, srv BenchmarkService_StreamingFromServerServer) error
- func (*UnimplementedBenchmarkServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)
- type UnimplementedReportQpsScenarioServiceServer
- type UnimplementedWorkerServiceServer
- func (*UnimplementedWorkerServiceServer) CoreCount(ctx context.Context, req *CoreRequest) (*CoreResponse, error)
- func (*UnimplementedWorkerServiceServer) QuitWorker(ctx context.Context, req *Void) (*Void, error)
- func (*UnimplementedWorkerServiceServer) RunClient(srv WorkerService_RunClientServer) error
- func (*UnimplementedWorkerServiceServer) RunServer(srv WorkerService_RunServerServer) error
- type Void
- func (*Void) Descriptor() ([]byte, []int)
- func (*Void) ProtoMessage()
- func (m *Void) Reset()
- func (m *Void) String() string
- func (m *Void) XXX_DiscardUnknown()
- func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Void) XXX_Merge(src proto.Message)
- func (m *Void) XXX_Size() int
- func (m *Void) XXX_Unmarshal(b []byte) error
- type WorkerServiceClient
- type WorkerServiceServer
- type WorkerService_RunClientClient
- type WorkerService_RunClientServer
- type WorkerService_RunServerClient
- type WorkerService_RunServerServer
Constants ¶
This section is empty.
Variables ¶
var ClientType_name = map[int32]string{
0: "SYNC_CLIENT",
1: "ASYNC_CLIENT",
2: "OTHER_CLIENT",
}
var ClientType_value = map[string]int32{
"SYNC_CLIENT": 0,
"ASYNC_CLIENT": 1,
"OTHER_CLIENT": 2,
}
var GrpclbRouteType_name = map[int32]string{
0: "GRPCLB_ROUTE_TYPE_UNKNOWN",
1: "GRPCLB_ROUTE_TYPE_FALLBACK",
2: "GRPCLB_ROUTE_TYPE_BACKEND",
}
var GrpclbRouteType_value = map[string]int32{
"GRPCLB_ROUTE_TYPE_UNKNOWN": 0,
"GRPCLB_ROUTE_TYPE_FALLBACK": 1,
"GRPCLB_ROUTE_TYPE_BACKEND": 2,
}
var PayloadType_name = map[int32]string{
0: "COMPRESSABLE",
}
var PayloadType_value = map[string]int32{
"COMPRESSABLE": 0,
}
var RpcType_name = map[int32]string{
0: "UNARY",
1: "STREAMING",
2: "STREAMING_FROM_CLIENT",
3: "STREAMING_FROM_SERVER",
4: "STREAMING_BOTH_WAYS",
}
var RpcType_value = map[string]int32{
"UNARY": 0,
"STREAMING": 1,
"STREAMING_FROM_CLIENT": 2,
"STREAMING_FROM_SERVER": 3,
"STREAMING_BOTH_WAYS": 4,
}
var ServerType_name = map[int32]string{
0: "SYNC_SERVER",
1: "ASYNC_SERVER",
2: "ASYNC_GENERIC_SERVER",
3: "OTHER_SERVER",
}
var ServerType_value = map[string]int32{
"SYNC_SERVER": 0,
"ASYNC_SERVER": 1,
"ASYNC_GENERIC_SERVER": 2,
"OTHER_SERVER": 3,
}
Functions ¶
func RegisterBenchmarkServiceServer ¶
func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)
func RegisterReportQpsScenarioServiceServer ¶
func RegisterReportQpsScenarioServiceServer(s *grpc.Server, srv ReportQpsScenarioServiceServer)
func RegisterWorkerServiceServer ¶
func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)
Types ¶
type BenchmarkServiceClient ¶
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) (BenchmarkService_StreamingCallClient, 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) (BenchmarkService_StreamingFromClientClient, 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) (BenchmarkService_StreamingFromServerClient, 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) (BenchmarkService_StreamingBothWaysClient, error)
}
BenchmarkServiceClient is the client API for BenchmarkService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBenchmarkServiceClient ¶
func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient
type BenchmarkServiceServer ¶
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(BenchmarkService_StreamingCallServer) error
// Single-sided unbounded streaming from client to server
// The server returns the client payload as-is once the client does WritesDone
StreamingFromClient(BenchmarkService_StreamingFromClientServer) error
// Single-sided unbounded streaming from server to client
// The server repeatedly returns the client payload as-is
StreamingFromServer(*SimpleRequest, BenchmarkService_StreamingFromServerServer) error
// Two-sided unbounded streaming between server to client
// Both sides send the content of their own choice to the other
StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error
}
BenchmarkServiceServer is the server API for BenchmarkService service.
type BenchmarkService_StreamingBothWaysClient ¶
type BenchmarkService_StreamingBothWaysClient interface {
Send(*SimpleRequest) error
Recv() (*SimpleResponse, error)
grpc.ClientStream
}
type BenchmarkService_StreamingBothWaysServer ¶
type BenchmarkService_StreamingBothWaysServer interface {
Send(*SimpleResponse) error
Recv() (*SimpleRequest, error)
grpc.ServerStream
}
type BenchmarkService_StreamingCallClient ¶
type BenchmarkService_StreamingCallClient interface {
Send(*SimpleRequest) error
Recv() (*SimpleResponse, error)
grpc.ClientStream
}
type BenchmarkService_StreamingCallServer ¶
type BenchmarkService_StreamingCallServer interface {
Send(*SimpleResponse) error
Recv() (*SimpleRequest, error)
grpc.ServerStream
}
type BenchmarkService_StreamingFromClientClient ¶
type BenchmarkService_StreamingFromClientClient interface {
Send(*SimpleRequest) error
CloseAndRecv() (*SimpleResponse, error)
grpc.ClientStream
}
type BenchmarkService_StreamingFromClientServer ¶
type BenchmarkService_StreamingFromClientServer interface {
SendAndClose(*SimpleResponse) error
Recv() (*SimpleRequest, error)
grpc.ServerStream
}
type BenchmarkService_StreamingFromServerClient ¶
type BenchmarkService_StreamingFromServerClient interface {
Recv() (*SimpleResponse, error)
grpc.ClientStream
}
type BenchmarkService_StreamingFromServerServer ¶
type BenchmarkService_StreamingFromServerServer interface {
Send(*SimpleResponse) error
grpc.ServerStream
}
type BoolValue ¶
type BoolValue struct {
// The bool value.
Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
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 ¶
func (*BoolValue) ProtoMessage ¶
func (*BoolValue) ProtoMessage()
func (*BoolValue) XXX_DiscardUnknown ¶
func (m *BoolValue) XXX_DiscardUnknown()
func (*BoolValue) XXX_Marshal ¶
func (*BoolValue) XXX_Unmarshal ¶
type ByteBufferParams ¶
type ByteBufferParams struct {
ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ByteBufferParams) Descriptor ¶
func (*ByteBufferParams) Descriptor() ([]byte, []int)
func (*ByteBufferParams) GetReqSize ¶
func (m *ByteBufferParams) GetReqSize() int32
func (*ByteBufferParams) GetRespSize ¶
func (m *ByteBufferParams) GetRespSize() int32
func (*ByteBufferParams) ProtoMessage ¶
func (*ByteBufferParams) ProtoMessage()
func (*ByteBufferParams) Reset ¶
func (m *ByteBufferParams) Reset()
func (*ByteBufferParams) String ¶
func (m *ByteBufferParams) String() string
func (*ByteBufferParams) XXX_DiscardUnknown ¶
func (m *ByteBufferParams) XXX_DiscardUnknown()
func (*ByteBufferParams) XXX_Marshal ¶
func (m *ByteBufferParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ByteBufferParams) XXX_Merge ¶
func (m *ByteBufferParams) XXX_Merge(src proto.Message)
func (*ByteBufferParams) XXX_Size ¶
func (m *ByteBufferParams) XXX_Size() int
func (*ByteBufferParams) XXX_Unmarshal ¶
func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error
type ChannelArg ¶
type ChannelArg struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Types that are valid to be assigned to Value:
// *ChannelArg_StrValue
// *ChannelArg_IntValue
Value isChannelArg_Value `protobuf_oneof:"value"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ChannelArg) Descriptor ¶
func (*ChannelArg) Descriptor() ([]byte, []int)
func (*ChannelArg) GetIntValue ¶
func (m *ChannelArg) GetIntValue() int32
func (*ChannelArg) GetName ¶
func (m *ChannelArg) GetName() string
func (*ChannelArg) GetStrValue ¶
func (m *ChannelArg) GetStrValue() string
func (*ChannelArg) GetValue ¶
func (m *ChannelArg) GetValue() isChannelArg_Value
func (*ChannelArg) ProtoMessage ¶
func (*ChannelArg) ProtoMessage()
func (*ChannelArg) Reset ¶
func (m *ChannelArg) Reset()
func (*ChannelArg) String ¶
func (m *ChannelArg) String() string
func (*ChannelArg) XXX_DiscardUnknown ¶
func (m *ChannelArg) XXX_DiscardUnknown()
func (*ChannelArg) XXX_Marshal ¶
func (m *ChannelArg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelArg) XXX_Merge ¶
func (m *ChannelArg) XXX_Merge(src proto.Message)
func (*ChannelArg) XXX_OneofWrappers ¶
func (*ChannelArg) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ChannelArg) XXX_Size ¶
func (m *ChannelArg) XXX_Size() int
func (*ChannelArg) XXX_Unmarshal ¶
func (m *ChannelArg) XXX_Unmarshal(b []byte) error
type ChannelArg_IntValue ¶
type ChannelArg_IntValue struct {
IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}
type ChannelArg_StrValue ¶
type ChannelArg_StrValue struct {
StrValue string `protobuf:"bytes,2,opt,name=str_value,json=strValue,proto3,oneof"`
}
type ClientArgs ¶
type ClientArgs struct {
// Types that are valid to be assigned to Argtype:
// *ClientArgs_Setup
// *ClientArgs_Mark
Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ClientArgs) Descriptor ¶
func (*ClientArgs) Descriptor() ([]byte, []int)
func (*ClientArgs) GetArgtype ¶
func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
func (*ClientArgs) GetMark ¶
func (m *ClientArgs) GetMark() *Mark
func (*ClientArgs) GetSetup ¶
func (m *ClientArgs) GetSetup() *ClientConfig
func (*ClientArgs) ProtoMessage ¶
func (*ClientArgs) ProtoMessage()
func (*ClientArgs) Reset ¶
func (m *ClientArgs) Reset()
func (*ClientArgs) String ¶
func (m *ClientArgs) String() string
func (*ClientArgs) XXX_DiscardUnknown ¶
func (m *ClientArgs) XXX_DiscardUnknown()
func (*ClientArgs) XXX_Marshal ¶
func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientArgs) XXX_Merge ¶
func (m *ClientArgs) XXX_Merge(src proto.Message)
func (*ClientArgs) XXX_OneofWrappers ¶
func (*ClientArgs) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ClientArgs) XXX_Size ¶
func (m *ClientArgs) XXX_Size() int
func (*ClientArgs) XXX_Unmarshal ¶
func (m *ClientArgs) XXX_Unmarshal(b []byte) error
type ClientArgs_Mark ¶
type ClientArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ClientArgs_Setup ¶
type ClientArgs_Setup struct {
Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ClientConfig ¶
type ClientConfig struct {
// 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ClientConfig) Descriptor ¶
func (*ClientConfig) Descriptor() ([]byte, []int)
func (*ClientConfig) GetAsyncClientThreads ¶
func (m *ClientConfig) GetAsyncClientThreads() int32
func (*ClientConfig) GetChannelArgs ¶
func (m *ClientConfig) GetChannelArgs() []*ChannelArg
func (*ClientConfig) GetClientChannels ¶
func (m *ClientConfig) GetClientChannels() int32
func (*ClientConfig) GetClientType ¶
func (m *ClientConfig) GetClientType() ClientType
func (*ClientConfig) GetCoreLimit ¶
func (m *ClientConfig) GetCoreLimit() int32
func (*ClientConfig) GetCoreList ¶
func (m *ClientConfig) GetCoreList() []int32
func (*ClientConfig) GetHistogramParams ¶
func (m *ClientConfig) GetHistogramParams() *HistogramParams
func (*ClientConfig) GetLoadParams ¶
func (m *ClientConfig) GetLoadParams() *LoadParams
func (*ClientConfig) GetMessagesPerStream ¶
func (m *ClientConfig) GetMessagesPerStream() int32
func (*ClientConfig) GetOtherClientApi ¶
func (m *ClientConfig) GetOtherClientApi() string
func (*ClientConfig) GetOutstandingRpcsPerChannel ¶
func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32
func (*ClientConfig) GetPayloadConfig ¶
func (m *ClientConfig) GetPayloadConfig() *PayloadConfig
func (*ClientConfig) GetRpcType ¶
func (m *ClientConfig) GetRpcType() RpcType
func (*ClientConfig) GetSecurityParams ¶
func (m *ClientConfig) GetSecurityParams() *SecurityParams
func (*ClientConfig) GetServerTargets ¶
func (m *ClientConfig) GetServerTargets() []string
func (*ClientConfig) GetThreadsPerCq ¶
func (m *ClientConfig) GetThreadsPerCq() int32
func (*ClientConfig) GetUseCoalesceApi ¶
func (m *ClientConfig) GetUseCoalesceApi() bool
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) Reset ¶
func (m *ClientConfig) Reset()
func (*ClientConfig) String ¶
func (m *ClientConfig) String() string
func (*ClientConfig) XXX_DiscardUnknown ¶
func (m *ClientConfig) XXX_DiscardUnknown()
func (*ClientConfig) XXX_Marshal ¶
func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientConfig) XXX_Merge ¶
func (m *ClientConfig) XXX_Merge(src proto.Message)
func (*ClientConfig) XXX_Size ¶
func (m *ClientConfig) XXX_Size() int
func (*ClientConfig) XXX_Unmarshal ¶
func (m *ClientConfig) XXX_Unmarshal(b []byte) error
type ClientStats ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ClientStats) Descriptor ¶
func (*ClientStats) Descriptor() ([]byte, []int)
func (*ClientStats) GetCoreStats ¶
func (m *ClientStats) GetCoreStats() *core.Stats
func (*ClientStats) GetCqPollCount ¶
func (m *ClientStats) GetCqPollCount() uint64
func (*ClientStats) GetLatencies ¶
func (m *ClientStats) GetLatencies() *HistogramData
func (*ClientStats) GetRequestResults ¶
func (m *ClientStats) GetRequestResults() []*RequestResultCount
func (*ClientStats) GetTimeElapsed ¶
func (m *ClientStats) GetTimeElapsed() float64
func (*ClientStats) GetTimeSystem ¶
func (m *ClientStats) GetTimeSystem() float64
func (*ClientStats) GetTimeUser ¶
func (m *ClientStats) GetTimeUser() float64
func (*ClientStats) ProtoMessage ¶
func (*ClientStats) ProtoMessage()
func (*ClientStats) Reset ¶
func (m *ClientStats) Reset()
func (*ClientStats) String ¶
func (m *ClientStats) String() string
func (*ClientStats) XXX_DiscardUnknown ¶
func (m *ClientStats) XXX_DiscardUnknown()
func (*ClientStats) XXX_Marshal ¶
func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientStats) XXX_Merge ¶
func (m *ClientStats) XXX_Merge(src proto.Message)
func (*ClientStats) XXX_Size ¶
func (m *ClientStats) XXX_Size() int
func (*ClientStats) XXX_Unmarshal ¶
func (m *ClientStats) XXX_Unmarshal(b []byte) error
type ClientStatus ¶
type ClientStatus struct {
Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ClientStatus) Descriptor ¶
func (*ClientStatus) Descriptor() ([]byte, []int)
func (*ClientStatus) GetStats ¶
func (m *ClientStatus) GetStats() *ClientStats
func (*ClientStatus) ProtoMessage ¶
func (*ClientStatus) ProtoMessage()
func (*ClientStatus) Reset ¶
func (m *ClientStatus) Reset()
func (*ClientStatus) String ¶
func (m *ClientStatus) String() string
func (*ClientStatus) XXX_DiscardUnknown ¶
func (m *ClientStatus) XXX_DiscardUnknown()
func (*ClientStatus) XXX_Marshal ¶
func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientStatus) XXX_Merge ¶
func (m *ClientStatus) XXX_Merge(src proto.Message)
func (*ClientStatus) XXX_Size ¶
func (m *ClientStatus) XXX_Size() int
func (*ClientStatus) XXX_Unmarshal ¶
func (m *ClientStatus) XXX_Unmarshal(b []byte) error
type ClientType ¶
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 )
func (ClientType) EnumDescriptor ¶
func (ClientType) EnumDescriptor() ([]byte, []int)
func (ClientType) String ¶
func (x ClientType) String() string
type ClosedLoopParams ¶
type ClosedLoopParams struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Once an RPC finishes, immediately start a new one. No configuration parameters needed.
func (*ClosedLoopParams) Descriptor ¶
func (*ClosedLoopParams) Descriptor() ([]byte, []int)
func (*ClosedLoopParams) ProtoMessage ¶
func (*ClosedLoopParams) ProtoMessage()
func (*ClosedLoopParams) Reset ¶
func (m *ClosedLoopParams) Reset()
func (*ClosedLoopParams) String ¶
func (m *ClosedLoopParams) String() string
func (*ClosedLoopParams) XXX_DiscardUnknown ¶
func (m *ClosedLoopParams) XXX_DiscardUnknown()
func (*ClosedLoopParams) XXX_Marshal ¶
func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClosedLoopParams) XXX_Merge ¶
func (m *ClosedLoopParams) XXX_Merge(src proto.Message)
func (*ClosedLoopParams) XXX_Size ¶
func (m *ClosedLoopParams) XXX_Size() int
func (*ClosedLoopParams) XXX_Unmarshal ¶
func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error
type ComplexProtoParams ¶
type ComplexProtoParams struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ComplexProtoParams) Descriptor ¶
func (*ComplexProtoParams) Descriptor() ([]byte, []int)
func (*ComplexProtoParams) ProtoMessage ¶
func (*ComplexProtoParams) ProtoMessage()
func (*ComplexProtoParams) Reset ¶
func (m *ComplexProtoParams) Reset()
func (*ComplexProtoParams) String ¶
func (m *ComplexProtoParams) String() string
func (*ComplexProtoParams) XXX_DiscardUnknown ¶
func (m *ComplexProtoParams) XXX_DiscardUnknown()
func (*ComplexProtoParams) XXX_Marshal ¶
func (m *ComplexProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ComplexProtoParams) XXX_Merge ¶
func (m *ComplexProtoParams) XXX_Merge(src proto.Message)
func (*ComplexProtoParams) XXX_Size ¶
func (m *ComplexProtoParams) XXX_Size() int
func (*ComplexProtoParams) XXX_Unmarshal ¶
func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error
type CoreRequest ¶
type CoreRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CoreRequest) Descriptor ¶
func (*CoreRequest) Descriptor() ([]byte, []int)
func (*CoreRequest) ProtoMessage ¶
func (*CoreRequest) ProtoMessage()
func (*CoreRequest) Reset ¶
func (m *CoreRequest) Reset()
func (*CoreRequest) String ¶
func (m *CoreRequest) String() string
func (*CoreRequest) XXX_DiscardUnknown ¶
func (m *CoreRequest) XXX_DiscardUnknown()
func (*CoreRequest) XXX_Marshal ¶
func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoreRequest) XXX_Merge ¶
func (m *CoreRequest) XXX_Merge(src proto.Message)
func (*CoreRequest) XXX_Size ¶
func (m *CoreRequest) XXX_Size() int
func (*CoreRequest) XXX_Unmarshal ¶
func (m *CoreRequest) XXX_Unmarshal(b []byte) error
type CoreResponse ¶
type CoreResponse struct {
// Number of cores available on the server
Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CoreResponse) Descriptor ¶
func (*CoreResponse) Descriptor() ([]byte, []int)
func (*CoreResponse) GetCores ¶
func (m *CoreResponse) GetCores() int32
func (*CoreResponse) ProtoMessage ¶
func (*CoreResponse) ProtoMessage()
func (*CoreResponse) Reset ¶
func (m *CoreResponse) Reset()
func (*CoreResponse) String ¶
func (m *CoreResponse) String() string
func (*CoreResponse) XXX_DiscardUnknown ¶
func (m *CoreResponse) XXX_DiscardUnknown()
func (*CoreResponse) XXX_Marshal ¶
func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoreResponse) XXX_Merge ¶
func (m *CoreResponse) XXX_Merge(src proto.Message)
func (*CoreResponse) XXX_Size ¶
func (m *CoreResponse) XXX_Size() int
func (*CoreResponse) XXX_Unmarshal ¶
func (m *CoreResponse) XXX_Unmarshal(b []byte) error
type EchoStatus ¶
type EchoStatus struct {
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
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 ¶
func (*EchoStatus) Descriptor() ([]byte, []int)
func (*EchoStatus) GetCode ¶
func (m *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶
func (m *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) Reset ¶
func (m *EchoStatus) Reset()
func (*EchoStatus) String ¶
func (m *EchoStatus) String() string
func (*EchoStatus) XXX_DiscardUnknown ¶
func (m *EchoStatus) XXX_DiscardUnknown()
func (*EchoStatus) XXX_Marshal ¶
func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoStatus) XXX_Merge ¶
func (m *EchoStatus) XXX_Merge(src proto.Message)
func (*EchoStatus) XXX_Size ¶
func (m *EchoStatus) XXX_Size() int
func (*EchoStatus) XXX_Unmarshal ¶
func (m *EchoStatus) XXX_Unmarshal(b []byte) error
type GrpclbRouteType ¶
type GrpclbRouteType int32
The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependant.
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) EnumDescriptor ¶
func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)
func (GrpclbRouteType) String ¶
func (x GrpclbRouteType) String() string
type HistogramData ¶
type HistogramData struct {
Bucket []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"`
MinSeen float64 `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"`
MaxSeen float64 `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"`
Sum float64 `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
SumOfSquares float64 `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"`
Count float64 `protobuf:"fixed64,6,opt,name=count,proto3" json:"count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Histogram data based on grpc/support/histogram.c
func (*HistogramData) Descriptor ¶
func (*HistogramData) Descriptor() ([]byte, []int)
func (*HistogramData) GetBucket ¶
func (m *HistogramData) GetBucket() []uint32
func (*HistogramData) GetCount ¶
func (m *HistogramData) GetCount() float64
func (*HistogramData) GetMaxSeen ¶
func (m *HistogramData) GetMaxSeen() float64
func (*HistogramData) GetMinSeen ¶
func (m *HistogramData) GetMinSeen() float64
func (*HistogramData) GetSum ¶
func (m *HistogramData) GetSum() float64
func (*HistogramData) GetSumOfSquares ¶
func (m *HistogramData) GetSumOfSquares() float64
func (*HistogramData) ProtoMessage ¶
func (*HistogramData) ProtoMessage()
func (*HistogramData) Reset ¶
func (m *HistogramData) Reset()
func (*HistogramData) String ¶
func (m *HistogramData) String() string
func (*HistogramData) XXX_DiscardUnknown ¶
func (m *HistogramData) XXX_DiscardUnknown()
func (*HistogramData) XXX_Marshal ¶
func (m *HistogramData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HistogramData) XXX_Merge ¶
func (m *HistogramData) XXX_Merge(src proto.Message)
func (*HistogramData) XXX_Size ¶
func (m *HistogramData) XXX_Size() int
func (*HistogramData) XXX_Unmarshal ¶
func (m *HistogramData) XXX_Unmarshal(b []byte) error
type HistogramParams ¶
type HistogramParams struct {
Resolution float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`
MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Histogram params based on grpc/support/histogram.c
func (*HistogramParams) Descriptor ¶
func (*HistogramParams) Descriptor() ([]byte, []int)
func (*HistogramParams) GetMaxPossible ¶
func (m *HistogramParams) GetMaxPossible() float64
func (*HistogramParams) GetResolution ¶
func (m *HistogramParams) GetResolution() float64
func (*HistogramParams) ProtoMessage ¶
func (*HistogramParams) ProtoMessage()
func (*HistogramParams) Reset ¶
func (m *HistogramParams) Reset()
func (*HistogramParams) String ¶
func (m *HistogramParams) String() string
func (*HistogramParams) XXX_DiscardUnknown ¶
func (m *HistogramParams) XXX_DiscardUnknown()
func (*HistogramParams) XXX_Marshal ¶
func (m *HistogramParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HistogramParams) XXX_Merge ¶
func (m *HistogramParams) XXX_Merge(src proto.Message)
func (*HistogramParams) XXX_Size ¶
func (m *HistogramParams) XXX_Size() int
func (*HistogramParams) XXX_Unmarshal ¶
func (m *HistogramParams) XXX_Unmarshal(b []byte) error
type LoadParams ¶
type LoadParams struct {
// Types that are valid to be assigned to Load:
// *LoadParams_ClosedLoop
// *LoadParams_Poisson
Load isLoadParams_Load `protobuf_oneof:"load"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*LoadParams) Descriptor ¶
func (*LoadParams) Descriptor() ([]byte, []int)
func (*LoadParams) GetClosedLoop ¶
func (m *LoadParams) GetClosedLoop() *ClosedLoopParams
func (*LoadParams) GetLoad ¶
func (m *LoadParams) GetLoad() isLoadParams_Load
func (*LoadParams) GetPoisson ¶
func (m *LoadParams) GetPoisson() *PoissonParams
func (*LoadParams) ProtoMessage ¶
func (*LoadParams) ProtoMessage()
func (*LoadParams) Reset ¶
func (m *LoadParams) Reset()
func (*LoadParams) String ¶
func (m *LoadParams) String() string
func (*LoadParams) XXX_DiscardUnknown ¶
func (m *LoadParams) XXX_DiscardUnknown()
func (*LoadParams) XXX_Marshal ¶
func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadParams) XXX_Merge ¶
func (m *LoadParams) XXX_Merge(src proto.Message)
func (*LoadParams) XXX_OneofWrappers ¶
func (*LoadParams) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*LoadParams) XXX_Size ¶
func (m *LoadParams) XXX_Size() int
func (*LoadParams) XXX_Unmarshal ¶
func (m *LoadParams) XXX_Unmarshal(b []byte) error
type LoadParams_ClosedLoop ¶
type LoadParams_ClosedLoop struct {
ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
}
type LoadParams_Poisson ¶
type LoadParams_Poisson struct {
Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
}
type Mark ¶
type Mark struct {
// if true, the stats will be reset after taking their snapshot.
Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Request current stats
func (*Mark) Descriptor ¶
func (*Mark) ProtoMessage ¶
func (*Mark) ProtoMessage()
func (*Mark) XXX_DiscardUnknown ¶
func (m *Mark) XXX_DiscardUnknown()
func (*Mark) XXX_Unmarshal ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor ¶
func (*Payload) GetType ¶
func (m *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) XXX_DiscardUnknown ¶
func (m *Payload) XXX_DiscardUnknown()
func (*Payload) XXX_Marshal ¶
func (*Payload) XXX_Unmarshal ¶
type PayloadConfig ¶
type PayloadConfig struct {
// Types that are valid to be assigned to Payload:
// *PayloadConfig_BytebufParams
// *PayloadConfig_SimpleParams
// *PayloadConfig_ComplexParams
Payload isPayloadConfig_Payload `protobuf_oneof:"payload"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PayloadConfig) Descriptor ¶
func (*PayloadConfig) Descriptor() ([]byte, []int)
func (*PayloadConfig) GetBytebufParams ¶
func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams
func (*PayloadConfig) GetComplexParams ¶
func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams
func (*PayloadConfig) GetPayload ¶
func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
func (*PayloadConfig) GetSimpleParams ¶
func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams
func (*PayloadConfig) ProtoMessage ¶
func (*PayloadConfig) ProtoMessage()
func (*PayloadConfig) Reset ¶
func (m *PayloadConfig) Reset()
func (*PayloadConfig) String ¶
func (m *PayloadConfig) String() string
func (*PayloadConfig) XXX_DiscardUnknown ¶
func (m *PayloadConfig) XXX_DiscardUnknown()
func (*PayloadConfig) XXX_Marshal ¶
func (m *PayloadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PayloadConfig) XXX_Merge ¶
func (m *PayloadConfig) XXX_Merge(src proto.Message)
func (*PayloadConfig) XXX_OneofWrappers ¶
func (*PayloadConfig) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*PayloadConfig) XXX_Size ¶
func (m *PayloadConfig) XXX_Size() int
func (*PayloadConfig) XXX_Unmarshal ¶
func (m *PayloadConfig) XXX_Unmarshal(b []byte) error
type PayloadConfig_BytebufParams ¶
type PayloadConfig_BytebufParams struct {
BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,proto3,oneof"`
}
type PayloadConfig_ComplexParams ¶
type PayloadConfig_ComplexParams struct {
ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,proto3,oneof"`
}
type PayloadConfig_SimpleParams ¶
type PayloadConfig_SimpleParams struct {
SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,oneof"`
}
type PayloadType ¶
type PayloadType int32
The type of payload that should be returned.
const ( // Compressable text format. PayloadType_COMPRESSABLE PayloadType = 0 )
func (PayloadType) EnumDescriptor ¶
func (PayloadType) EnumDescriptor() ([]byte, []int)
func (PayloadType) String ¶
func (x PayloadType) String() string
type PoissonParams ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.
func (*PoissonParams) Descriptor ¶
func (*PoissonParams) Descriptor() ([]byte, []int)
func (*PoissonParams) GetOfferedLoad ¶
func (m *PoissonParams) GetOfferedLoad() float64
func (*PoissonParams) ProtoMessage ¶
func (*PoissonParams) ProtoMessage()
func (*PoissonParams) Reset ¶
func (m *PoissonParams) Reset()
func (*PoissonParams) String ¶
func (m *PoissonParams) String() string
func (*PoissonParams) XXX_DiscardUnknown ¶
func (m *PoissonParams) XXX_DiscardUnknown()
func (*PoissonParams) XXX_Marshal ¶
func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PoissonParams) XXX_Merge ¶
func (m *PoissonParams) XXX_Merge(src proto.Message)
func (*PoissonParams) XXX_Size ¶
func (m *PoissonParams) XXX_Size() int
func (*PoissonParams) XXX_Unmarshal ¶
func (m *PoissonParams) XXX_Unmarshal(b []byte) error
type ReconnectInfo ¶
type ReconnectInfo struct {
Passed bool `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.
func (*ReconnectInfo) Descriptor ¶
func (*ReconnectInfo) Descriptor() ([]byte, []int)
func (*ReconnectInfo) GetBackoffMs ¶
func (m *ReconnectInfo) GetBackoffMs() []int32
func (*ReconnectInfo) GetPassed ¶
func (m *ReconnectInfo) GetPassed() bool
func (*ReconnectInfo) ProtoMessage ¶
func (*ReconnectInfo) ProtoMessage()
func (*ReconnectInfo) Reset ¶
func (m *ReconnectInfo) Reset()
func (*ReconnectInfo) String ¶
func (m *ReconnectInfo) String() string
func (*ReconnectInfo) XXX_DiscardUnknown ¶
func (m *ReconnectInfo) XXX_DiscardUnknown()
func (*ReconnectInfo) XXX_Marshal ¶
func (m *ReconnectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReconnectInfo) XXX_Merge ¶
func (m *ReconnectInfo) XXX_Merge(src proto.Message)
func (*ReconnectInfo) XXX_Size ¶
func (m *ReconnectInfo) XXX_Size() int
func (*ReconnectInfo) XXX_Unmarshal ¶
func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error
type ReconnectParams ¶
type ReconnectParams struct {
MaxReconnectBackoffMs int32 `` /* 129-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
For reconnect interop test only. Client tells server what reconnection parameters it used.
func (*ReconnectParams) Descriptor ¶
func (*ReconnectParams) Descriptor() ([]byte, []int)
func (*ReconnectParams) GetMaxReconnectBackoffMs ¶
func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32
func (*ReconnectParams) ProtoMessage ¶
func (*ReconnectParams) ProtoMessage()
func (*ReconnectParams) Reset ¶
func (m *ReconnectParams) Reset()
func (*ReconnectParams) String ¶
func (m *ReconnectParams) String() string
func (*ReconnectParams) XXX_DiscardUnknown ¶
func (m *ReconnectParams) XXX_DiscardUnknown()
func (*ReconnectParams) XXX_Marshal ¶
func (m *ReconnectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReconnectParams) XXX_Merge ¶
func (m *ReconnectParams) XXX_Merge(src proto.Message)
func (*ReconnectParams) XXX_Size ¶
func (m *ReconnectParams) XXX_Size() int
func (*ReconnectParams) XXX_Unmarshal ¶
func (m *ReconnectParams) XXX_Unmarshal(b []byte) error
type ReportQpsScenarioServiceClient ¶
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewReportQpsScenarioServiceClient ¶
func NewReportQpsScenarioServiceClient(cc grpc.ClientConnInterface) ReportQpsScenarioServiceClient
type ReportQpsScenarioServiceServer ¶
type ReportQpsScenarioServiceServer interface {
// Report results of a QPS test benchmark scenario.
ReportScenario(context.Context, *ScenarioResult) (*Void, error)
}
ReportQpsScenarioServiceServer is the server API for ReportQpsScenarioService service.
type RequestResultCount ¶
type RequestResultCount struct {
StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RequestResultCount) Descriptor ¶
func (*RequestResultCount) Descriptor() ([]byte, []int)
func (*RequestResultCount) GetCount ¶
func (m *RequestResultCount) GetCount() int64
func (*RequestResultCount) GetStatusCode ¶
func (m *RequestResultCount) GetStatusCode() int32
func (*RequestResultCount) ProtoMessage ¶
func (*RequestResultCount) ProtoMessage()
func (*RequestResultCount) Reset ¶
func (m *RequestResultCount) Reset()
func (*RequestResultCount) String ¶
func (m *RequestResultCount) String() string
func (*RequestResultCount) XXX_DiscardUnknown ¶
func (m *RequestResultCount) XXX_DiscardUnknown()
func (*RequestResultCount) XXX_Marshal ¶
func (m *RequestResultCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestResultCount) XXX_Merge ¶
func (m *RequestResultCount) XXX_Merge(src proto.Message)
func (*RequestResultCount) XXX_Size ¶
func (m *RequestResultCount) XXX_Size() int
func (*RequestResultCount) XXX_Unmarshal ¶
func (m *RequestResultCount) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Configuration for a particular response.
func (*ResponseParameters) Descriptor ¶
func (*ResponseParameters) Descriptor() ([]byte, []int)
func (*ResponseParameters) GetCompressed ¶
func (m *ResponseParameters) GetCompressed() *BoolValue
func (*ResponseParameters) GetIntervalUs ¶
func (m *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (m *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) Reset ¶
func (m *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (m *ResponseParameters) String() string
func (*ResponseParameters) XXX_DiscardUnknown ¶
func (m *ResponseParameters) XXX_DiscardUnknown()
func (*ResponseParameters) XXX_Marshal ¶
func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseParameters) XXX_Merge ¶
func (m *ResponseParameters) XXX_Merge(src proto.Message)
func (*ResponseParameters) XXX_Size ¶
func (m *ResponseParameters) XXX_Size() int
func (*ResponseParameters) XXX_Unmarshal ¶
func (m *ResponseParameters) XXX_Unmarshal(b []byte) error
type Scenario ¶
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 */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
A single performance scenario: input to qps_json_driver
func (*Scenario) Descriptor ¶
func (*Scenario) GetBenchmarkSeconds ¶
func (*Scenario) GetClientConfig ¶
func (m *Scenario) GetClientConfig() *ClientConfig
func (*Scenario) GetNumClients ¶
func (*Scenario) GetNumServers ¶
func (*Scenario) GetServerConfig ¶
func (m *Scenario) GetServerConfig() *ServerConfig
func (*Scenario) GetSpawnLocalWorkerCount ¶
func (*Scenario) GetWarmupSeconds ¶
func (*Scenario) ProtoMessage ¶
func (*Scenario) ProtoMessage()
func (*Scenario) XXX_DiscardUnknown ¶
func (m *Scenario) XXX_DiscardUnknown()
func (*Scenario) XXX_Marshal ¶
func (*Scenario) XXX_Unmarshal ¶
type ScenarioResult ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Results of a single benchmark scenario.
func (*ScenarioResult) Descriptor ¶
func (*ScenarioResult) Descriptor() ([]byte, []int)
func (*ScenarioResult) GetClientStats ¶
func (m *ScenarioResult) GetClientStats() []*ClientStats
func (*ScenarioResult) GetClientSuccess ¶
func (m *ScenarioResult) GetClientSuccess() []bool
func (*ScenarioResult) GetLatencies ¶
func (m *ScenarioResult) GetLatencies() *HistogramData
func (*ScenarioResult) GetRequestResults ¶
func (m *ScenarioResult) GetRequestResults() []*RequestResultCount
func (*ScenarioResult) GetScenario ¶
func (m *ScenarioResult) GetScenario() *Scenario
func (*ScenarioResult) GetServerCores ¶
func (m *ScenarioResult) GetServerCores() []int32
func (*ScenarioResult) GetServerStats ¶
func (m *ScenarioResult) GetServerStats() []*ServerStats
func (*ScenarioResult) GetServerSuccess ¶
func (m *ScenarioResult) GetServerSuccess() []bool
func (*ScenarioResult) GetSummary ¶
func (m *ScenarioResult) GetSummary() *ScenarioResultSummary
func (*ScenarioResult) ProtoMessage ¶
func (*ScenarioResult) ProtoMessage()
func (*ScenarioResult) Reset ¶
func (m *ScenarioResult) Reset()
func (*ScenarioResult) String ¶
func (m *ScenarioResult) String() string
func (*ScenarioResult) XXX_DiscardUnknown ¶
func (m *ScenarioResult) XXX_DiscardUnknown()
func (*ScenarioResult) XXX_Marshal ¶
func (m *ScenarioResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScenarioResult) XXX_Merge ¶
func (m *ScenarioResult) XXX_Merge(src proto.Message)
func (*ScenarioResult) XXX_Size ¶
func (m *ScenarioResult) XXX_Size() int
func (*ScenarioResult) XXX_Unmarshal ¶
func (m *ScenarioResult) XXX_Unmarshal(b []byte) error
type ScenarioResultSummary ¶
type ScenarioResultSummary struct {
// Total number of operations per second over all clients.
Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
// QPS per one server core.
QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
// server load based on system_time (0.85 => 85%)
ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
// server load based on user_time (0.85 => 85%)
ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
// client load based on system_time (0.85 => 85%)
ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
// client load based on user_time (0.85 => 85%)
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 */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Basic summary that can be computed from ClientStats and ServerStats once the scenario has finished.
func (*ScenarioResultSummary) Descriptor ¶
func (*ScenarioResultSummary) Descriptor() ([]byte, []int)
func (*ScenarioResultSummary) GetClientPollsPerRequest ¶
func (m *ScenarioResultSummary) GetClientPollsPerRequest() float64
func (*ScenarioResultSummary) GetClientQueriesPerCpuSec ¶
func (m *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetClientSystemTime ¶
func (m *ScenarioResultSummary) GetClientSystemTime() float64
func (*ScenarioResultSummary) GetClientUserTime ¶
func (m *ScenarioResultSummary) GetClientUserTime() float64
func (*ScenarioResultSummary) GetFailedRequestsPerSecond ¶
func (m *ScenarioResultSummary) GetFailedRequestsPerSecond() float64
func (*ScenarioResultSummary) GetLatency_50 ¶
func (m *ScenarioResultSummary) GetLatency_50() float64
func (*ScenarioResultSummary) GetLatency_90 ¶
func (m *ScenarioResultSummary) GetLatency_90() float64
func (*ScenarioResultSummary) GetLatency_95 ¶
func (m *ScenarioResultSummary) GetLatency_95() float64
func (*ScenarioResultSummary) GetLatency_99 ¶
func (m *ScenarioResultSummary) GetLatency_99() float64
func (*ScenarioResultSummary) GetLatency_999 ¶
func (m *ScenarioResultSummary) GetLatency_999() float64
func (*ScenarioResultSummary) GetQps ¶
func (m *ScenarioResultSummary) GetQps() float64
func (*ScenarioResultSummary) GetQpsPerServerCore ¶
func (m *ScenarioResultSummary) GetQpsPerServerCore() float64
func (*ScenarioResultSummary) GetServerCpuUsage ¶
func (m *ScenarioResultSummary) GetServerCpuUsage() float64
func (*ScenarioResultSummary) GetServerPollsPerRequest ¶
func (m *ScenarioResultSummary) GetServerPollsPerRequest() float64
func (*ScenarioResultSummary) GetServerQueriesPerCpuSec ¶
func (m *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64
func (*ScenarioResultSummary) GetServerSystemTime ¶
func (m *ScenarioResultSummary) GetServerSystemTime() float64
func (*ScenarioResultSummary) GetServerUserTime ¶
func (m *ScenarioResultSummary) GetServerUserTime() float64
func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond ¶
func (m *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64
func (*ScenarioResultSummary) ProtoMessage ¶
func (*ScenarioResultSummary) ProtoMessage()
func (*ScenarioResultSummary) Reset ¶
func (m *ScenarioResultSummary) Reset()
func (*ScenarioResultSummary) String ¶
func (m *ScenarioResultSummary) String() string
func (*ScenarioResultSummary) XXX_DiscardUnknown ¶
func (m *ScenarioResultSummary) XXX_DiscardUnknown()
func (*ScenarioResultSummary) XXX_Marshal ¶
func (m *ScenarioResultSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScenarioResultSummary) XXX_Merge ¶
func (m *ScenarioResultSummary) XXX_Merge(src proto.Message)
func (*ScenarioResultSummary) XXX_Size ¶
func (m *ScenarioResultSummary) XXX_Size() int
func (*ScenarioResultSummary) XXX_Unmarshal ¶
func (m *ScenarioResultSummary) XXX_Unmarshal(b []byte) error
type Scenarios ¶
type Scenarios struct {
Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
A set of scenarios to be run with qps_json_driver
func (*Scenarios) Descriptor ¶
func (*Scenarios) GetScenarios ¶
func (*Scenarios) ProtoMessage ¶
func (*Scenarios) ProtoMessage()
func (*Scenarios) XXX_DiscardUnknown ¶
func (m *Scenarios) XXX_DiscardUnknown()
func (*Scenarios) XXX_Marshal ¶
func (*Scenarios) XXX_Unmarshal ¶
type SecurityParams ¶
type SecurityParams struct {
UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
CredType string `protobuf:"bytes,3,opt,name=cred_type,json=credType,proto3" json:"cred_type,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
presence of SecurityParams implies use of TLS
func (*SecurityParams) Descriptor ¶
func (*SecurityParams) Descriptor() ([]byte, []int)
func (*SecurityParams) GetCredType ¶
func (m *SecurityParams) GetCredType() string
func (*SecurityParams) GetServerHostOverride ¶
func (m *SecurityParams) GetServerHostOverride() string
func (*SecurityParams) GetUseTestCa ¶
func (m *SecurityParams) GetUseTestCa() bool
func (*SecurityParams) ProtoMessage ¶
func (*SecurityParams) ProtoMessage()
func (*SecurityParams) Reset ¶
func (m *SecurityParams) Reset()
func (*SecurityParams) String ¶
func (m *SecurityParams) String() string
func (*SecurityParams) XXX_DiscardUnknown ¶
func (m *SecurityParams) XXX_DiscardUnknown()
func (*SecurityParams) XXX_Marshal ¶
func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SecurityParams) XXX_Merge ¶
func (m *SecurityParams) XXX_Merge(src proto.Message)
func (*SecurityParams) XXX_Size ¶
func (m *SecurityParams) XXX_Size() int
func (*SecurityParams) XXX_Unmarshal ¶
func (m *SecurityParams) XXX_Unmarshal(b []byte) error
type ServerArgs ¶
type ServerArgs struct {
// Types that are valid to be assigned to Argtype:
// *ServerArgs_Setup
// *ServerArgs_Mark
Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ServerArgs) Descriptor ¶
func (*ServerArgs) Descriptor() ([]byte, []int)
func (*ServerArgs) GetArgtype ¶
func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
func (*ServerArgs) GetMark ¶
func (m *ServerArgs) GetMark() *Mark
func (*ServerArgs) GetSetup ¶
func (m *ServerArgs) GetSetup() *ServerConfig
func (*ServerArgs) ProtoMessage ¶
func (*ServerArgs) ProtoMessage()
func (*ServerArgs) Reset ¶
func (m *ServerArgs) Reset()
func (*ServerArgs) String ¶
func (m *ServerArgs) String() string
func (*ServerArgs) XXX_DiscardUnknown ¶
func (m *ServerArgs) XXX_DiscardUnknown()
func (*ServerArgs) XXX_Marshal ¶
func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerArgs) XXX_Merge ¶
func (m *ServerArgs) XXX_Merge(src proto.Message)
func (*ServerArgs) XXX_OneofWrappers ¶
func (*ServerArgs) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServerArgs) XXX_Size ¶
func (m *ServerArgs) XXX_Size() int
func (*ServerArgs) XXX_Unmarshal ¶
func (m *ServerArgs) XXX_Unmarshal(b []byte) error
type ServerArgs_Mark ¶
type ServerArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ServerArgs_Setup ¶
type ServerArgs_Setup struct {
Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ServerConfig ¶
type ServerConfig struct {
ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
// Port 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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ServerConfig) Descriptor ¶
func (*ServerConfig) Descriptor() ([]byte, []int)
func (*ServerConfig) GetAsyncServerThreads ¶
func (m *ServerConfig) GetAsyncServerThreads() int32
func (*ServerConfig) GetChannelArgs ¶
func (m *ServerConfig) GetChannelArgs() []*ChannelArg
func (*ServerConfig) GetCoreLimit ¶
func (m *ServerConfig) GetCoreLimit() int32
func (*ServerConfig) GetCoreList ¶
func (m *ServerConfig) GetCoreList() []int32
func (*ServerConfig) GetOtherServerApi ¶
func (m *ServerConfig) GetOtherServerApi() string
func (*ServerConfig) GetPayloadConfig ¶
func (m *ServerConfig) GetPayloadConfig() *PayloadConfig
func (*ServerConfig) GetPort ¶
func (m *ServerConfig) GetPort() int32
func (*ServerConfig) GetResourceQuotaSize ¶
func (m *ServerConfig) GetResourceQuotaSize() int32
func (*ServerConfig) GetSecurityParams ¶
func (m *ServerConfig) GetSecurityParams() *SecurityParams
func (*ServerConfig) GetServerType ¶
func (m *ServerConfig) GetServerType() ServerType
func (*ServerConfig) GetThreadsPerCq ¶
func (m *ServerConfig) GetThreadsPerCq() int32
func (*ServerConfig) ProtoMessage ¶
func (*ServerConfig) ProtoMessage()
func (*ServerConfig) Reset ¶
func (m *ServerConfig) Reset()
func (*ServerConfig) String ¶
func (m *ServerConfig) String() string
func (*ServerConfig) XXX_DiscardUnknown ¶
func (m *ServerConfig) XXX_DiscardUnknown()
func (*ServerConfig) XXX_Marshal ¶
func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerConfig) XXX_Merge ¶
func (m *ServerConfig) XXX_Merge(src proto.Message)
func (*ServerConfig) XXX_Size ¶
func (m *ServerConfig) XXX_Size() int
func (*ServerConfig) XXX_Unmarshal ¶
func (m *ServerConfig) XXX_Unmarshal(b []byte) error
type ServerStats ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ServerStats) Descriptor ¶
func (*ServerStats) Descriptor() ([]byte, []int)
func (*ServerStats) GetCoreStats ¶
func (m *ServerStats) GetCoreStats() *core.Stats
func (*ServerStats) GetCqPollCount ¶
func (m *ServerStats) GetCqPollCount() uint64
func (*ServerStats) GetIdleCpuTime ¶
func (m *ServerStats) GetIdleCpuTime() uint64
func (*ServerStats) GetTimeElapsed ¶
func (m *ServerStats) GetTimeElapsed() float64
func (*ServerStats) GetTimeSystem ¶
func (m *ServerStats) GetTimeSystem() float64
func (*ServerStats) GetTimeUser ¶
func (m *ServerStats) GetTimeUser() float64
func (*ServerStats) GetTotalCpuTime ¶
func (m *ServerStats) GetTotalCpuTime() uint64
func (*ServerStats) ProtoMessage ¶
func (*ServerStats) ProtoMessage()
func (*ServerStats) Reset ¶
func (m *ServerStats) Reset()
func (*ServerStats) String ¶
func (m *ServerStats) String() string
func (*ServerStats) XXX_DiscardUnknown ¶
func (m *ServerStats) XXX_DiscardUnknown()
func (*ServerStats) XXX_Marshal ¶
func (m *ServerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerStats) XXX_Merge ¶
func (m *ServerStats) XXX_Merge(src proto.Message)
func (*ServerStats) XXX_Size ¶
func (m *ServerStats) XXX_Size() int
func (*ServerStats) XXX_Unmarshal ¶
func (m *ServerStats) XXX_Unmarshal(b []byte) error
type ServerStatus ¶
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ServerStatus) Descriptor ¶
func (*ServerStatus) Descriptor() ([]byte, []int)
func (*ServerStatus) GetCores ¶
func (m *ServerStatus) GetCores() int32
func (*ServerStatus) GetPort ¶
func (m *ServerStatus) GetPort() int32
func (*ServerStatus) GetStats ¶
func (m *ServerStatus) GetStats() *ServerStats
func (*ServerStatus) ProtoMessage ¶
func (*ServerStatus) ProtoMessage()
func (*ServerStatus) Reset ¶
func (m *ServerStatus) Reset()
func (*ServerStatus) String ¶
func (m *ServerStatus) String() string
func (*ServerStatus) XXX_DiscardUnknown ¶
func (m *ServerStatus) XXX_DiscardUnknown()
func (*ServerStatus) XXX_Marshal ¶
func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerStatus) XXX_Merge ¶
func (m *ServerStatus) XXX_Merge(src proto.Message)
func (*ServerStatus) XXX_Size ¶
func (m *ServerStatus) XXX_Size() int
func (*ServerStatus) XXX_Unmarshal ¶
func (m *ServerStatus) XXX_Unmarshal(b []byte) error
type ServerType ¶
type ServerType int32
const ( ServerType_SYNC_SERVER ServerType = 0 ServerType_ASYNC_SERVER ServerType = 1 ServerType_ASYNC_GENERIC_SERVER ServerType = 2 ServerType_OTHER_SERVER ServerType = 3 )
func (ServerType) EnumDescriptor ¶
func (ServerType) EnumDescriptor() ([]byte, []int)
func (ServerType) String ¶
func (x ServerType) String() string
type SimpleProtoParams ¶
type SimpleProtoParams struct {
ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SimpleProtoParams) Descriptor ¶
func (*SimpleProtoParams) Descriptor() ([]byte, []int)
func (*SimpleProtoParams) GetReqSize ¶
func (m *SimpleProtoParams) GetReqSize() int32
func (*SimpleProtoParams) GetRespSize ¶
func (m *SimpleProtoParams) GetRespSize() int32
func (*SimpleProtoParams) ProtoMessage ¶
func (*SimpleProtoParams) ProtoMessage()
func (*SimpleProtoParams) Reset ¶
func (m *SimpleProtoParams) Reset()
func (*SimpleProtoParams) String ¶
func (m *SimpleProtoParams) String() string
func (*SimpleProtoParams) XXX_DiscardUnknown ¶
func (m *SimpleProtoParams) XXX_DiscardUnknown()
func (*SimpleProtoParams) XXX_Marshal ¶
func (m *SimpleProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleProtoParams) XXX_Merge ¶
func (m *SimpleProtoParams) XXX_Merge(src proto.Message)
func (*SimpleProtoParams) XXX_Size ¶
func (m *SimpleProtoParams) XXX_Size() int
func (*SimpleProtoParams) XXX_Unmarshal ¶
func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Unary request.
func (*SimpleRequest) Descriptor ¶
func (*SimpleRequest) Descriptor() ([]byte, []int)
func (*SimpleRequest) GetExpectCompressed ¶
func (m *SimpleRequest) GetExpectCompressed() *BoolValue
func (*SimpleRequest) GetFillGrpclbRouteType ¶
func (m *SimpleRequest) GetFillGrpclbRouteType() bool
func (*SimpleRequest) GetFillOauthScope ¶
func (m *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillServerId ¶
func (m *SimpleRequest) GetFillServerId() bool
func (*SimpleRequest) GetFillUsername ¶
func (m *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (m *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompressed ¶
func (m *SimpleRequest) GetResponseCompressed() *BoolValue
func (*SimpleRequest) GetResponseSize ¶
func (m *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶
func (m *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (m *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) Reset ¶
func (m *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (m *SimpleRequest) String() string
func (*SimpleRequest) XXX_DiscardUnknown ¶
func (m *SimpleRequest) XXX_DiscardUnknown()
func (*SimpleRequest) XXX_Marshal ¶
func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleRequest) XXX_Merge ¶
func (m *SimpleRequest) XXX_Merge(src proto.Message)
func (*SimpleRequest) XXX_Size ¶
func (m *SimpleRequest) XXX_Size() int
func (*SimpleRequest) XXX_Unmarshal ¶
func (m *SimpleRequest) XXX_Unmarshal(b []byte) error
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 */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor ¶
func (*SimpleResponse) Descriptor() ([]byte, []int)
func (*SimpleResponse) GetGrpclbRouteType ¶
func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
func (*SimpleResponse) GetOauthScope ¶
func (m *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (m *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetServerId ¶
func (m *SimpleResponse) GetServerId() string
func (*SimpleResponse) GetUsername ¶
func (m *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) Reset ¶
func (m *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (m *SimpleResponse) String() string
func (*SimpleResponse) XXX_DiscardUnknown ¶
func (m *SimpleResponse) XXX_DiscardUnknown()
func (*SimpleResponse) XXX_Marshal ¶
func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleResponse) XXX_Merge ¶
func (m *SimpleResponse) XXX_Merge(src proto.Message)
func (*SimpleResponse) XXX_Size ¶
func (m *SimpleResponse) XXX_Size() int
func (*SimpleResponse) XXX_Unmarshal ¶
func (m *SimpleResponse) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor ¶
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
func (*StreamingInputCallRequest) GetExpectCompressed ¶
func (m *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
func (*StreamingInputCallRequest) GetPayload ¶
func (m *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) Reset ¶
func (m *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (m *StreamingInputCallRequest) String() string
func (*StreamingInputCallRequest) XXX_DiscardUnknown ¶
func (m *StreamingInputCallRequest) XXX_DiscardUnknown()
func (*StreamingInputCallRequest) XXX_Marshal ¶
func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingInputCallRequest) XXX_Merge ¶
func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)
func (*StreamingInputCallRequest) XXX_Size ¶
func (m *StreamingInputCallRequest) XXX_Size() int
func (*StreamingInputCallRequest) XXX_Unmarshal ¶
func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct {
// Aggregated size of payloads received from the client.
AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor ¶
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
func (*StreamingInputCallResponse) GetAggregatedPayloadSize ¶
func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage ¶
func (*StreamingInputCallResponse) ProtoMessage()
func (*StreamingInputCallResponse) Reset ¶
func (m *StreamingInputCallResponse) Reset()
func (*StreamingInputCallResponse) String ¶
func (m *StreamingInputCallResponse) String() string
func (*StreamingInputCallResponse) XXX_DiscardUnknown ¶
func (m *StreamingInputCallResponse) XXX_DiscardUnknown()
func (*StreamingInputCallResponse) XXX_Marshal ¶
func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingInputCallResponse) XXX_Merge ¶
func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)
func (*StreamingInputCallResponse) XXX_Size ¶
func (m *StreamingInputCallResponse) XXX_Size() int
func (*StreamingInputCallResponse) XXX_Unmarshal ¶
func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor ¶
func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
func (*StreamingOutputCallRequest) GetPayload ¶
func (m *StreamingOutputCallRequest) GetPayload() *Payload
func (*StreamingOutputCallRequest) GetResponseParameters ¶
func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶
func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (m *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) Reset ¶
func (m *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (m *StreamingOutputCallRequest) String() string
func (*StreamingOutputCallRequest) XXX_DiscardUnknown ¶
func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()
func (*StreamingOutputCallRequest) XXX_Marshal ¶
func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingOutputCallRequest) XXX_Merge ¶
func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)
func (*StreamingOutputCallRequest) XXX_Size ¶
func (m *StreamingOutputCallRequest) XXX_Size() int
func (*StreamingOutputCallRequest) XXX_Unmarshal ¶
func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct {
// Payload to increase response size.
Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor ¶
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
func (*StreamingOutputCallResponse) GetPayload ¶
func (m *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage ¶
func (*StreamingOutputCallResponse) ProtoMessage()
func (*StreamingOutputCallResponse) Reset ¶
func (m *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (m *StreamingOutputCallResponse) String() string
func (*StreamingOutputCallResponse) XXX_DiscardUnknown ¶
func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()
func (*StreamingOutputCallResponse) XXX_Marshal ¶
func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingOutputCallResponse) XXX_Merge ¶
func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)
func (*StreamingOutputCallResponse) XXX_Size ¶
func (m *StreamingOutputCallResponse) XXX_Size() int
func (*StreamingOutputCallResponse) XXX_Unmarshal ¶
func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error
type UnimplementedBenchmarkServiceServer ¶
type UnimplementedBenchmarkServiceServer struct {
}
UnimplementedBenchmarkServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedBenchmarkServiceServer) StreamingBothWays ¶
func (*UnimplementedBenchmarkServiceServer) StreamingBothWays(srv BenchmarkService_StreamingBothWaysServer) error
func (*UnimplementedBenchmarkServiceServer) StreamingCall ¶
func (*UnimplementedBenchmarkServiceServer) StreamingCall(srv BenchmarkService_StreamingCallServer) error
func (*UnimplementedBenchmarkServiceServer) StreamingFromClient ¶
func (*UnimplementedBenchmarkServiceServer) StreamingFromClient(srv BenchmarkService_StreamingFromClientServer) error
func (*UnimplementedBenchmarkServiceServer) StreamingFromServer ¶
func (*UnimplementedBenchmarkServiceServer) StreamingFromServer(req *SimpleRequest, srv BenchmarkService_StreamingFromServerServer) error
func (*UnimplementedBenchmarkServiceServer) UnaryCall ¶
func (*UnimplementedBenchmarkServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)
type UnimplementedReportQpsScenarioServiceServer ¶
type UnimplementedReportQpsScenarioServiceServer struct {
}
UnimplementedReportQpsScenarioServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedReportQpsScenarioServiceServer) ReportScenario ¶
func (*UnimplementedReportQpsScenarioServiceServer) ReportScenario(ctx context.Context, req *ScenarioResult) (*Void, error)
type UnimplementedWorkerServiceServer ¶
type UnimplementedWorkerServiceServer struct {
}
UnimplementedWorkerServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedWorkerServiceServer) CoreCount ¶
func (*UnimplementedWorkerServiceServer) CoreCount(ctx context.Context, req *CoreRequest) (*CoreResponse, error)
func (*UnimplementedWorkerServiceServer) QuitWorker ¶
func (*UnimplementedWorkerServiceServer) RunClient ¶
func (*UnimplementedWorkerServiceServer) RunClient(srv WorkerService_RunClientServer) error
func (*UnimplementedWorkerServiceServer) RunServer ¶
func (*UnimplementedWorkerServiceServer) RunServer(srv WorkerService_RunServerServer) error
type Void ¶
type Void struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Void) Descriptor ¶
func (*Void) ProtoMessage ¶
func (*Void) ProtoMessage()
func (*Void) XXX_DiscardUnknown ¶
func (m *Void) XXX_DiscardUnknown()
func (*Void) XXX_Unmarshal ¶
type WorkerServiceClient ¶
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) (WorkerService_RunServerClient, 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) (WorkerService_RunClientClient, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWorkerServiceClient ¶
func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
type WorkerServiceServer ¶
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(WorkerService_RunServerServer) 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(WorkerService_RunClientServer) error
// Just return the core count - unary call
CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
// Quit this worker
QuitWorker(context.Context, *Void) (*Void, error)
}
WorkerServiceServer is the server API for WorkerService service.
type WorkerService_RunClientClient ¶
type WorkerService_RunClientClient interface {
Send(*ClientArgs) error
Recv() (*ClientStatus, error)
grpc.ClientStream
}
type WorkerService_RunClientServer ¶
type WorkerService_RunClientServer interface {
Send(*ClientStatus) error
Recv() (*ClientArgs, error)
grpc.ServerStream
}
type WorkerService_RunServerClient ¶
type WorkerService_RunServerClient interface {
Send(*ServerArgs) error
Recv() (*ServerStatus, error)
grpc.ClientStream
}
type WorkerService_RunServerServer ¶
type WorkerService_RunServerServer interface {
Send(*ServerStatus) error
Recv() (*ServerArgs, error)
grpc.ServerStream
}