Documentation ¶
Index ¶
- Variables
- func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
- func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, 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)deprecated
- func (x *ByteBufferParams) GetReqSize() int32
- func (x *ByteBufferParams) GetRespSize() int32
- func (*ByteBufferParams) ProtoMessage()
- func (x *ByteBufferParams) ProtoReflect() protoreflect.Message
- func (x *ByteBufferParams) Reset()
- func (x *ByteBufferParams) String() string
- type ClientArgs
- func (*ClientArgs) Descriptor() ([]byte, []int)deprecated
- func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
- func (x *ClientArgs) GetMark() *Mark
- func (x *ClientArgs) GetSetup() *ClientConfig
- func (*ClientArgs) ProtoMessage()
- func (x *ClientArgs) ProtoReflect() protoreflect.Message
- func (x *ClientArgs) Reset()
- func (x *ClientArgs) String() string
- type ClientArgs_Mark
- type ClientArgs_Setup
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientConfig) GetAsyncClientThreads() int32
- func (x *ClientConfig) GetClientChannels() int32
- func (x *ClientConfig) GetClientType() ClientType
- func (x *ClientConfig) GetCoreLimit() int32
- func (x *ClientConfig) GetCoreList() []int32
- func (x *ClientConfig) GetHistogramParams() *HistogramParams
- func (x *ClientConfig) GetLoadParams() *LoadParams
- func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32
- func (x *ClientConfig) GetPayloadConfig() *PayloadConfig
- func (x *ClientConfig) GetRpcType() RpcType
- func (x *ClientConfig) GetSecurityParams() *SecurityParams
- func (x *ClientConfig) GetServerTargets() []string
- func (*ClientConfig) ProtoMessage()
- func (x *ClientConfig) ProtoReflect() protoreflect.Message
- func (x *ClientConfig) Reset()
- func (x *ClientConfig) String() string
- type ClientStats
- func (*ClientStats) Descriptor() ([]byte, []int)deprecated
- func (x *ClientStats) GetLatencies() *HistogramData
- func (x *ClientStats) GetTimeElapsed() float64
- func (x *ClientStats) GetTimeSystem() float64
- func (x *ClientStats) GetTimeUser() float64
- func (*ClientStats) ProtoMessage()
- func (x *ClientStats) ProtoReflect() protoreflect.Message
- func (x *ClientStats) Reset()
- func (x *ClientStats) String() string
- type ClientStatus
- type ClientType
- type ClosedLoopParams
- type ComplexProtoParams
- type CompressionType
- func (CompressionType) Descriptor() protoreflect.EnumDescriptor
- func (x CompressionType) Enum() *CompressionType
- func (CompressionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CompressionType) Number() protoreflect.EnumNumber
- func (x CompressionType) String() string
- func (CompressionType) Type() protoreflect.EnumType
- type CoreRequest
- type CoreResponse
- type DeterministicParams
- func (*DeterministicParams) Descriptor() ([]byte, []int)deprecated
- func (x *DeterministicParams) GetOfferedLoad() float64
- func (*DeterministicParams) ProtoMessage()
- func (x *DeterministicParams) ProtoReflect() protoreflect.Message
- func (x *DeterministicParams) Reset()
- func (x *DeterministicParams) String() string
- type EchoStatus
- type HistogramData
- func (*HistogramData) Descriptor() ([]byte, []int)deprecated
- func (x *HistogramData) GetBucket() []uint32
- func (x *HistogramData) GetCount() float64
- func (x *HistogramData) GetMaxSeen() float64
- func (x *HistogramData) GetMinSeen() float64
- func (x *HistogramData) GetSum() float64
- func (x *HistogramData) GetSumOfSquares() float64
- func (*HistogramData) ProtoMessage()
- func (x *HistogramData) ProtoReflect() protoreflect.Message
- func (x *HistogramData) Reset()
- func (x *HistogramData) String() string
- type HistogramParams
- func (*HistogramParams) Descriptor() ([]byte, []int)deprecated
- func (x *HistogramParams) GetMaxPossible() float64
- func (x *HistogramParams) GetResolution() float64
- func (*HistogramParams) ProtoMessage()
- func (x *HistogramParams) ProtoReflect() protoreflect.Message
- func (x *HistogramParams) Reset()
- func (x *HistogramParams) String() string
- type LoadParams
- func (*LoadParams) Descriptor() ([]byte, []int)deprecated
- func (x *LoadParams) GetClosedLoop() *ClosedLoopParams
- func (x *LoadParams) GetDeterm() *DeterministicParams
- func (m *LoadParams) GetLoad() isLoadParams_Load
- func (x *LoadParams) GetPareto() *ParetoParams
- func (x *LoadParams) GetPoisson() *PoissonParams
- func (x *LoadParams) GetUniform() *UniformParams
- func (*LoadParams) ProtoMessage()
- func (x *LoadParams) ProtoReflect() protoreflect.Message
- func (x *LoadParams) Reset()
- func (x *LoadParams) String() string
- type LoadParams_ClosedLoop
- type LoadParams_Determ
- type LoadParams_Pareto
- type LoadParams_Poisson
- type LoadParams_Uniform
- type Mark
- type ParetoParams
- func (*ParetoParams) Descriptor() ([]byte, []int)deprecated
- func (x *ParetoParams) GetAlpha() float64
- func (x *ParetoParams) GetInterarrivalBase() float64
- func (*ParetoParams) ProtoMessage()
- func (x *ParetoParams) ProtoReflect() protoreflect.Message
- func (x *ParetoParams) Reset()
- func (x *ParetoParams) String() string
- type Payload
- type PayloadConfig
- func (*PayloadConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams
- func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams
- func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
- func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams
- func (*PayloadConfig) ProtoMessage()
- func (x *PayloadConfig) ProtoReflect() protoreflect.Message
- func (x *PayloadConfig) Reset()
- func (x *PayloadConfig) String() string
- type PayloadConfig_BytebufParams
- type PayloadConfig_ComplexParams
- type PayloadConfig_SimpleParams
- type PayloadType
- func (PayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x PayloadType) Enum() *PayloadType
- func (PayloadType) EnumDescriptor() ([]byte, []int)deprecated
- func (x PayloadType) Number() protoreflect.EnumNumber
- func (x PayloadType) String() string
- func (PayloadType) Type() protoreflect.EnumType
- type PoissonParams
- type ReconnectInfo
- func (*ReconnectInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ReconnectInfo) GetBackoffMs() []int32
- func (x *ReconnectInfo) GetPassed() bool
- func (*ReconnectInfo) ProtoMessage()
- func (x *ReconnectInfo) ProtoReflect() protoreflect.Message
- func (x *ReconnectInfo) Reset()
- func (x *ReconnectInfo) String() string
- type ReconnectParams
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseParameters) GetIntervalUs() int32
- func (x *ResponseParameters) GetSize() int32
- func (*ResponseParameters) ProtoMessage()
- func (x *ResponseParameters) ProtoReflect() protoreflect.Message
- func (x *ResponseParameters) Reset()
- func (x *ResponseParameters) String() string
- type RpcType
- type Scenario
- func (*Scenario) Descriptor() ([]byte, []int)deprecated
- func (x *Scenario) GetBenchmarkSeconds() int32
- func (x *Scenario) GetClientConfig() *ClientConfig
- func (x *Scenario) GetName() string
- func (x *Scenario) GetNumClients() int32
- func (x *Scenario) GetNumServers() int32
- func (x *Scenario) GetServerConfig() *ServerConfig
- func (x *Scenario) GetSpawnLocalWorkerCount() int32
- func (x *Scenario) GetWarmupSeconds() int32
- func (*Scenario) ProtoMessage()
- func (x *Scenario) ProtoReflect() protoreflect.Message
- func (x *Scenario) Reset()
- func (x *Scenario) String() string
- type Scenarios
- type SecurityParams
- func (*SecurityParams) Descriptor() ([]byte, []int)deprecated
- func (x *SecurityParams) GetServerHostOverride() string
- func (x *SecurityParams) GetUseTestCa() bool
- func (*SecurityParams) ProtoMessage()
- func (x *SecurityParams) ProtoReflect() protoreflect.Message
- func (x *SecurityParams) Reset()
- func (x *SecurityParams) String() string
- type ServerArgs
- func (*ServerArgs) Descriptor() ([]byte, []int)deprecated
- func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
- func (x *ServerArgs) GetMark() *Mark
- func (x *ServerArgs) GetSetup() *ServerConfig
- func (*ServerArgs) ProtoMessage()
- func (x *ServerArgs) ProtoReflect() protoreflect.Message
- func (x *ServerArgs) Reset()
- func (x *ServerArgs) String() string
- type ServerArgs_Mark
- type ServerArgs_Setup
- type ServerConfig
- func (*ServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ServerConfig) GetAsyncServerThreads() int32
- func (x *ServerConfig) GetCoreLimit() int32
- func (x *ServerConfig) GetCoreList() []int32
- func (x *ServerConfig) GetPayloadConfig() *PayloadConfig
- func (x *ServerConfig) GetPort() int32
- func (x *ServerConfig) GetSecurityParams() *SecurityParams
- func (x *ServerConfig) GetServerType() ServerType
- func (*ServerConfig) ProtoMessage()
- func (x *ServerConfig) ProtoReflect() protoreflect.Message
- func (x *ServerConfig) Reset()
- func (x *ServerConfig) String() string
- type ServerStats
- func (*ServerStats) Descriptor() ([]byte, []int)deprecated
- func (x *ServerStats) GetTimeElapsed() float64
- func (x *ServerStats) GetTimeSystem() float64
- func (x *ServerStats) GetTimeUser() float64
- func (*ServerStats) ProtoMessage()
- func (x *ServerStats) ProtoReflect() protoreflect.Message
- func (x *ServerStats) Reset()
- func (x *ServerStats) String() string
- type ServerStatus
- func (*ServerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ServerStatus) GetCores() int32
- func (x *ServerStatus) GetPort() int32
- func (x *ServerStatus) GetStats() *ServerStats
- func (*ServerStatus) ProtoMessage()
- func (x *ServerStatus) ProtoReflect() protoreflect.Message
- func (x *ServerStatus) Reset()
- func (x *ServerStatus) String() string
- type ServerType
- type SimpleProtoParams
- func (*SimpleProtoParams) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleProtoParams) GetReqSize() int32
- func (x *SimpleProtoParams) GetRespSize() int32
- func (*SimpleProtoParams) ProtoMessage()
- func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message
- func (x *SimpleProtoParams) Reset()
- func (x *SimpleProtoParams) String() string
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleRequest) GetFillOauthScope() bool
- func (x *SimpleRequest) GetFillUsername() bool
- func (x *SimpleRequest) GetPayload() *Payload
- func (x *SimpleRequest) GetResponseCompression() CompressionType
- func (x *SimpleRequest) GetResponseSize() int32
- func (x *SimpleRequest) GetResponseStatus() *EchoStatus
- func (x *SimpleRequest) GetResponseType() PayloadType
- func (*SimpleRequest) ProtoMessage()
- func (x *SimpleRequest) ProtoReflect() protoreflect.Message
- func (x *SimpleRequest) Reset()
- func (x *SimpleRequest) String() string
- type SimpleResponse
- func (*SimpleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleResponse) GetOauthScope() string
- func (x *SimpleResponse) GetPayload() *Payload
- func (x *SimpleResponse) GetUsername() string
- func (*SimpleResponse) ProtoMessage()
- func (x *SimpleResponse) ProtoReflect() protoreflect.Message
- func (x *SimpleResponse) Reset()
- func (x *SimpleResponse) String() string
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallRequest) GetPayload() *Payload
- func (*StreamingInputCallRequest) ProtoMessage()
- func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallRequest) Reset()
- func (x *StreamingInputCallRequest) String() string
- type StreamingInputCallResponse
- func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
- func (*StreamingInputCallResponse) ProtoMessage()
- func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallResponse) Reset()
- func (x *StreamingInputCallResponse) String() string
- type StreamingOutputCallRequest
- func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallRequest) GetPayload() *Payload
- func (x *StreamingOutputCallRequest) GetResponseCompression() CompressionType
- func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
- func (*StreamingOutputCallRequest) ProtoMessage()
- func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallRequest) Reset()
- func (x *StreamingOutputCallRequest) String() string
- type StreamingOutputCallResponse
- func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallResponse) Reset()
- func (x *StreamingOutputCallResponse) String() string
- type UniformParams
- func (*UniformParams) Descriptor() ([]byte, []int)deprecated
- func (x *UniformParams) GetInterarrivalHi() float64
- func (x *UniformParams) GetInterarrivalLo() float64
- func (*UniformParams) ProtoMessage()
- func (x *UniformParams) ProtoReflect() protoreflect.Message
- func (x *UniformParams) Reset()
- func (x *UniformParams) String() string
- type UnimplementedBenchmarkServiceServer
- func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error
- func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- func (UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall(BenchmarkService_UnconstrainedStreamingCallServer) error
- type UnimplementedWorkerServiceServer
- func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
- func (UnimplementedWorkerServiceServer) QuitWorker(context.Context, *Void) (*Void, error)
- func (UnimplementedWorkerServiceServer) RunClient(WorkerService_RunClientServer) error
- func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error
- type UnsafeBenchmarkServiceServer
- type UnsafeWorkerServiceServer
- type Void
- 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", } ClientType_value = map[string]int32{ "SYNC_CLIENT": 0, "ASYNC_CLIENT": 1, } )
Enum value maps for ClientType.
var ( ServerType_name = map[int32]string{ 0: "SYNC_SERVER", 1: "ASYNC_SERVER", 2: "ASYNC_GENERIC_SERVER", } ServerType_value = map[string]int32{ "SYNC_SERVER": 0, "ASYNC_SERVER": 1, "ASYNC_GENERIC_SERVER": 2, } )
Enum value maps for ServerType.
var ( RpcType_name = map[int32]string{ 0: "UNARY", 1: "STREAMING", } RpcType_value = map[string]int32{ "UNARY": 0, "STREAMING": 1, } )
Enum value maps for RpcType.
var ( PayloadType_name = map[int32]string{ 0: "COMPRESSABLE", 1: "UNCOMPRESSABLE", 2: "RANDOM", } PayloadType_value = map[string]int32{ "COMPRESSABLE": 0, "UNCOMPRESSABLE": 1, "RANDOM": 2, } )
Enum value maps for PayloadType.
var ( CompressionType_name = map[int32]string{ 0: "NONE", 1: "GZIP", 2: "DEFLATE", } CompressionType_value = map[string]int32{ "NONE": 0, "GZIP": 1, "DEFLATE": 2, } )
Enum value maps for CompressionType.
var File_benchmark_grpc_testing_control_proto protoreflect.FileDescriptor
var File_benchmark_grpc_testing_messages_proto protoreflect.FileDescriptor
var File_benchmark_grpc_testing_payloads_proto protoreflect.FileDescriptor
var File_benchmark_grpc_testing_services_proto protoreflect.FileDescriptor
var File_benchmark_grpc_testing_stats_proto protoreflect.FileDescriptor
Functions ¶
func RegisterBenchmarkServiceServer ¶
func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
func RegisterWorkerServiceServer ¶
func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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 // contains filtered or unexported methods }
BenchmarkServiceServer is the server API for BenchmarkService service. All implementations must embed UnimplementedBenchmarkServiceServer for forward compatibility
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"` // contains filtered or unexported fields }
func (*ByteBufferParams) Descriptor
deprecated
func (*ByteBufferParams) Descriptor() ([]byte, []int)
Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.
func (*ByteBufferParams) GetReqSize ¶
func (x *ByteBufferParams) GetReqSize() int32
func (*ByteBufferParams) GetRespSize ¶
func (x *ByteBufferParams) GetRespSize() int32
func (*ByteBufferParams) ProtoMessage ¶
func (*ByteBufferParams) ProtoMessage()
func (*ByteBufferParams) ProtoReflect ¶
func (x *ByteBufferParams) ProtoReflect() protoreflect.Message
func (*ByteBufferParams) Reset ¶
func (x *ByteBufferParams) Reset()
func (*ByteBufferParams) String ¶
func (x *ByteBufferParams) String() string
type ClientArgs ¶
type ClientArgs struct { // Types that are assignable to Argtype: // *ClientArgs_Setup // *ClientArgs_Mark Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"` // contains filtered or unexported fields }
func (*ClientArgs) Descriptor
deprecated
func (*ClientArgs) Descriptor() ([]byte, []int)
Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.
func (*ClientArgs) GetArgtype ¶
func (m *ClientArgs) GetArgtype() isClientArgs_Argtype
func (*ClientArgs) GetMark ¶
func (x *ClientArgs) GetMark() *Mark
func (*ClientArgs) GetSetup ¶
func (x *ClientArgs) GetSetup() *ClientConfig
func (*ClientArgs) ProtoMessage ¶
func (*ClientArgs) ProtoMessage()
func (*ClientArgs) ProtoReflect ¶
func (x *ClientArgs) ProtoReflect() protoreflect.Message
func (*ClientArgs) Reset ¶
func (x *ClientArgs) Reset()
func (*ClientArgs) String ¶
func (x *ClientArgs) String() string
type ClientArgs_Mark ¶
type ClientArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ClientArgs_Setup ¶
type ClientArgs_Setup struct {
Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ClientConfig ¶
type ClientConfig struct { // 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"` // contains filtered or unexported fields }
func (*ClientConfig) Descriptor
deprecated
func (*ClientConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.
func (*ClientConfig) GetAsyncClientThreads ¶
func (x *ClientConfig) GetAsyncClientThreads() int32
func (*ClientConfig) GetClientChannels ¶
func (x *ClientConfig) GetClientChannels() int32
func (*ClientConfig) GetClientType ¶
func (x *ClientConfig) GetClientType() ClientType
func (*ClientConfig) GetCoreLimit ¶
func (x *ClientConfig) GetCoreLimit() int32
func (*ClientConfig) GetCoreList ¶
func (x *ClientConfig) GetCoreList() []int32
func (*ClientConfig) GetHistogramParams ¶
func (x *ClientConfig) GetHistogramParams() *HistogramParams
func (*ClientConfig) GetLoadParams ¶
func (x *ClientConfig) GetLoadParams() *LoadParams
func (*ClientConfig) GetOutstandingRpcsPerChannel ¶
func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32
func (*ClientConfig) GetPayloadConfig ¶
func (x *ClientConfig) GetPayloadConfig() *PayloadConfig
func (*ClientConfig) GetRpcType ¶
func (x *ClientConfig) GetRpcType() RpcType
func (*ClientConfig) GetSecurityParams ¶
func (x *ClientConfig) GetSecurityParams() *SecurityParams
func (*ClientConfig) GetServerTargets ¶
func (x *ClientConfig) GetServerTargets() []string
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) ProtoReflect ¶
func (x *ClientConfig) ProtoReflect() protoreflect.Message
func (*ClientConfig) Reset ¶
func (x *ClientConfig) Reset()
func (*ClientConfig) String ¶
func (x *ClientConfig) String() string
type 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"` // contains filtered or unexported fields }
func (*ClientStats) Descriptor
deprecated
func (*ClientStats) Descriptor() ([]byte, []int)
Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.
func (*ClientStats) GetLatencies ¶
func (x *ClientStats) GetLatencies() *HistogramData
func (*ClientStats) GetTimeElapsed ¶
func (x *ClientStats) GetTimeElapsed() float64
func (*ClientStats) GetTimeSystem ¶
func (x *ClientStats) GetTimeSystem() float64
func (*ClientStats) GetTimeUser ¶
func (x *ClientStats) GetTimeUser() float64
func (*ClientStats) ProtoMessage ¶
func (*ClientStats) ProtoMessage()
func (*ClientStats) ProtoReflect ¶
func (x *ClientStats) ProtoReflect() protoreflect.Message
func (*ClientStats) Reset ¶
func (x *ClientStats) Reset()
func (*ClientStats) String ¶
func (x *ClientStats) String() string
type ClientStatus ¶
type ClientStatus struct { Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // contains filtered or unexported fields }
func (*ClientStatus) Descriptor
deprecated
func (*ClientStatus) Descriptor() ([]byte, []int)
Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.
func (*ClientStatus) GetStats ¶
func (x *ClientStatus) GetStats() *ClientStats
func (*ClientStatus) ProtoMessage ¶
func (*ClientStatus) ProtoMessage()
func (*ClientStatus) ProtoReflect ¶
func (x *ClientStatus) ProtoReflect() protoreflect.Message
func (*ClientStatus) Reset ¶
func (x *ClientStatus) Reset()
func (*ClientStatus) String ¶
func (x *ClientStatus) String() string
type ClientType ¶
type ClientType int32
const ( ClientType_SYNC_CLIENT ClientType = 0 ClientType_ASYNC_CLIENT ClientType = 1 )
func (ClientType) Descriptor ¶
func (ClientType) Descriptor() protoreflect.EnumDescriptor
func (ClientType) Enum ¶
func (x ClientType) Enum() *ClientType
func (ClientType) EnumDescriptor
deprecated
func (ClientType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientType.Descriptor instead.
func (ClientType) Number ¶
func (x ClientType) Number() protoreflect.EnumNumber
func (ClientType) String ¶
func (x ClientType) String() string
func (ClientType) Type ¶
func (ClientType) Type() protoreflect.EnumType
type ClosedLoopParams ¶
type ClosedLoopParams struct {
// contains filtered or unexported fields
}
Once an RPC finishes, immediately start a new one. No configuration parameters needed.
func (*ClosedLoopParams) Descriptor
deprecated
func (*ClosedLoopParams) Descriptor() ([]byte, []int)
Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.
func (*ClosedLoopParams) ProtoMessage ¶
func (*ClosedLoopParams) ProtoMessage()
func (*ClosedLoopParams) ProtoReflect ¶
func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message
func (*ClosedLoopParams) Reset ¶
func (x *ClosedLoopParams) Reset()
func (*ClosedLoopParams) String ¶
func (x *ClosedLoopParams) String() string
type ComplexProtoParams ¶
type ComplexProtoParams struct {
// contains filtered or unexported fields
}
func (*ComplexProtoParams) Descriptor
deprecated
func (*ComplexProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.
func (*ComplexProtoParams) ProtoMessage ¶
func (*ComplexProtoParams) ProtoMessage()
func (*ComplexProtoParams) ProtoReflect ¶
func (x *ComplexProtoParams) ProtoReflect() protoreflect.Message
func (*ComplexProtoParams) Reset ¶
func (x *ComplexProtoParams) Reset()
func (*ComplexProtoParams) String ¶
func (x *ComplexProtoParams) String() string
type CompressionType ¶
type CompressionType int32
Compression algorithms
const ( // No compression CompressionType_NONE CompressionType = 0 CompressionType_GZIP CompressionType = 1 CompressionType_DEFLATE CompressionType = 2 )
func (CompressionType) Descriptor ¶
func (CompressionType) Descriptor() protoreflect.EnumDescriptor
func (CompressionType) Enum ¶
func (x CompressionType) Enum() *CompressionType
func (CompressionType) EnumDescriptor
deprecated
func (CompressionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CompressionType.Descriptor instead.
func (CompressionType) Number ¶
func (x CompressionType) Number() protoreflect.EnumNumber
func (CompressionType) String ¶
func (x CompressionType) String() string
func (CompressionType) Type ¶
func (CompressionType) Type() protoreflect.EnumType
type CoreRequest ¶
type CoreRequest struct {
// contains filtered or unexported fields
}
func (*CoreRequest) Descriptor
deprecated
func (*CoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.
func (*CoreRequest) ProtoMessage ¶
func (*CoreRequest) ProtoMessage()
func (*CoreRequest) ProtoReflect ¶
func (x *CoreRequest) ProtoReflect() protoreflect.Message
func (*CoreRequest) Reset ¶
func (x *CoreRequest) Reset()
func (*CoreRequest) String ¶
func (x *CoreRequest) String() string
type CoreResponse ¶
type CoreResponse struct { // Number of cores available on the server Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*CoreResponse) Descriptor
deprecated
func (*CoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.
func (*CoreResponse) GetCores ¶
func (x *CoreResponse) GetCores() int32
func (*CoreResponse) ProtoMessage ¶
func (*CoreResponse) ProtoMessage()
func (*CoreResponse) ProtoReflect ¶
func (x *CoreResponse) ProtoReflect() protoreflect.Message
func (*CoreResponse) Reset ¶
func (x *CoreResponse) Reset()
func (*CoreResponse) String ¶
func (x *CoreResponse) String() string
type DeterministicParams ¶
type DeterministicParams struct { OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` // contains filtered or unexported fields }
func (*DeterministicParams) Descriptor
deprecated
func (*DeterministicParams) Descriptor() ([]byte, []int)
Deprecated: Use DeterministicParams.ProtoReflect.Descriptor instead.
func (*DeterministicParams) GetOfferedLoad ¶
func (x *DeterministicParams) GetOfferedLoad() float64
func (*DeterministicParams) ProtoMessage ¶
func (*DeterministicParams) ProtoMessage()
func (*DeterministicParams) ProtoReflect ¶
func (x *DeterministicParams) ProtoReflect() protoreflect.Message
func (*DeterministicParams) Reset ¶
func (x *DeterministicParams) Reset()
func (*DeterministicParams) String ¶
func (x *DeterministicParams) String() string
type EchoStatus ¶
type EchoStatus struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.
func (*EchoStatus) Descriptor
deprecated
func (*EchoStatus) Descriptor() ([]byte, []int)
Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.
func (*EchoStatus) GetCode ¶
func (x *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶
func (x *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) ProtoReflect ¶
func (x *EchoStatus) ProtoReflect() protoreflect.Message
func (*EchoStatus) Reset ¶
func (x *EchoStatus) Reset()
func (*EchoStatus) String ¶
func (x *EchoStatus) String() string
type HistogramData ¶
type HistogramData struct { Bucket []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"` MinSeen float64 `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"` MaxSeen float64 `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"` Sum float64 `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"` SumOfSquares float64 `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"` Count float64 `protobuf:"fixed64,6,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
Histogram data based on grpc/support/histogram.c
func (*HistogramData) Descriptor
deprecated
func (*HistogramData) Descriptor() ([]byte, []int)
Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.
func (*HistogramData) GetBucket ¶
func (x *HistogramData) GetBucket() []uint32
func (*HistogramData) GetCount ¶
func (x *HistogramData) GetCount() float64
func (*HistogramData) GetMaxSeen ¶
func (x *HistogramData) GetMaxSeen() float64
func (*HistogramData) GetMinSeen ¶
func (x *HistogramData) GetMinSeen() float64
func (*HistogramData) GetSum ¶
func (x *HistogramData) GetSum() float64
func (*HistogramData) GetSumOfSquares ¶
func (x *HistogramData) GetSumOfSquares() float64
func (*HistogramData) ProtoMessage ¶
func (*HistogramData) ProtoMessage()
func (*HistogramData) ProtoReflect ¶
func (x *HistogramData) ProtoReflect() protoreflect.Message
func (*HistogramData) Reset ¶
func (x *HistogramData) Reset()
func (*HistogramData) String ¶
func (x *HistogramData) String() string
type HistogramParams ¶
type HistogramParams struct { Resolution float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"` // first bucket is [0, 1 + resolution) MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"` // use enough buckets to allow this value // contains filtered or unexported fields }
Histogram params based on grpc/support/histogram.c
func (*HistogramParams) Descriptor
deprecated
func (*HistogramParams) Descriptor() ([]byte, []int)
Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.
func (*HistogramParams) GetMaxPossible ¶
func (x *HistogramParams) GetMaxPossible() float64
func (*HistogramParams) GetResolution ¶
func (x *HistogramParams) GetResolution() float64
func (*HistogramParams) ProtoMessage ¶
func (*HistogramParams) ProtoMessage()
func (*HistogramParams) ProtoReflect ¶
func (x *HistogramParams) ProtoReflect() protoreflect.Message
func (*HistogramParams) Reset ¶
func (x *HistogramParams) Reset()
func (*HistogramParams) String ¶
func (x *HistogramParams) String() string
type LoadParams ¶
type LoadParams struct { // Types that are assignable to Load: // *LoadParams_ClosedLoop // *LoadParams_Poisson // *LoadParams_Uniform // *LoadParams_Determ // *LoadParams_Pareto Load isLoadParams_Load `protobuf_oneof:"load"` // contains filtered or unexported fields }
func (*LoadParams) Descriptor
deprecated
func (*LoadParams) Descriptor() ([]byte, []int)
Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.
func (*LoadParams) GetClosedLoop ¶
func (x *LoadParams) GetClosedLoop() *ClosedLoopParams
func (*LoadParams) GetDeterm ¶
func (x *LoadParams) GetDeterm() *DeterministicParams
func (*LoadParams) GetLoad ¶
func (m *LoadParams) GetLoad() isLoadParams_Load
func (*LoadParams) GetPareto ¶
func (x *LoadParams) GetPareto() *ParetoParams
func (*LoadParams) GetPoisson ¶
func (x *LoadParams) GetPoisson() *PoissonParams
func (*LoadParams) GetUniform ¶
func (x *LoadParams) GetUniform() *UniformParams
func (*LoadParams) ProtoMessage ¶
func (*LoadParams) ProtoMessage()
func (*LoadParams) ProtoReflect ¶
func (x *LoadParams) ProtoReflect() protoreflect.Message
func (*LoadParams) Reset ¶
func (x *LoadParams) Reset()
func (*LoadParams) String ¶
func (x *LoadParams) String() string
type LoadParams_ClosedLoop ¶
type LoadParams_ClosedLoop struct {
ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
}
type LoadParams_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"` // contains filtered or unexported fields }
Request current stats
func (*Mark) Descriptor
deprecated
func (*Mark) ProtoMessage ¶
func (*Mark) ProtoMessage()
func (*Mark) ProtoReflect ¶
func (x *Mark) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
func (*ParetoParams) Descriptor
deprecated
func (*ParetoParams) Descriptor() ([]byte, []int)
Deprecated: Use ParetoParams.ProtoReflect.Descriptor instead.
func (*ParetoParams) GetAlpha ¶
func (x *ParetoParams) GetAlpha() float64
func (*ParetoParams) GetInterarrivalBase ¶
func (x *ParetoParams) GetInterarrivalBase() float64
func (*ParetoParams) ProtoMessage ¶
func (*ParetoParams) ProtoMessage()
func (*ParetoParams) ProtoReflect ¶
func (x *ParetoParams) ProtoReflect() protoreflect.Message
func (*ParetoParams) Reset ¶
func (x *ParetoParams) Reset()
func (*ParetoParams) String ¶
func (x *ParetoParams) String() string
type Payload ¶
type Payload struct { // The type of data in body. Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"` // Primary contents of payload. Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor
deprecated
func (*Payload) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type PayloadConfig ¶
type PayloadConfig struct { // Types that are assignable to Payload: // *PayloadConfig_BytebufParams // *PayloadConfig_SimpleParams // *PayloadConfig_ComplexParams Payload isPayloadConfig_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*PayloadConfig) Descriptor
deprecated
func (*PayloadConfig) Descriptor() ([]byte, []int)
Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.
func (*PayloadConfig) GetBytebufParams ¶
func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams
func (*PayloadConfig) GetComplexParams ¶
func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams
func (*PayloadConfig) GetPayload ¶
func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload
func (*PayloadConfig) GetSimpleParams ¶
func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams
func (*PayloadConfig) ProtoMessage ¶
func (*PayloadConfig) ProtoMessage()
func (*PayloadConfig) ProtoReflect ¶
func (x *PayloadConfig) ProtoReflect() protoreflect.Message
func (*PayloadConfig) Reset ¶
func (x *PayloadConfig) Reset()
func (*PayloadConfig) String ¶
func (x *PayloadConfig) String() string
type PayloadConfig_BytebufParams ¶
type PayloadConfig_BytebufParams struct {
BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,proto3,oneof"`
}
type PayloadConfig_ComplexParams ¶
type PayloadConfig_ComplexParams struct {
ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,proto3,oneof"`
}
type PayloadConfig_SimpleParams ¶
type PayloadConfig_SimpleParams struct {
SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,oneof"`
}
type PayloadType ¶
type PayloadType int32
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) Descriptor ¶
func (PayloadType) Descriptor() protoreflect.EnumDescriptor
func (PayloadType) Enum ¶
func (x PayloadType) Enum() *PayloadType
func (PayloadType) EnumDescriptor
deprecated
func (PayloadType) EnumDescriptor() ([]byte, []int)
Deprecated: Use PayloadType.Descriptor instead.
func (PayloadType) Number ¶
func (x PayloadType) Number() protoreflect.EnumNumber
func (PayloadType) String ¶
func (x PayloadType) String() string
func (PayloadType) Type ¶
func (PayloadType) Type() protoreflect.EnumType
type PoissonParams ¶
type PoissonParams struct { // The rate of arrivals (a.k.a. lambda parameter of the exp distribution). OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"` // contains filtered or unexported fields }
Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.
func (*PoissonParams) Descriptor
deprecated
func (*PoissonParams) Descriptor() ([]byte, []int)
Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.
func (*PoissonParams) GetOfferedLoad ¶
func (x *PoissonParams) GetOfferedLoad() float64
func (*PoissonParams) ProtoMessage ¶
func (*PoissonParams) ProtoMessage()
func (*PoissonParams) ProtoReflect ¶
func (x *PoissonParams) ProtoReflect() protoreflect.Message
func (*PoissonParams) Reset ¶
func (x *PoissonParams) Reset()
func (*PoissonParams) String ¶
func (x *PoissonParams) String() string
type ReconnectInfo ¶
type ReconnectInfo struct { Passed bool `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"` BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"` // contains filtered or unexported fields }
For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.
func (*ReconnectInfo) Descriptor
deprecated
func (*ReconnectInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.
func (*ReconnectInfo) GetBackoffMs ¶
func (x *ReconnectInfo) GetBackoffMs() []int32
func (*ReconnectInfo) GetPassed ¶
func (x *ReconnectInfo) GetPassed() bool
func (*ReconnectInfo) ProtoMessage ¶
func (*ReconnectInfo) ProtoMessage()
func (*ReconnectInfo) ProtoReflect ¶
func (x *ReconnectInfo) ProtoReflect() protoreflect.Message
func (*ReconnectInfo) Reset ¶
func (x *ReconnectInfo) Reset()
func (*ReconnectInfo) String ¶
func (x *ReconnectInfo) String() string
type ReconnectParams ¶
type ReconnectParams struct { MaxReconnectBackoffMs int32 `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
For reconnect interop test only. Client tells server what reconnection parameters it used.
func (*ReconnectParams) Descriptor
deprecated
func (*ReconnectParams) Descriptor() ([]byte, []int)
Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.
func (*ReconnectParams) GetMaxReconnectBackoffMs ¶
func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32
func (*ReconnectParams) ProtoMessage ¶
func (*ReconnectParams) ProtoMessage()
func (*ReconnectParams) ProtoReflect ¶
func (x *ReconnectParams) ProtoReflect() protoreflect.Message
func (*ReconnectParams) Reset ¶
func (x *ReconnectParams) Reset()
func (*ReconnectParams) String ¶
func (x *ReconnectParams) String() string
type ResponseParameters ¶
type ResponseParameters struct { // Desired payload sizes in responses from the server. // 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"` // contains filtered or unexported fields }
Configuration for a particular response.
func (*ResponseParameters) Descriptor
deprecated
func (*ResponseParameters) Descriptor() ([]byte, []int)
Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.
func (*ResponseParameters) GetIntervalUs ¶
func (x *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (x *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) ProtoReflect ¶
func (x *ResponseParameters) ProtoReflect() protoreflect.Message
func (*ResponseParameters) Reset ¶
func (x *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (x *ResponseParameters) String() string
type RpcType ¶
type RpcType int32
func (RpcType) Descriptor ¶
func (RpcType) Descriptor() protoreflect.EnumDescriptor
func (RpcType) EnumDescriptor
deprecated
func (RpcType) Number ¶
func (x RpcType) Number() protoreflect.EnumNumber
func (RpcType) Type ¶
func (RpcType) Type() protoreflect.EnumType
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 */ // contains filtered or unexported fields }
A single performance scenario: input to qps_json_driver
func (*Scenario) Descriptor
deprecated
func (*Scenario) GetBenchmarkSeconds ¶
func (*Scenario) GetClientConfig ¶
func (x *Scenario) GetClientConfig() *ClientConfig
func (*Scenario) GetNumClients ¶
func (*Scenario) GetNumServers ¶
func (*Scenario) GetServerConfig ¶
func (x *Scenario) GetServerConfig() *ServerConfig
func (*Scenario) GetSpawnLocalWorkerCount ¶
func (*Scenario) GetWarmupSeconds ¶
func (*Scenario) ProtoMessage ¶
func (*Scenario) ProtoMessage()
func (*Scenario) ProtoReflect ¶
func (x *Scenario) ProtoReflect() protoreflect.Message
type Scenarios ¶
type Scenarios struct { Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"` // contains filtered or unexported fields }
A set of scenarios to be run with qps_json_driver
func (*Scenarios) Descriptor
deprecated
func (*Scenarios) GetScenarios ¶
func (*Scenarios) ProtoMessage ¶
func (*Scenarios) ProtoMessage()
func (*Scenarios) ProtoReflect ¶
func (x *Scenarios) ProtoReflect() protoreflect.Message
type SecurityParams ¶
type SecurityParams struct { UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"` ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"` // contains filtered or unexported fields }
presence of SecurityParams implies use of TLS
func (*SecurityParams) Descriptor
deprecated
func (*SecurityParams) Descriptor() ([]byte, []int)
Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.
func (*SecurityParams) GetServerHostOverride ¶
func (x *SecurityParams) GetServerHostOverride() string
func (*SecurityParams) GetUseTestCa ¶
func (x *SecurityParams) GetUseTestCa() bool
func (*SecurityParams) ProtoMessage ¶
func (*SecurityParams) ProtoMessage()
func (*SecurityParams) ProtoReflect ¶
func (x *SecurityParams) ProtoReflect() protoreflect.Message
func (*SecurityParams) Reset ¶
func (x *SecurityParams) Reset()
func (*SecurityParams) String ¶
func (x *SecurityParams) String() string
type ServerArgs ¶
type ServerArgs struct { // Types that are assignable to Argtype: // *ServerArgs_Setup // *ServerArgs_Mark Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"` // contains filtered or unexported fields }
func (*ServerArgs) Descriptor
deprecated
func (*ServerArgs) Descriptor() ([]byte, []int)
Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.
func (*ServerArgs) GetArgtype ¶
func (m *ServerArgs) GetArgtype() isServerArgs_Argtype
func (*ServerArgs) GetMark ¶
func (x *ServerArgs) GetMark() *Mark
func (*ServerArgs) GetSetup ¶
func (x *ServerArgs) GetSetup() *ServerConfig
func (*ServerArgs) ProtoMessage ¶
func (*ServerArgs) ProtoMessage()
func (*ServerArgs) ProtoReflect ¶
func (x *ServerArgs) ProtoReflect() protoreflect.Message
func (*ServerArgs) Reset ¶
func (x *ServerArgs) Reset()
func (*ServerArgs) String ¶
func (x *ServerArgs) String() string
type ServerArgs_Mark ¶
type ServerArgs_Mark struct {
Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}
type ServerArgs_Setup ¶
type ServerArgs_Setup struct {
Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}
type ServerConfig ¶
type ServerConfig struct { ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"` SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"` // Port 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"` // contains filtered or unexported fields }
func (*ServerConfig) Descriptor
deprecated
func (*ServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.
func (*ServerConfig) GetAsyncServerThreads ¶
func (x *ServerConfig) GetAsyncServerThreads() int32
func (*ServerConfig) GetCoreLimit ¶
func (x *ServerConfig) GetCoreLimit() int32
func (*ServerConfig) GetCoreList ¶
func (x *ServerConfig) GetCoreList() []int32
func (*ServerConfig) GetPayloadConfig ¶
func (x *ServerConfig) GetPayloadConfig() *PayloadConfig
func (*ServerConfig) GetPort ¶
func (x *ServerConfig) GetPort() int32
func (*ServerConfig) GetSecurityParams ¶
func (x *ServerConfig) GetSecurityParams() *SecurityParams
func (*ServerConfig) GetServerType ¶
func (x *ServerConfig) GetServerType() ServerType
func (*ServerConfig) ProtoMessage ¶
func (*ServerConfig) ProtoMessage()
func (*ServerConfig) ProtoReflect ¶
func (x *ServerConfig) ProtoReflect() protoreflect.Message
func (*ServerConfig) Reset ¶
func (x *ServerConfig) Reset()
func (*ServerConfig) String ¶
func (x *ServerConfig) String() string
type ServerStats ¶
type ServerStats struct { // 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"` // contains filtered or unexported fields }
func (*ServerStats) Descriptor
deprecated
func (*ServerStats) Descriptor() ([]byte, []int)
Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.
func (*ServerStats) GetTimeElapsed ¶
func (x *ServerStats) GetTimeElapsed() float64
func (*ServerStats) GetTimeSystem ¶
func (x *ServerStats) GetTimeSystem() float64
func (*ServerStats) GetTimeUser ¶
func (x *ServerStats) GetTimeUser() float64
func (*ServerStats) ProtoMessage ¶
func (*ServerStats) ProtoMessage()
func (*ServerStats) ProtoReflect ¶
func (x *ServerStats) ProtoReflect() protoreflect.Message
func (*ServerStats) Reset ¶
func (x *ServerStats) Reset()
func (*ServerStats) String ¶
func (x *ServerStats) String() string
type ServerStatus ¶
type ServerStatus struct { Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // the port bound by the server Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Number of cores available to the server Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` // contains filtered or unexported fields }
func (*ServerStatus) Descriptor
deprecated
func (*ServerStatus) Descriptor() ([]byte, []int)
Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.
func (*ServerStatus) GetCores ¶
func (x *ServerStatus) GetCores() int32
func (*ServerStatus) GetPort ¶
func (x *ServerStatus) GetPort() int32
func (*ServerStatus) GetStats ¶
func (x *ServerStatus) GetStats() *ServerStats
func (*ServerStatus) ProtoMessage ¶
func (*ServerStatus) ProtoMessage()
func (*ServerStatus) ProtoReflect ¶
func (x *ServerStatus) ProtoReflect() protoreflect.Message
func (*ServerStatus) Reset ¶
func (x *ServerStatus) Reset()
func (*ServerStatus) String ¶
func (x *ServerStatus) String() string
type ServerType ¶
type ServerType int32
const ( ServerType_SYNC_SERVER ServerType = 0 ServerType_ASYNC_SERVER ServerType = 1 ServerType_ASYNC_GENERIC_SERVER ServerType = 2 )
func (ServerType) Descriptor ¶
func (ServerType) Descriptor() protoreflect.EnumDescriptor
func (ServerType) Enum ¶
func (x ServerType) Enum() *ServerType
func (ServerType) EnumDescriptor
deprecated
func (ServerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServerType.Descriptor instead.
func (ServerType) Number ¶
func (x ServerType) Number() protoreflect.EnumNumber
func (ServerType) String ¶
func (x ServerType) String() string
func (ServerType) Type ¶
func (ServerType) Type() protoreflect.EnumType
type SimpleProtoParams ¶
type SimpleProtoParams struct { ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"` // contains filtered or unexported fields }
func (*SimpleProtoParams) Descriptor
deprecated
func (*SimpleProtoParams) Descriptor() ([]byte, []int)
Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.
func (*SimpleProtoParams) GetReqSize ¶
func (x *SimpleProtoParams) GetReqSize() int32
func (*SimpleProtoParams) GetRespSize ¶
func (x *SimpleProtoParams) GetRespSize() int32
func (*SimpleProtoParams) ProtoMessage ¶
func (*SimpleProtoParams) ProtoMessage()
func (*SimpleProtoParams) ProtoReflect ¶
func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message
func (*SimpleProtoParams) Reset ¶
func (x *SimpleProtoParams) Reset()
func (*SimpleProtoParams) String ¶
func (x *SimpleProtoParams) String() string
type SimpleRequest ¶
type SimpleRequest struct { // 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"` // contains filtered or unexported fields }
Unary request.
func (*SimpleRequest) Descriptor
deprecated
func (*SimpleRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.
func (*SimpleRequest) GetFillOauthScope ¶
func (x *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillUsername ¶
func (x *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (x *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompression ¶
func (x *SimpleRequest) GetResponseCompression() CompressionType
func (*SimpleRequest) GetResponseSize ¶
func (x *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶
func (x *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (x *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) ProtoReflect ¶
func (x *SimpleRequest) ProtoReflect() protoreflect.Message
func (*SimpleRequest) Reset ¶
func (x *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (x *SimpleRequest) String() string
type SimpleResponse ¶
type SimpleResponse struct { // Payload to increase message size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // The user the request came from, for verifying authentication was // successful when the client expected it. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` // OAuth scope. OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"` // contains filtered or unexported fields }
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor
deprecated
func (*SimpleResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.
func (*SimpleResponse) GetOauthScope ¶
func (x *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (x *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetUsername ¶
func (x *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) ProtoReflect ¶
func (x *SimpleResponse) ProtoReflect() protoreflect.Message
func (*SimpleResponse) Reset ¶
func (x *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (x *SimpleResponse) String() string
type StreamingInputCallRequest ¶
type StreamingInputCallRequest struct { // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor
deprecated
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingInputCallRequest) GetPayload ¶
func (x *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) ProtoReflect ¶
func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingInputCallRequest) Reset ¶
func (x *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (x *StreamingInputCallRequest) String() string
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct { // Aggregated size of payloads received from the client. AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor
deprecated
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingInputCallResponse) GetAggregatedPayloadSize ¶
func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage ¶
func (*StreamingInputCallResponse) ProtoMessage()
func (*StreamingInputCallResponse) ProtoReflect ¶
func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingInputCallResponse) Reset ¶
func (x *StreamingInputCallResponse) Reset()
func (*StreamingInputCallResponse) String ¶
func (x *StreamingInputCallResponse) String() string
type StreamingOutputCallRequest ¶
type StreamingOutputCallRequest struct { // Desired payload type in the response from the server. // If response_type is RANDOM, the payload from each response in the stream // might be of different types. This is to simulate a mixed type of payload // stream. ResponseType PayloadType `` /* 128-byte string literal not displayed */ // Configuration for each expected response message. ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"` // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // 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"` // contains filtered or unexported fields }
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor
deprecated
func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallRequest) GetPayload ¶
func (x *StreamingOutputCallRequest) GetPayload() *Payload
func (*StreamingOutputCallRequest) GetResponseCompression ¶
func (x *StreamingOutputCallRequest) GetResponseCompression() CompressionType
func (*StreamingOutputCallRequest) GetResponseParameters ¶
func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶
func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) ProtoReflect ¶
func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallRequest) Reset ¶
func (x *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (x *StreamingOutputCallRequest) String() string
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct { // Payload to increase response size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor
deprecated
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.
func (*StreamingOutputCallResponse) GetPayload ¶
func (x *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage ¶
func (*StreamingOutputCallResponse) ProtoMessage()
func (*StreamingOutputCallResponse) ProtoReflect ¶
func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallResponse) Reset ¶
func (x *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (x *StreamingOutputCallResponse) String() string
type 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"` // contains filtered or unexported fields }
func (*UniformParams) Descriptor
deprecated
func (*UniformParams) Descriptor() ([]byte, []int)
Deprecated: Use UniformParams.ProtoReflect.Descriptor instead.
func (*UniformParams) GetInterarrivalHi ¶
func (x *UniformParams) GetInterarrivalHi() float64
func (*UniformParams) GetInterarrivalLo ¶
func (x *UniformParams) GetInterarrivalLo() float64
func (*UniformParams) ProtoMessage ¶
func (*UniformParams) ProtoMessage()
func (*UniformParams) ProtoReflect ¶
func (x *UniformParams) ProtoReflect() protoreflect.Message
func (*UniformParams) Reset ¶
func (x *UniformParams) Reset()
func (*UniformParams) String ¶
func (x *UniformParams) String() string
type UnimplementedBenchmarkServiceServer ¶
type UnimplementedBenchmarkServiceServer struct { }
UnimplementedBenchmarkServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedBenchmarkServiceServer) StreamingCall ¶
func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error
func (UnimplementedBenchmarkServiceServer) UnaryCall ¶
func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
func (UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall ¶
func (UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall(BenchmarkService_UnconstrainedStreamingCallServer) error
type UnimplementedWorkerServiceServer ¶
type UnimplementedWorkerServiceServer struct { }
UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedWorkerServiceServer) CoreCount ¶
func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
func (UnimplementedWorkerServiceServer) QuitWorker ¶
func (UnimplementedWorkerServiceServer) RunClient ¶
func (UnimplementedWorkerServiceServer) RunClient(WorkerService_RunClientServer) error
func (UnimplementedWorkerServiceServer) RunServer ¶
func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error
type UnsafeBenchmarkServiceServer ¶
type UnsafeBenchmarkServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBenchmarkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BenchmarkServiceServer will result in compilation errors.
type UnsafeWorkerServiceServer ¶
type UnsafeWorkerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.
type Void ¶
type Void struct {
// contains filtered or unexported fields
}
func (*Void) Descriptor
deprecated
func (*Void) ProtoMessage ¶
func (*Void) ProtoMessage()
func (*Void) ProtoReflect ¶
func (x *Void) ProtoReflect() protoreflect.Message
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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) // contains filtered or unexported methods }
WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility
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 }