Documentation

Index

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.Server, srv BenchmarkServiceServer)

func RegisterWorkerServiceServer

func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer)

Types

type BenchmarkServiceClient

type BenchmarkServiceClient interface {
	// One request followed by one response.
	// The server returns the client payload as-is.
	UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// One request followed by one response.
	// The server returns the client payload as-is.
	StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)
	// Unconstrainted streaming.
	// Both server and client keep sending & receiving simultaneously.
	UnconstrainedStreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_UnconstrainedStreamingCallClient, error)
}

BenchmarkServiceClient is the client API for BenchmarkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

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

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

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 {
	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"`

	OutstandingRpcsPerChannel int32 "" /* 141 byte string literal not displayed */

	ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`

	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"`

	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"`

	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"`

}

func (*ClientConfig) Descriptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func (*Mark) Descriptor() ([]byte, []int)

Deprecated: Use Mark.ProtoReflect.Descriptor instead.

func (*Mark) GetReset_

func (x *Mark) GetReset_() bool

func (*Mark) ProtoMessage

func (*Mark) ProtoMessage()

func (*Mark) ProtoReflect

func (x *Mark) ProtoReflect() protoreflect.Message

func (*Mark) Reset

func (x *Mark) Reset()

func (*Mark) String

func (x *Mark) String() string

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

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

func (*Payload) Descriptor() ([]byte, []int)

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetBody

func (x *Payload) GetBody() []byte

func (*Payload) GetType

func (x *Payload) GetType() PayloadType

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect

func (x *Payload) ProtoReflect() protoreflect.Message

func (*Payload) Reset

func (x *Payload) Reset()

func (*Payload) String

func (x *Payload) String() string

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

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

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

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

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 */

}

For reconnect interop test only. Client tells server what reconnection parameters it used.

func (*ReconnectParams) Descriptor

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

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
const (
	RpcType_UNARY     RpcType = 0
	RpcType_STREAMING RpcType = 1
)

func (RpcType) Descriptor

func (RpcType) Descriptor() protoreflect.EnumDescriptor

func (RpcType) Enum

func (x RpcType) Enum() *RpcType

func (RpcType) EnumDescriptor

func (RpcType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RpcType.Descriptor instead.

func (RpcType) Number

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String

func (x RpcType) String() string

func (RpcType) Type

func (RpcType) Type() protoreflect.EnumType

type Scenario

type Scenario struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`

	NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`

	ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`

	NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`

	WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`

	BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`

	SpawnLocalWorkerCount int32 "" /* 129 byte string literal not displayed */

}

A single performance scenario: input to qps_json_driver

func (*Scenario) Descriptor

func (*Scenario) Descriptor() ([]byte, []int)

Deprecated: Use Scenario.ProtoReflect.Descriptor instead.

func (*Scenario) GetBenchmarkSeconds

func (x *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig

func (x *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName

func (x *Scenario) GetName() string

func (*Scenario) GetNumClients

func (x *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers

func (x *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig

func (x *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount

func (x *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds

func (x *Scenario) GetWarmupSeconds() int32

func (*Scenario) ProtoMessage

func (*Scenario) ProtoMessage()

func (*Scenario) ProtoReflect

func (x *Scenario) ProtoReflect() protoreflect.Message

func (*Scenario) Reset

func (x *Scenario) Reset()

func (*Scenario) String

func (x *Scenario) String() string

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

func (*Scenarios) Descriptor() ([]byte, []int)

Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.

func (*Scenarios) GetScenarios

func (x *Scenarios) GetScenarios() []*Scenario

func (*Scenarios) ProtoMessage

func (*Scenarios) ProtoMessage()

func (*Scenarios) ProtoReflect

func (x *Scenarios) ProtoReflect() protoreflect.Message

func (*Scenarios) Reset

func (x *Scenarios) Reset()

func (*Scenarios) String

func (x *Scenarios) String() string

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

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

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

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

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

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

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

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 {
	ResponseType PayloadType "" /* 128 byte string literal not displayed */

	ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`

	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`

	FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`

	FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`

	ResponseCompression CompressionType "" /* 153 byte string literal not displayed */

	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`

}

Unary request.

func (*SimpleRequest) Descriptor

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

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

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 {
	AggregatedPayloadSize int32 "" /* 127 byte string literal not displayed */

}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor

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 {
	ResponseType PayloadType "" /* 128 byte string literal not displayed */

	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`

	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`

	ResponseCompression CompressionType "" /* 153 byte string literal not displayed */

	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`

}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor

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

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

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) QuitWorker(context.Context, *Void) (*Void, error)

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

func (*Void) Descriptor() ([]byte, []int)

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) ProtoReflect

func (x *Void) ProtoReflect() protoreflect.Message

func (*Void) Reset

func (x *Void) Reset()

func (*Void) String

func (x *Void) String() string

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.

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
}