Documentation ¶
Index ¶
- Variables
- func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)
- func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)
- type BenchmarkServiceClient
- type BenchmarkServiceServer
- type BenchmarkService_StreamingCallClient
- type BenchmarkService_StreamingCallServer
- type BenchmarkService_UnconstrainedStreamingCallClient
- type BenchmarkService_UnconstrainedStreamingCallServer
- 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 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) 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) GetOutstandingRpcsPerChannel() int32
- func (m *ClientConfig) GetPayloadConfig() *PayloadConfig
- func (m *ClientConfig) GetRpcType() RpcType
- func (m *ClientConfig) GetSecurityParams() *SecurityParams
- func (m *ClientConfig) GetServerTargets() []string
- 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) GetLatencies() *HistogramData
- 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 CompressionType
- 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 DeterministicParams
- func (*DeterministicParams) Descriptor() ([]byte, []int)
- func (m *DeterministicParams) GetOfferedLoad() float64
- func (*DeterministicParams) ProtoMessage()
- func (m *DeterministicParams) Reset()
- func (m *DeterministicParams) String() string
- func (m *DeterministicParams) XXX_DiscardUnknown()
- func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeterministicParams) XXX_Merge(src proto.Message)
- func (m *DeterministicParams) XXX_Size() int
- func (m *DeterministicParams) 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 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) GetDeterm() *DeterministicParams
- func (m *LoadParams) GetLoad() isLoadParams_Load
- func (m *LoadParams) GetPareto() *ParetoParams
- func (m *LoadParams) GetPoisson() *PoissonParams
- func (m *LoadParams) GetUniform() *UniformParams
- 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_Determ
- type LoadParams_Pareto
- type LoadParams_Poisson
- type LoadParams_Uniform
- 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 ParetoParams
- func (*ParetoParams) Descriptor() ([]byte, []int)
- func (m *ParetoParams) GetAlpha() float64
- func (m *ParetoParams) GetInterarrivalBase() float64
- func (*ParetoParams) ProtoMessage()
- func (m *ParetoParams) Reset()
- func (m *ParetoParams) String() string
- func (m *ParetoParams) XXX_DiscardUnknown()
- func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ParetoParams) XXX_Merge(src proto.Message)
- func (m *ParetoParams) XXX_Size() int
- func (m *ParetoParams) 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 ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)
- 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 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) 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) GetCoreLimit() int32
- func (m *ServerConfig) GetCoreList() []int32
- func (m *ServerConfig) GetPayloadConfig() *PayloadConfig
- func (m *ServerConfig) GetPort() int32
- func (m *ServerConfig) GetSecurityParams() *SecurityParams
- func (m *ServerConfig) GetServerType() ServerType
- 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) GetTimeElapsed() float64
- func (m *ServerStats) GetTimeSystem() float64
- func (m *ServerStats) GetTimeUser() float64
- 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) GetFillOauthScope() bool
- func (m *SimpleRequest) GetFillUsername() bool
- func (m *SimpleRequest) GetPayload() *Payload
- func (m *SimpleRequest) GetResponseCompression() CompressionType
- 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) GetOauthScope() string
- func (m *SimpleResponse) GetPayload() *Payload
- 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) 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) GetResponseCompression() CompressionType
- 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 UniformParams
- func (*UniformParams) Descriptor() ([]byte, []int)
- func (m *UniformParams) GetInterarrivalHi() float64
- func (m *UniformParams) GetInterarrivalLo() float64
- func (*UniformParams) ProtoMessage()
- func (m *UniformParams) Reset()
- func (m *UniformParams) String() string
- func (m *UniformParams) XXX_DiscardUnknown()
- func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UniformParams) XXX_Merge(src proto.Message)
- func (m *UniformParams) XXX_Size() int
- func (m *UniformParams) XXX_Unmarshal(b []byte) error
- type UnimplementedBenchmarkServiceServer
- func (*UnimplementedBenchmarkServiceServer) StreamingCall(srv BenchmarkService_StreamingCallServer) error
- func (*UnimplementedBenchmarkServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)
- func (*UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall(srv BenchmarkService_UnconstrainedStreamingCallServer) error
- 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 PayloadType_name = map[int32]string{
0: "COMPRESSABLE",
1: "UNCOMPRESSABLE",
2: "RANDOM",
}
var PayloadType_value = map[string]int32{
"COMPRESSABLE": 0,
"UNCOMPRESSABLE": 1,
"RANDOM": 2,
}
Functions ¶
func RegisterBenchmarkServiceServer ¶
func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)
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) // One request followed by one response. // The server returns the client payload as-is. StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error) // Unconstrainted streaming. // Both server and client keep sending & receiving simultaneously. UnconstrainedStreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_UnconstrainedStreamingCallClient, 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/code.aliyun.com/yjkj.ink/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) // One request followed by one response. // The server returns the client payload as-is. StreamingCall(BenchmarkService_StreamingCallServer) error // Unconstrainted streaming. // Both server and client keep sending & receiving simultaneously. UnconstrainedStreamingCall(BenchmarkService_UnconstrainedStreamingCallServer) error }
BenchmarkServiceServer is the server API for BenchmarkService service.
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_UnconstrainedStreamingCallClient ¶
type BenchmarkService_UnconstrainedStreamingCallClient interface { Send(*SimpleRequest) error Recv() (*SimpleResponse, error) grpc.ClientStream }
type BenchmarkService_UnconstrainedStreamingCallServer ¶
type BenchmarkService_UnconstrainedStreamingCallServer interface { Send(*SimpleResponse) error Recv() (*SimpleRequest, error) grpc.ServerStream }
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 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"` 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) 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) 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) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClientStats) Descriptor ¶
func (*ClientStats) Descriptor() ([]byte, []int)
func (*ClientStats) GetLatencies ¶
func (m *ClientStats) GetLatencies() *HistogramData
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 ( ClientType_SYNC_CLIENT ClientType = 0 ClientType_ASYNC_CLIENT ClientType = 1 )
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 CompressionType ¶
type CompressionType int32
Compression algorithms
const ( // No compression CompressionType_NONE CompressionType = 0 CompressionType_GZIP CompressionType = 1 CompressionType_DEFLATE CompressionType = 2 )
func (CompressionType) EnumDescriptor ¶
func (CompressionType) EnumDescriptor() ([]byte, []int)
func (CompressionType) String ¶
func (x CompressionType) String() string
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 DeterministicParams ¶
type DeterministicParams struct { 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:"-"` }
func (*DeterministicParams) Descriptor ¶
func (*DeterministicParams) Descriptor() ([]byte, []int)
func (*DeterministicParams) GetOfferedLoad ¶
func (m *DeterministicParams) GetOfferedLoad() float64
func (*DeterministicParams) ProtoMessage ¶
func (*DeterministicParams) ProtoMessage()
func (*DeterministicParams) Reset ¶
func (m *DeterministicParams) Reset()
func (*DeterministicParams) String ¶
func (m *DeterministicParams) String() string
func (*DeterministicParams) XXX_DiscardUnknown ¶
func (m *DeterministicParams) XXX_DiscardUnknown()
func (*DeterministicParams) XXX_Marshal ¶
func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeterministicParams) XXX_Merge ¶
func (m *DeterministicParams) XXX_Merge(src proto.Message)
func (*DeterministicParams) XXX_Size ¶
func (m *DeterministicParams) XXX_Size() int
func (*DeterministicParams) XXX_Unmarshal ¶
func (m *DeterministicParams) 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 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 // *LoadParams_Uniform // *LoadParams_Determ // *LoadParams_Pareto 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) GetDeterm ¶
func (m *LoadParams) GetDeterm() *DeterministicParams
func (*LoadParams) GetLoad ¶
func (m *LoadParams) GetLoad() isLoadParams_Load
func (*LoadParams) GetPareto ¶
func (m *LoadParams) GetPareto() *ParetoParams
func (*LoadParams) GetPoisson ¶
func (m *LoadParams) GetPoisson() *PoissonParams
func (*LoadParams) GetUniform ¶
func (m *LoadParams) GetUniform() *UniformParams
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_Determ ¶
type LoadParams_Determ struct {
Determ *DeterministicParams `protobuf:"bytes,4,opt,name=determ,proto3,oneof"`
}
type LoadParams_Pareto ¶
type LoadParams_Pareto struct {
Pareto *ParetoParams `protobuf:"bytes,5,opt,name=pareto,proto3,oneof"`
}
type LoadParams_Poisson ¶
type LoadParams_Poisson struct {
Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
}
type LoadParams_Uniform ¶
type LoadParams_Uniform struct {
Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,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
type ParetoParams ¶
type ParetoParams struct { InterarrivalBase float64 `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase,proto3" json:"interarrival_base,omitempty"` Alpha float64 `protobuf:"fixed64,2,opt,name=alpha,proto3" json:"alpha,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ParetoParams) Descriptor ¶
func (*ParetoParams) Descriptor() ([]byte, []int)
func (*ParetoParams) GetAlpha ¶
func (m *ParetoParams) GetAlpha() float64
func (*ParetoParams) GetInterarrivalBase ¶
func (m *ParetoParams) GetInterarrivalBase() float64
func (*ParetoParams) ProtoMessage ¶
func (*ParetoParams) ProtoMessage()
func (*ParetoParams) Reset ¶
func (m *ParetoParams) Reset()
func (*ParetoParams) String ¶
func (m *ParetoParams) String() string
func (*ParetoParams) XXX_DiscardUnknown ¶
func (m *ParetoParams) XXX_DiscardUnknown()
func (*ParetoParams) XXX_Marshal ¶
func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ParetoParams) XXX_Merge ¶
func (m *ParetoParams) XXX_Merge(src proto.Message)
func (*ParetoParams) XXX_Size ¶
func (m *ParetoParams) XXX_Size() int
func (*ParetoParams) XXX_Unmarshal ¶
func (m *ParetoParams) XXX_Unmarshal(b []byte) error
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) GetType ¶
func (m *Payload) GetType() PayloadType
func (*Payload) XXX_Marshal ¶
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 // Uncompressable binary format. PayloadType_UNCOMPRESSABLE PayloadType = 1 // Randomly chosen from all other formats defined in this enum. PayloadType_RANDOM PayloadType = 2 )
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 ResponseParameters ¶
type ResponseParameters struct { // Desired payload sizes in responses from the server. // If response_type is COMPRESSABLE, this denotes the size before compression. 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"` 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) 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) GetClientConfig ¶
func (m *Scenario) GetClientConfig() *ClientConfig
func (*Scenario) GetServerConfig ¶
func (m *Scenario) GetServerConfig() *ServerConfig
func (*Scenario) XXX_Marshal ¶
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) XXX_Marshal ¶
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"` 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) 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 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"` 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) GetCoreLimit ¶
func (m *ServerConfig) GetCoreLimit() int32
func (*ServerConfig) GetCoreList ¶
func (m *ServerConfig) GetCoreList() []int32
func (*ServerConfig) GetPayloadConfig ¶
func (m *ServerConfig) GetPayloadConfig() *PayloadConfig
func (*ServerConfig) GetPort ¶
func (m *ServerConfig) GetPort() int32
func (*ServerConfig) GetSecurityParams ¶
func (m *ServerConfig) GetSecurityParams() *SecurityParams
func (*ServerConfig) GetServerType ¶
func (m *ServerConfig) GetServerType() ServerType
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServerStats) Descriptor ¶
func (*ServerStats) Descriptor() ([]byte, []int)
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) 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 )
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. // If response_type is COMPRESSABLE, this denotes the size before compression. 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"` // Compression algorithm to be used by the server for the response (stream) ResponseCompression CompressionType `` /* 153-byte string literal not displayed */ // 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:"-"` }
Unary request.
func (*SimpleRequest) Descriptor ¶
func (*SimpleRequest) Descriptor() ([]byte, []int)
func (*SimpleRequest) GetFillOauthScope ¶
func (m *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillUsername ¶
func (m *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (m *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompression ¶
func (m *SimpleRequest) GetResponseCompression() CompressionType
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"` 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) GetOauthScope ¶
func (m *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (m *SimpleResponse) GetPayload() *Payload
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"` 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) 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"` // Compression algorithm to be used by the server for the response (stream) ResponseCompression CompressionType `` /* 153-byte string literal not displayed */ // 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) GetResponseCompression ¶
func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType
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 UniformParams ¶
type UniformParams struct { InterarrivalLo float64 `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo,proto3" json:"interarrival_lo,omitempty"` InterarrivalHi float64 `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi,proto3" json:"interarrival_hi,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UniformParams) Descriptor ¶
func (*UniformParams) Descriptor() ([]byte, []int)
func (*UniformParams) GetInterarrivalHi ¶
func (m *UniformParams) GetInterarrivalHi() float64
func (*UniformParams) GetInterarrivalLo ¶
func (m *UniformParams) GetInterarrivalLo() float64
func (*UniformParams) ProtoMessage ¶
func (*UniformParams) ProtoMessage()
func (*UniformParams) Reset ¶
func (m *UniformParams) Reset()
func (*UniformParams) String ¶
func (m *UniformParams) String() string
func (*UniformParams) XXX_DiscardUnknown ¶
func (m *UniformParams) XXX_DiscardUnknown()
func (*UniformParams) XXX_Marshal ¶
func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UniformParams) XXX_Merge ¶
func (m *UniformParams) XXX_Merge(src proto.Message)
func (*UniformParams) XXX_Size ¶
func (m *UniformParams) XXX_Size() int
func (*UniformParams) XXX_Unmarshal ¶
func (m *UniformParams) XXX_Unmarshal(b []byte) error
type UnimplementedBenchmarkServiceServer ¶
type UnimplementedBenchmarkServiceServer struct { }
UnimplementedBenchmarkServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedBenchmarkServiceServer) StreamingCall ¶
func (*UnimplementedBenchmarkServiceServer) StreamingCall(srv BenchmarkService_StreamingCallServer) error
func (*UnimplementedBenchmarkServiceServer) UnaryCall ¶
func (*UnimplementedBenchmarkServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)
func (*UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall ¶
func (*UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall(srv BenchmarkService_UnconstrainedStreamingCallServer) 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 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/code.aliyun.com/yjkj.ink/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 }