import "google.golang.org/grpc/benchmark/grpc_testing"
Package grpc_testing is a generated protocol buffer package.
It is generated from these files:
control.proto messages.proto payloads.proto services.proto stats.proto
It has these top-level messages:
PoissonParams UniformParams DeterministicParams ParetoParams ClosedLoopParams LoadParams SecurityParams ClientConfig ClientStatus Mark ClientArgs ServerConfig ServerArgs ServerStatus CoreRequest CoreResponse Void Scenario Scenarios Payload EchoStatus SimpleRequest SimpleResponse StreamingInputCallRequest StreamingInputCallResponse ResponseParameters StreamingOutputCallRequest StreamingOutputCallResponse ReconnectParams ReconnectInfo ByteBufferParams SimpleProtoParams ComplexProtoParams PayloadConfig ServerStats HistogramParams HistogramData ClientStats
control.pb.go messages.pb.go payloads.pb.go services.pb.go stats.pb.go
var ServerType_name = map[int32]string{ 0: "SYNC_SERVER", 1: "ASYNC_SERVER", 2: "ASYNC_GENERIC_SERVER", }
var ServerType_value = map[string]int32{ "SYNC_SERVER": 0, "ASYNC_SERVER": 1, "ASYNC_GENERIC_SERVER": 2, }
func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)
func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)
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)
}func NewBenchmarkServiceClient(cc *grpc.ClientConn) BenchmarkServiceClient
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
}type BenchmarkService_StreamingCallClient interface {
Send(*SimpleRequest) error
Recv() (*SimpleResponse, error)
grpc.ClientStream
}type BenchmarkService_StreamingCallServer interface {
Send(*SimpleResponse) error
Recv() (*SimpleRequest, error)
grpc.ServerStream
}type ByteBufferParams struct {
ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize" json:"req_size,omitempty"`
RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize" json:"resp_size,omitempty"`
}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
type ClientArgs struct {
// Types that are valid to be assigned to Argtype:
// *ClientArgs_Setup
// *ClientArgs_Mark
Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"`
}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 (*ClientArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type ClientArgs_Setup struct {
Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,oneof"`
}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" json:"server_targets,omitempty"`
ClientType ClientType `protobuf:"varint,2,opt,name=client_type,json=clientType,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams" 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 `protobuf:"varint,4,opt,name=outstanding_rpcs_per_channel,json=outstandingRpcsPerChannel" json:"outstanding_rpcs_per_channel,omitempty"`
// 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" 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" json:"async_client_threads,omitempty"`
RpcType RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,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" json:"load_params,omitempty"`
PayloadConfig *PayloadConfig `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig" json:"payload_config,omitempty"`
HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams" 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" json:"core_list,omitempty"`
CoreLimit int32 `protobuf:"varint,14,opt,name=core_limit,json=coreLimit" json:"core_limit,omitempty"`
}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
type ClientStats struct {
// Latency histogram. Data points are in nanoseconds.
Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies" json:"latencies,omitempty"`
// See ServerStats for details.
TimeElapsed float64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed" json:"time_elapsed,omitempty"`
TimeUser float64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser" json:"time_user,omitempty"`
TimeSystem float64 `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem" json:"time_system,omitempty"`
}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
type ClientStatus struct {
Stats *ClientStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
}func (*ClientStatus) Descriptor() ([]byte, []int)
func (m *ClientStatus) GetStats() *ClientStats
func (*ClientStatus) ProtoMessage()
func (m *ClientStatus) Reset()
func (m *ClientStatus) String() string
const (
ClientType_SYNC_CLIENT ClientType = 0
ClientType_ASYNC_CLIENT ClientType = 1
)func (ClientType) EnumDescriptor() ([]byte, []int)
func (x ClientType) String() string
type ClosedLoopParams struct {
}Once an RPC finishes, immediately start a new one. No configuration parameters needed.
func (*ClosedLoopParams) Descriptor() ([]byte, []int)
func (*ClosedLoopParams) ProtoMessage()
func (m *ClosedLoopParams) Reset()
func (m *ClosedLoopParams) String() string
type ComplexProtoParams struct {
}func (*ComplexProtoParams) Descriptor() ([]byte, []int)
func (*ComplexProtoParams) ProtoMessage()
func (m *ComplexProtoParams) Reset()
func (m *ComplexProtoParams) String() string
Compression algorithms
const (
// No compression
CompressionType_NONE CompressionType = 0
CompressionType_GZIP CompressionType = 1
CompressionType_DEFLATE CompressionType = 2
)func (CompressionType) EnumDescriptor() ([]byte, []int)
func (x CompressionType) String() string
type CoreRequest struct {
}func (*CoreRequest) Descriptor() ([]byte, []int)
func (*CoreRequest) ProtoMessage()
func (m *CoreRequest) Reset()
func (m *CoreRequest) String() string
type CoreResponse struct {
// Number of cores available on the server
Cores int32 `protobuf:"varint,1,opt,name=cores" json:"cores,omitempty"`
}func (*CoreResponse) Descriptor() ([]byte, []int)
func (m *CoreResponse) GetCores() int32
func (*CoreResponse) ProtoMessage()
func (m *CoreResponse) Reset()
func (m *CoreResponse) String() string
type DeterministicParams struct {
OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad" json:"offered_load,omitempty"`
}func (*DeterministicParams) Descriptor() ([]byte, []int)
func (m *DeterministicParams) GetOfferedLoad() float64
func (*DeterministicParams) ProtoMessage()
func (m *DeterministicParams) Reset()
func (m *DeterministicParams) String() string
type EchoStatus struct {
Code int32 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}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() ([]byte, []int)
func (m *EchoStatus) GetCode() int32
func (m *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage()
func (m *EchoStatus) Reset()
func (m *EchoStatus) String() string
type HistogramData struct {
Bucket []uint32 `protobuf:"varint,1,rep,packed,name=bucket" json:"bucket,omitempty"`
MinSeen float64 `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen" json:"min_seen,omitempty"`
MaxSeen float64 `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen" json:"max_seen,omitempty"`
Sum float64 `protobuf:"fixed64,4,opt,name=sum" json:"sum,omitempty"`
SumOfSquares float64 `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares" json:"sum_of_squares,omitempty"`
Count float64 `protobuf:"fixed64,6,opt,name=count" json:"count,omitempty"`
}Histogram data based on grpc/support/histogram.c
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
type HistogramParams struct {
Resolution float64 `protobuf:"fixed64,1,opt,name=resolution" json:"resolution,omitempty"`
MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible" json:"max_possible,omitempty"`
}Histogram params based on grpc/support/histogram.c
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
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"`
}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 (*LoadParams) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type LoadParams_ClosedLoop struct {
ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,oneof"`
}type LoadParams_Determ struct {
Determ *DeterministicParams `protobuf:"bytes,4,opt,name=determ,oneof"`
}type LoadParams_Pareto struct {
Pareto *ParetoParams `protobuf:"bytes,5,opt,name=pareto,oneof"`
}type LoadParams_Poisson struct {
Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,oneof"`
}type LoadParams_Uniform struct {
Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,oneof"`
}type Mark struct {
// if true, the stats will be reset after taking their snapshot.
Reset_ bool `protobuf:"varint,1,opt,name=reset" json:"reset,omitempty"`
}Request current stats
type ParetoParams struct {
InterarrivalBase float64 `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase" json:"interarrival_base,omitempty"`
Alpha float64 `protobuf:"fixed64,2,opt,name=alpha" json:"alpha,omitempty"`
}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
type Payload struct {
// The type of data in body.
Type PayloadType `protobuf:"varint,1,opt,name=type,enum=grpc.testing.PayloadType" json:"type,omitempty"`
// Primary contents of payload.
Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}A block of data, to simply increase gRPC message size.
func (m *Payload) GetType() PayloadType
type PayloadConfig struct {
// Types that are valid to be assigned to Payload:
// *PayloadConfig_BytebufParams
// *PayloadConfig_SimpleParams
// *PayloadConfig_ComplexParams
Payload isPayloadConfig_Payload `protobuf_oneof:"payload"`
}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 (*PayloadConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type PayloadConfig_BytebufParams struct {
BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,oneof"`
}type PayloadConfig_ComplexParams struct {
ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,oneof"`
}type PayloadConfig_SimpleParams struct {
SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,oneof"`
}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() ([]byte, []int)
func (x PayloadType) String() string
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" json:"offered_load,omitempty"`
}Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.
func (*PoissonParams) Descriptor() ([]byte, []int)
func (m *PoissonParams) GetOfferedLoad() float64
func (*PoissonParams) ProtoMessage()
func (m *PoissonParams) Reset()
func (m *PoissonParams) String() string
type ReconnectInfo struct {
Passed bool `protobuf:"varint,1,opt,name=passed" json:"passed,omitempty"`
BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs" json:"backoff_ms,omitempty"`
}For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.
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
type ReconnectParams struct {
MaxReconnectBackoffMs int32 `protobuf:"varint,1,opt,name=max_reconnect_backoff_ms,json=maxReconnectBackoffMs" json:"max_reconnect_backoff_ms,omitempty"`
}For reconnect interop test only. Client tells server what reconnection parameters it used.
func (*ReconnectParams) Descriptor() ([]byte, []int)
func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32
func (*ReconnectParams) ProtoMessage()
func (m *ReconnectParams) Reset()
func (m *ReconnectParams) String() string
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" 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" json:"interval_us,omitempty"`
}Configuration for a particular response.
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
type Scenario struct {
// Human readable name for this scenario
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
// Client configuration
ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig" json:"client_config,omitempty"`
// Number of clients to start for the test
NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients" json:"num_clients,omitempty"`
// Server configuration
ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig" json:"server_config,omitempty"`
// Number of servers to start for the test
NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers" json:"num_servers,omitempty"`
// Warmup period, in seconds
WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds" json:"warmup_seconds,omitempty"`
// Benchmark time, in seconds
BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds" json:"benchmark_seconds,omitempty"`
// Number of workers to spawn locally (usually zero)
SpawnLocalWorkerCount int32 `protobuf:"varint,8,opt,name=spawn_local_worker_count,json=spawnLocalWorkerCount" json:"spawn_local_worker_count,omitempty"`
}A single performance scenario: input to qps_json_driver
func (m *Scenario) GetClientConfig() *ClientConfig
func (m *Scenario) GetServerConfig() *ServerConfig
type Scenarios struct {
Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios" json:"scenarios,omitempty"`
}A set of scenarios to be run with qps_json_driver
type SecurityParams struct {
UseTestCa bool `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa" json:"use_test_ca,omitempty"`
ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride" json:"server_host_override,omitempty"`
}presence of SecurityParams implies use of TLS
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
type ServerArgs struct {
// Types that are valid to be assigned to Argtype:
// *ServerArgs_Setup
// *ServerArgs_Mark
Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"`
}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 (*ServerArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type ServerArgs_Setup struct {
Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,oneof"`
}type ServerConfig struct {
ServerType ServerType `protobuf:"varint,1,opt,name=server_type,json=serverType,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams" json:"security_params,omitempty"`
// Port on which to listen. Zero means pick unused port.
Port int32 `protobuf:"varint,4,opt,name=port" 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" 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" json:"core_limit,omitempty"`
// payload config, used in generic server
PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig" 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" json:"core_list,omitempty"`
}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
type ServerStats struct {
// wall clock time change in seconds since last reset
TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed" 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" 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" json:"time_system,omitempty"`
}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
type ServerStatus struct {
Stats *ServerStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
// the port bound by the server
Port int32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
// Number of cores available to the server
Cores int32 `protobuf:"varint,3,opt,name=cores" json:"cores,omitempty"`
}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
const (
ServerType_SYNC_SERVER ServerType = 0
ServerType_ASYNC_SERVER ServerType = 1
ServerType_ASYNC_GENERIC_SERVER ServerType = 2
)func (ServerType) EnumDescriptor() ([]byte, []int)
func (x ServerType) String() string
type SimpleProtoParams struct {
ReqSize int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize" json:"req_size,omitempty"`
RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize" json:"resp_size,omitempty"`
}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
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 `protobuf:"varint,1,opt,name=response_type,json=responseType,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
// 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" json:"response_size,omitempty"`
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
// Whether SimpleResponse should include username.
FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername" json:"fill_username,omitempty"`
// Whether SimpleResponse should include OAuth scope.
FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope" json:"fill_oauth_scope,omitempty"`
// Compression algorithm to be used by the server for the response (stream)
ResponseCompression CompressionType `protobuf:"varint,6,opt,name=response_compression,json=responseCompression,enum=grpc.testing.CompressionType" json:"response_compression,omitempty"`
// Whether server should return a given status
ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
}Unary request.
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
type SimpleResponse struct {
// Payload to increase message size.
Payload *Payload `protobuf:"bytes,1,opt,name=payload" 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" json:"username,omitempty"`
// OAuth scope.
OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope" json:"oauth_scope,omitempty"`
}Unary response, as configured by the request.
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
type StreamingInputCallRequest struct {
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
}Client-streaming request.
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
func (m *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage()
func (m *StreamingInputCallRequest) Reset()
func (m *StreamingInputCallRequest) String() string
type StreamingInputCallResponse struct {
// Aggregated size of payloads received from the client.
AggregatedPayloadSize int32 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize" json:"aggregated_payload_size,omitempty"`
}Client-streaming response.
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage()
func (m *StreamingInputCallResponse) Reset()
func (m *StreamingInputCallResponse) String() string
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 `protobuf:"varint,1,opt,name=response_type,json=responseType,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
// Configuration for each expected response message.
ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters" json:"response_parameters,omitempty"`
// Optional input payload sent along with the request.
Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
// Compression algorithm to be used by the server for the response (stream)
ResponseCompression CompressionType `protobuf:"varint,6,opt,name=response_compression,json=responseCompression,enum=grpc.testing.CompressionType" json:"response_compression,omitempty"`
// Whether server should return a given status
ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
}Server-streaming request.
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
type StreamingOutputCallResponse struct {
// Payload to increase response size.
Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
}Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
func (m *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage()
func (m *StreamingOutputCallResponse) Reset()
func (m *StreamingOutputCallResponse) String() string
type UniformParams struct {
InterarrivalLo float64 `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo" json:"interarrival_lo,omitempty"`
InterarrivalHi float64 `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi" json:"interarrival_hi,omitempty"`
}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
type Void struct {
}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)
}func NewWorkerServiceClient(cc *grpc.ClientConn) WorkerServiceClient
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)
}type WorkerService_RunClientClient interface {
Send(*ClientArgs) error
Recv() (*ClientStatus, error)
grpc.ClientStream
}type WorkerService_RunClientServer interface {
Send(*ClientStatus) error
Recv() (*ClientArgs, error)
grpc.ServerStream
}type WorkerService_RunServerClient interface {
Send(*ServerArgs) error
Recv() (*ServerStatus, error)
grpc.ClientStream
}type WorkerService_RunServerServer interface {
Send(*ServerStatus) error
Recv() (*ServerArgs, error)
grpc.ServerStream
}Package grpc_testing imports 5 packages (graph) and is imported by 40 packages. Updated 2018-01-03. Refresh now. Tools for package owners.