grpc_testing

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ClientType_name = map[int32]string{
	0: "SYNC_CLIENT",
	1: "ASYNC_CLIENT",
}
View Source
var ClientType_value = map[string]int32{
	"SYNC_CLIENT":  0,
	"ASYNC_CLIENT": 1,
}
View Source
var CompressionType_name = map[int32]string{
	0: "NONE",
	1: "GZIP",
	2: "DEFLATE",
}
View Source
var CompressionType_value = map[string]int32{
	"NONE":    0,
	"GZIP":    1,
	"DEFLATE": 2,
}
View Source
var PayloadType_name = map[int32]string{
	0: "COMPRESSABLE",
	1: "UNCOMPRESSABLE",
	2: "RANDOM",
}
View Source
var PayloadType_value = map[string]int32{
	"COMPRESSABLE":   0,
	"UNCOMPRESSABLE": 1,
	"RANDOM":         2,
}
View Source
var RpcType_name = map[int32]string{
	0: "UNARY",
	1: "STREAMING",
}
View Source
var RpcType_value = map[string]int32{
	"UNARY":     0,
	"STREAMING": 1,
}
View Source
var ServerType_name = map[int32]string{
	0: "SYNC_SERVER",
	1: "ASYNC_SERVER",
	2: "ASYNC_GENERIC_SERVER",
}
View Source
var ServerType_value = map[string]int32{
	"SYNC_SERVER":          0,
	"ASYNC_SERVER":         1,
	"ASYNC_GENERIC_SERVER": 2,
}

Functions

func RegisterBenchmarkServiceServer

func RegisterBenchmarkServiceServer(s *grpc.Server, srv BenchmarkServiceServer)

func RegisterWorkerServiceServer

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

Types

type BenchmarkServiceClient

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

BenchmarkServiceClient is the client API for BenchmarkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/code.aliyun.com/yjkj.ink/grpc#ClientConn.NewStream.

func NewBenchmarkServiceClient

func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient

type BenchmarkServiceServer

type BenchmarkServiceServer interface {
	// One request followed by one response.
	// The server returns the client payload as-is.
	UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
	// One request followed by one response.
	// The server returns the client payload as-is.
	StreamingCall(BenchmarkService_StreamingCallServer) error
	// Unconstrainted streaming.
	// Both server and client keep sending & receiving simultaneously.
	UnconstrainedStreamingCall(BenchmarkService_UnconstrainedStreamingCallServer) error
}

BenchmarkServiceServer is the server API for BenchmarkService service.

type BenchmarkService_StreamingCallClient

type BenchmarkService_StreamingCallClient interface {
	Send(*SimpleRequest) error
	Recv() (*SimpleResponse, error)
	grpc.ClientStream
}

type BenchmarkService_StreamingCallServer

type BenchmarkService_StreamingCallServer interface {
	Send(*SimpleResponse) error
	Recv() (*SimpleRequest, error)
	grpc.ServerStream
}

type BenchmarkService_UnconstrainedStreamingCallClient

type BenchmarkService_UnconstrainedStreamingCallClient interface {
	Send(*SimpleRequest) error
	Recv() (*SimpleResponse, error)
	grpc.ClientStream
}

type BenchmarkService_UnconstrainedStreamingCallServer

type BenchmarkService_UnconstrainedStreamingCallServer interface {
	Send(*SimpleResponse) error
	Recv() (*SimpleRequest, error)
	grpc.ServerStream
}

type ByteBufferParams

type ByteBufferParams struct {
	ReqSize              int32    `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
	RespSize             int32    `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ByteBufferParams) Descriptor

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

func (*ByteBufferParams) GetReqSize

func (m *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize

func (m *ByteBufferParams) GetRespSize() int32

func (*ByteBufferParams) ProtoMessage

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams) Reset

func (m *ByteBufferParams) Reset()

func (*ByteBufferParams) String

func (m *ByteBufferParams) String() string

func (*ByteBufferParams) XXX_DiscardUnknown

func (m *ByteBufferParams) XXX_DiscardUnknown()

func (*ByteBufferParams) XXX_Marshal

func (m *ByteBufferParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ByteBufferParams) XXX_Merge

func (m *ByteBufferParams) XXX_Merge(src proto.Message)

func (*ByteBufferParams) XXX_Size

func (m *ByteBufferParams) XXX_Size() int

func (*ByteBufferParams) XXX_Unmarshal

func (m *ByteBufferParams) XXX_Unmarshal(b []byte) error

type ClientArgs

type ClientArgs struct {
	// Types that are valid to be assigned to Argtype:
	//	*ClientArgs_Setup
	//	*ClientArgs_Mark
	Argtype              isClientArgs_Argtype `protobuf_oneof:"argtype"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ClientArgs) Descriptor

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

func (*ClientArgs) GetArgtype

func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark

func (m *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup

func (m *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) ProtoMessage

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) Reset

func (m *ClientArgs) Reset()

func (*ClientArgs) String

func (m *ClientArgs) String() string

func (*ClientArgs) XXX_DiscardUnknown

func (m *ClientArgs) XXX_DiscardUnknown()

func (*ClientArgs) XXX_Marshal

func (m *ClientArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientArgs) XXX_Merge

func (m *ClientArgs) XXX_Merge(src proto.Message)

func (*ClientArgs) XXX_OneofWrappers

func (*ClientArgs) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientArgs) XXX_Size

func (m *ClientArgs) XXX_Size() int

func (*ClientArgs) XXX_Unmarshal

func (m *ClientArgs) XXX_Unmarshal(b []byte) error

type ClientArgs_Mark

type ClientArgs_Mark struct {
	Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}

type ClientArgs_Setup

type ClientArgs_Setup struct {
	Setup *ClientConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}

type ClientConfig

type ClientConfig struct {
	// List of targets to connect to. At least one target needs to be specified.
	ServerTargets  []string        `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"`
	ClientType     ClientType      `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
	SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
	// How many concurrent RPCs to start for each channel.
	// For synchronous client, use a separate thread for each outstanding RPC.
	OutstandingRpcsPerChannel int32 `` /* 141-byte string literal not displayed */
	// Number of independent client channels to create.
	// i-th channel will connect to server_target[i % server_targets.size()]
	ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`
	// Only for async client. Number of threads to use to start/manage RPCs.
	AsyncClientThreads int32   `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"`
	RpcType            RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"`
	// The requested load for the entire client (aggregated over all the threads).
	LoadParams      *LoadParams      `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"`
	PayloadConfig   *PayloadConfig   `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
	HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"`
	// Specify the cores we should run the client on, if desired
	CoreList             []int32  `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
	CoreLimit            int32    `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientConfig) Descriptor

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

func (*ClientConfig) GetAsyncClientThreads

func (m *ClientConfig) GetAsyncClientThreads() int32

func (*ClientConfig) GetClientChannels

func (m *ClientConfig) GetClientChannels() int32

func (*ClientConfig) GetClientType

func (m *ClientConfig) GetClientType() ClientType

func (*ClientConfig) GetCoreLimit

func (m *ClientConfig) GetCoreLimit() int32

func (*ClientConfig) GetCoreList

func (m *ClientConfig) GetCoreList() []int32

func (*ClientConfig) GetHistogramParams

func (m *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig) GetLoadParams

func (m *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig) GetOutstandingRpcsPerChannel

func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32

func (*ClientConfig) GetPayloadConfig

func (m *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig) GetRpcType

func (m *ClientConfig) GetRpcType() RpcType

func (*ClientConfig) GetSecurityParams

func (m *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig) GetServerTargets

func (m *ClientConfig) GetServerTargets() []string

func (*ClientConfig) ProtoMessage

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset

func (m *ClientConfig) Reset()

func (*ClientConfig) String

func (m *ClientConfig) String() string

func (*ClientConfig) XXX_DiscardUnknown

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal

func (m *ClientConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientConfig) XXX_Merge

func (m *ClientConfig) XXX_Merge(src proto.Message)

func (*ClientConfig) XXX_Size

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal

func (m *ClientConfig) XXX_Unmarshal(b []byte) error

type ClientStats

type ClientStats struct {
	// Latency histogram. Data points are in nanoseconds.
	Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"`
	// See ServerStats for details.
	TimeElapsed          float64  `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	TimeUser             float64  `protobuf:"fixed64,3,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
	TimeSystem           float64  `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStats) Descriptor

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

func (*ClientStats) GetLatencies

func (m *ClientStats) GetLatencies() *HistogramData

func (*ClientStats) GetTimeElapsed

func (m *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem

func (m *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser

func (m *ClientStats) GetTimeUser() float64

func (*ClientStats) ProtoMessage

func (*ClientStats) ProtoMessage()

func (*ClientStats) Reset

func (m *ClientStats) Reset()

func (*ClientStats) String

func (m *ClientStats) String() string

func (*ClientStats) XXX_DiscardUnknown

func (m *ClientStats) XXX_DiscardUnknown()

func (*ClientStats) XXX_Marshal

func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStats) XXX_Merge

func (m *ClientStats) XXX_Merge(src proto.Message)

func (*ClientStats) XXX_Size

func (m *ClientStats) XXX_Size() int

func (*ClientStats) XXX_Unmarshal

func (m *ClientStats) XXX_Unmarshal(b []byte) error

type ClientStatus

type ClientStatus struct {
	Stats                *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ClientStatus) Descriptor

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

func (*ClientStatus) GetStats

func (m *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) ProtoMessage

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) Reset

func (m *ClientStatus) Reset()

func (*ClientStatus) String

func (m *ClientStatus) String() string

func (*ClientStatus) XXX_DiscardUnknown

func (m *ClientStatus) XXX_DiscardUnknown()

func (*ClientStatus) XXX_Marshal

func (m *ClientStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStatus) XXX_Merge

func (m *ClientStatus) XXX_Merge(src proto.Message)

func (*ClientStatus) XXX_Size

func (m *ClientStatus) XXX_Size() int

func (*ClientStatus) XXX_Unmarshal

func (m *ClientStatus) XXX_Unmarshal(b []byte) error

type ClientType

type ClientType int32
const (
	ClientType_SYNC_CLIENT  ClientType = 0
	ClientType_ASYNC_CLIENT ClientType = 1
)

func (ClientType) EnumDescriptor

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

func (ClientType) String

func (x ClientType) String() string

type ClosedLoopParams

type ClosedLoopParams struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Once an RPC finishes, immediately start a new one. No configuration parameters needed.

func (*ClosedLoopParams) Descriptor

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

func (*ClosedLoopParams) ProtoMessage

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams) Reset

func (m *ClosedLoopParams) Reset()

func (*ClosedLoopParams) String

func (m *ClosedLoopParams) String() string

func (*ClosedLoopParams) XXX_DiscardUnknown

func (m *ClosedLoopParams) XXX_DiscardUnknown()

func (*ClosedLoopParams) XXX_Marshal

func (m *ClosedLoopParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClosedLoopParams) XXX_Merge

func (m *ClosedLoopParams) XXX_Merge(src proto.Message)

func (*ClosedLoopParams) XXX_Size

func (m *ClosedLoopParams) XXX_Size() int

func (*ClosedLoopParams) XXX_Unmarshal

func (m *ClosedLoopParams) XXX_Unmarshal(b []byte) error

type ComplexProtoParams

type ComplexProtoParams struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ComplexProtoParams) Descriptor

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

func (*ComplexProtoParams) ProtoMessage

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams) Reset

func (m *ComplexProtoParams) Reset()

func (*ComplexProtoParams) String

func (m *ComplexProtoParams) String() string

func (*ComplexProtoParams) XXX_DiscardUnknown

func (m *ComplexProtoParams) XXX_DiscardUnknown()

func (*ComplexProtoParams) XXX_Marshal

func (m *ComplexProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ComplexProtoParams) XXX_Merge

func (m *ComplexProtoParams) XXX_Merge(src proto.Message)

func (*ComplexProtoParams) XXX_Size

func (m *ComplexProtoParams) XXX_Size() int

func (*ComplexProtoParams) XXX_Unmarshal

func (m *ComplexProtoParams) XXX_Unmarshal(b []byte) error

type CompressionType

type CompressionType int32

Compression algorithms

const (
	// No compression
	CompressionType_NONE    CompressionType = 0
	CompressionType_GZIP    CompressionType = 1
	CompressionType_DEFLATE CompressionType = 2
)

func (CompressionType) EnumDescriptor

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

func (CompressionType) String

func (x CompressionType) String() string

type CoreRequest

type CoreRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CoreRequest) Descriptor

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

func (*CoreRequest) ProtoMessage

func (*CoreRequest) ProtoMessage()

func (*CoreRequest) Reset

func (m *CoreRequest) Reset()

func (*CoreRequest) String

func (m *CoreRequest) String() string

func (*CoreRequest) XXX_DiscardUnknown

func (m *CoreRequest) XXX_DiscardUnknown()

func (*CoreRequest) XXX_Marshal

func (m *CoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CoreRequest) XXX_Merge

func (m *CoreRequest) XXX_Merge(src proto.Message)

func (*CoreRequest) XXX_Size

func (m *CoreRequest) XXX_Size() int

func (*CoreRequest) XXX_Unmarshal

func (m *CoreRequest) XXX_Unmarshal(b []byte) error

type CoreResponse

type CoreResponse struct {
	// Number of cores available on the server
	Cores                int32    `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CoreResponse) Descriptor

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

func (*CoreResponse) GetCores

func (m *CoreResponse) GetCores() int32

func (*CoreResponse) ProtoMessage

func (*CoreResponse) ProtoMessage()

func (*CoreResponse) Reset

func (m *CoreResponse) Reset()

func (*CoreResponse) String

func (m *CoreResponse) String() string

func (*CoreResponse) XXX_DiscardUnknown

func (m *CoreResponse) XXX_DiscardUnknown()

func (*CoreResponse) XXX_Marshal

func (m *CoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CoreResponse) XXX_Merge

func (m *CoreResponse) XXX_Merge(src proto.Message)

func (*CoreResponse) XXX_Size

func (m *CoreResponse) XXX_Size() int

func (*CoreResponse) XXX_Unmarshal

func (m *CoreResponse) XXX_Unmarshal(b []byte) error

type DeterministicParams

type DeterministicParams struct {
	OfferedLoad          float64  `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeterministicParams) Descriptor

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

func (*DeterministicParams) GetOfferedLoad

func (m *DeterministicParams) GetOfferedLoad() float64

func (*DeterministicParams) ProtoMessage

func (*DeterministicParams) ProtoMessage()

func (*DeterministicParams) Reset

func (m *DeterministicParams) Reset()

func (*DeterministicParams) String

func (m *DeterministicParams) String() string

func (*DeterministicParams) XXX_DiscardUnknown

func (m *DeterministicParams) XXX_DiscardUnknown()

func (*DeterministicParams) XXX_Marshal

func (m *DeterministicParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeterministicParams) XXX_Merge

func (m *DeterministicParams) XXX_Merge(src proto.Message)

func (*DeterministicParams) XXX_Size

func (m *DeterministicParams) XXX_Size() int

func (*DeterministicParams) XXX_Unmarshal

func (m *DeterministicParams) XXX_Unmarshal(b []byte) error

type EchoStatus

type EchoStatus struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.

func (*EchoStatus) Descriptor

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

func (*EchoStatus) GetCode

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage

func (m *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) Reset

func (m *EchoStatus) Reset()

func (*EchoStatus) String

func (m *EchoStatus) String() string

func (*EchoStatus) XXX_DiscardUnknown

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal

func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStatus) XXX_Merge

func (m *EchoStatus) XXX_Merge(src proto.Message)

func (*EchoStatus) XXX_Size

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal

func (m *EchoStatus) XXX_Unmarshal(b []byte) error

type HistogramData

type HistogramData struct {
	Bucket               []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"`
	MinSeen              float64  `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"`
	MaxSeen              float64  `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"`
	Sum                  float64  `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	SumOfSquares         float64  `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"`
	Count                float64  `protobuf:"fixed64,6,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Histogram data based on grpc/support/histogram.c

func (*HistogramData) Descriptor

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

func (*HistogramData) GetBucket

func (m *HistogramData) GetBucket() []uint32

func (*HistogramData) GetCount

func (m *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen

func (m *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen

func (m *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum

func (m *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares

func (m *HistogramData) GetSumOfSquares() float64

func (*HistogramData) ProtoMessage

func (*HistogramData) ProtoMessage()

func (*HistogramData) Reset

func (m *HistogramData) Reset()

func (*HistogramData) String

func (m *HistogramData) String() string

func (*HistogramData) XXX_DiscardUnknown

func (m *HistogramData) XXX_DiscardUnknown()

func (*HistogramData) XXX_Marshal

func (m *HistogramData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistogramData) XXX_Merge

func (m *HistogramData) XXX_Merge(src proto.Message)

func (*HistogramData) XXX_Size

func (m *HistogramData) XXX_Size() int

func (*HistogramData) XXX_Unmarshal

func (m *HistogramData) XXX_Unmarshal(b []byte) error

type HistogramParams

type HistogramParams struct {
	Resolution           float64  `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`
	MaxPossible          float64  `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Histogram params based on grpc/support/histogram.c

func (*HistogramParams) Descriptor

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

func (*HistogramParams) GetMaxPossible

func (m *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution

func (m *HistogramParams) GetResolution() float64

func (*HistogramParams) ProtoMessage

func (*HistogramParams) ProtoMessage()

func (*HistogramParams) Reset

func (m *HistogramParams) Reset()

func (*HistogramParams) String

func (m *HistogramParams) String() string

func (*HistogramParams) XXX_DiscardUnknown

func (m *HistogramParams) XXX_DiscardUnknown()

func (*HistogramParams) XXX_Marshal

func (m *HistogramParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistogramParams) XXX_Merge

func (m *HistogramParams) XXX_Merge(src proto.Message)

func (*HistogramParams) XXX_Size

func (m *HistogramParams) XXX_Size() int

func (*HistogramParams) XXX_Unmarshal

func (m *HistogramParams) XXX_Unmarshal(b []byte) error

type LoadParams

type LoadParams struct {
	// Types that are valid to be assigned to Load:
	//	*LoadParams_ClosedLoop
	//	*LoadParams_Poisson
	//	*LoadParams_Uniform
	//	*LoadParams_Determ
	//	*LoadParams_Pareto
	Load                 isLoadParams_Load `protobuf_oneof:"load"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*LoadParams) Descriptor

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

func (*LoadParams) GetClosedLoop

func (m *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams) GetDeterm

func (m *LoadParams) GetDeterm() *DeterministicParams

func (*LoadParams) GetLoad

func (m *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPareto

func (m *LoadParams) GetPareto() *ParetoParams

func (*LoadParams) GetPoisson

func (m *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) GetUniform

func (m *LoadParams) GetUniform() *UniformParams

func (*LoadParams) ProtoMessage

func (*LoadParams) ProtoMessage()

func (*LoadParams) Reset

func (m *LoadParams) Reset()

func (*LoadParams) String

func (m *LoadParams) String() string

func (*LoadParams) XXX_DiscardUnknown

func (m *LoadParams) XXX_DiscardUnknown()

func (*LoadParams) XXX_Marshal

func (m *LoadParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadParams) XXX_Merge

func (m *LoadParams) XXX_Merge(src proto.Message)

func (*LoadParams) XXX_OneofWrappers

func (*LoadParams) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoadParams) XXX_Size

func (m *LoadParams) XXX_Size() int

func (*LoadParams) XXX_Unmarshal

func (m *LoadParams) XXX_Unmarshal(b []byte) error

type LoadParams_ClosedLoop

type LoadParams_ClosedLoop struct {
	ClosedLoop *ClosedLoopParams `protobuf:"bytes,1,opt,name=closed_loop,json=closedLoop,proto3,oneof"`
}

type LoadParams_Determ

type LoadParams_Determ struct {
	Determ *DeterministicParams `protobuf:"bytes,4,opt,name=determ,proto3,oneof"`
}

type LoadParams_Pareto

type LoadParams_Pareto struct {
	Pareto *ParetoParams `protobuf:"bytes,5,opt,name=pareto,proto3,oneof"`
}

type LoadParams_Poisson

type LoadParams_Poisson struct {
	Poisson *PoissonParams `protobuf:"bytes,2,opt,name=poisson,proto3,oneof"`
}

type LoadParams_Uniform

type LoadParams_Uniform struct {
	Uniform *UniformParams `protobuf:"bytes,3,opt,name=uniform,proto3,oneof"`
}

type Mark

type Mark struct {
	// if true, the stats will be reset after taking their snapshot.
	Reset_               bool     `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request current stats

func (*Mark) Descriptor

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

func (*Mark) GetReset_

func (m *Mark) GetReset_() bool

func (*Mark) ProtoMessage

func (*Mark) ProtoMessage()

func (*Mark) Reset

func (m *Mark) Reset()

func (*Mark) String

func (m *Mark) String() string

func (*Mark) XXX_DiscardUnknown

func (m *Mark) XXX_DiscardUnknown()

func (*Mark) XXX_Marshal

func (m *Mark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mark) XXX_Merge

func (m *Mark) XXX_Merge(src proto.Message)

func (*Mark) XXX_Size

func (m *Mark) XXX_Size() int

func (*Mark) XXX_Unmarshal

func (m *Mark) XXX_Unmarshal(b []byte) error

type ParetoParams

type ParetoParams struct {
	InterarrivalBase     float64  `protobuf:"fixed64,1,opt,name=interarrival_base,json=interarrivalBase,proto3" json:"interarrival_base,omitempty"`
	Alpha                float64  `protobuf:"fixed64,2,opt,name=alpha,proto3" json:"alpha,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ParetoParams) Descriptor

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

func (*ParetoParams) GetAlpha

func (m *ParetoParams) GetAlpha() float64

func (*ParetoParams) GetInterarrivalBase

func (m *ParetoParams) GetInterarrivalBase() float64

func (*ParetoParams) ProtoMessage

func (*ParetoParams) ProtoMessage()

func (*ParetoParams) Reset

func (m *ParetoParams) Reset()

func (*ParetoParams) String

func (m *ParetoParams) String() string

func (*ParetoParams) XXX_DiscardUnknown

func (m *ParetoParams) XXX_DiscardUnknown()

func (*ParetoParams) XXX_Marshal

func (m *ParetoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParetoParams) XXX_Merge

func (m *ParetoParams) XXX_Merge(src proto.Message)

func (*ParetoParams) XXX_Size

func (m *ParetoParams) XXX_Size() int

func (*ParetoParams) XXX_Unmarshal

func (m *ParetoParams) XXX_Unmarshal(b []byte) error

type Payload

type Payload struct {
	// The type of data in body.
	Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
	// Primary contents of payload.
	Body                 []byte   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A block of data, to simply increase gRPC message size.

func (*Payload) Descriptor

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

func (*Payload) GetBody

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

func (*Payload) GetType

func (m *Payload) GetType() PayloadType

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

func (m *Payload) XXX_Unmarshal(b []byte) error

type PayloadConfig

type PayloadConfig struct {
	// Types that are valid to be assigned to Payload:
	//	*PayloadConfig_BytebufParams
	//	*PayloadConfig_SimpleParams
	//	*PayloadConfig_ComplexParams
	Payload              isPayloadConfig_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*PayloadConfig) Descriptor

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

func (*PayloadConfig) GetBytebufParams

func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams

func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload

func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams

func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) ProtoMessage

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) Reset

func (m *PayloadConfig) Reset()

func (*PayloadConfig) String

func (m *PayloadConfig) String() string

func (*PayloadConfig) XXX_DiscardUnknown

func (m *PayloadConfig) XXX_DiscardUnknown()

func (*PayloadConfig) XXX_Marshal

func (m *PayloadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PayloadConfig) XXX_Merge

func (m *PayloadConfig) XXX_Merge(src proto.Message)

func (*PayloadConfig) XXX_OneofWrappers

func (*PayloadConfig) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PayloadConfig) XXX_Size

func (m *PayloadConfig) XXX_Size() int

func (*PayloadConfig) XXX_Unmarshal

func (m *PayloadConfig) XXX_Unmarshal(b []byte) error

type PayloadConfig_BytebufParams

type PayloadConfig_BytebufParams struct {
	BytebufParams *ByteBufferParams `protobuf:"bytes,1,opt,name=bytebuf_params,json=bytebufParams,proto3,oneof"`
}

type PayloadConfig_ComplexParams

type PayloadConfig_ComplexParams struct {
	ComplexParams *ComplexProtoParams `protobuf:"bytes,3,opt,name=complex_params,json=complexParams,proto3,oneof"`
}

type PayloadConfig_SimpleParams

type PayloadConfig_SimpleParams struct {
	SimpleParams *SimpleProtoParams `protobuf:"bytes,2,opt,name=simple_params,json=simpleParams,proto3,oneof"`
}

type PayloadType

type PayloadType int32

The type of payload that should be returned.

const (
	// Compressable text format.
	PayloadType_COMPRESSABLE PayloadType = 0
	// Uncompressable binary format.
	PayloadType_UNCOMPRESSABLE PayloadType = 1
	// Randomly chosen from all other formats defined in this enum.
	PayloadType_RANDOM PayloadType = 2
)

func (PayloadType) EnumDescriptor

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

func (PayloadType) String

func (x PayloadType) String() string

type PoissonParams

type PoissonParams struct {
	// The rate of arrivals (a.k.a. lambda parameter of the exp distribution).
	OfferedLoad          float64  `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Parameters of poisson process distribution, which is a good representation of activity coming in from independent identical stationary sources.

func (*PoissonParams) Descriptor

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

func (*PoissonParams) GetOfferedLoad

func (m *PoissonParams) GetOfferedLoad() float64

func (*PoissonParams) ProtoMessage

func (*PoissonParams) ProtoMessage()

func (*PoissonParams) Reset

func (m *PoissonParams) Reset()

func (*PoissonParams) String

func (m *PoissonParams) String() string

func (*PoissonParams) XXX_DiscardUnknown

func (m *PoissonParams) XXX_DiscardUnknown()

func (*PoissonParams) XXX_Marshal

func (m *PoissonParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoissonParams) XXX_Merge

func (m *PoissonParams) XXX_Merge(src proto.Message)

func (*PoissonParams) XXX_Size

func (m *PoissonParams) XXX_Size() int

func (*PoissonParams) XXX_Unmarshal

func (m *PoissonParams) XXX_Unmarshal(b []byte) error

type ReconnectInfo

type ReconnectInfo struct {
	Passed               bool     `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
	BackoffMs            []int32  `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For reconnect interop test only. Server tells client whether its reconnects are following the spec and the reconnect backoffs it saw.

func (*ReconnectInfo) Descriptor

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

func (*ReconnectInfo) GetBackoffMs

func (m *ReconnectInfo) GetBackoffMs() []int32

func (*ReconnectInfo) GetPassed

func (m *ReconnectInfo) GetPassed() bool

func (*ReconnectInfo) ProtoMessage

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo) Reset

func (m *ReconnectInfo) Reset()

func (*ReconnectInfo) String

func (m *ReconnectInfo) String() string

func (*ReconnectInfo) XXX_DiscardUnknown

func (m *ReconnectInfo) XXX_DiscardUnknown()

func (*ReconnectInfo) XXX_Marshal

func (m *ReconnectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReconnectInfo) XXX_Merge

func (m *ReconnectInfo) XXX_Merge(src proto.Message)

func (*ReconnectInfo) XXX_Size

func (m *ReconnectInfo) XXX_Size() int

func (*ReconnectInfo) XXX_Unmarshal

func (m *ReconnectInfo) XXX_Unmarshal(b []byte) error

type ReconnectParams

type ReconnectParams struct {
	MaxReconnectBackoffMs int32    `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

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

func (*ReconnectParams) Descriptor

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

func (*ReconnectParams) GetMaxReconnectBackoffMs

func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32

func (*ReconnectParams) ProtoMessage

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams) Reset

func (m *ReconnectParams) Reset()

func (*ReconnectParams) String

func (m *ReconnectParams) String() string

func (*ReconnectParams) XXX_DiscardUnknown

func (m *ReconnectParams) XXX_DiscardUnknown()

func (*ReconnectParams) XXX_Marshal

func (m *ReconnectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReconnectParams) XXX_Merge

func (m *ReconnectParams) XXX_Merge(src proto.Message)

func (*ReconnectParams) XXX_Size

func (m *ReconnectParams) XXX_Size() int

func (*ReconnectParams) XXX_Unmarshal

func (m *ReconnectParams) XXX_Unmarshal(b []byte) error

type ResponseParameters

type ResponseParameters struct {
	// Desired payload sizes in responses from the server.
	// If response_type is COMPRESSABLE, this denotes the size before compression.
	Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Desired interval between consecutive responses in the response stream in
	// microseconds.
	IntervalUs           int32    `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration for a particular response.

func (*ResponseParameters) Descriptor

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

func (*ResponseParameters) GetIntervalUs

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize

func (m *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) Reset

func (m *ResponseParameters) Reset()

func (*ResponseParameters) String

func (m *ResponseParameters) String() string

func (*ResponseParameters) XXX_DiscardUnknown

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal

func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseParameters) XXX_Merge

func (m *ResponseParameters) XXX_Merge(src proto.Message)

func (*ResponseParameters) XXX_Size

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal

func (m *ResponseParameters) XXX_Unmarshal(b []byte) error

type RpcType

type RpcType int32
const (
	RpcType_UNARY     RpcType = 0
	RpcType_STREAMING RpcType = 1
)

func (RpcType) EnumDescriptor

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

func (RpcType) String

func (x RpcType) String() string

type Scenario

type Scenario struct {
	// Human readable name for this scenario
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Client configuration
	ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
	// Number of clients to start for the test
	NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	// Server configuration
	ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
	// Number of servers to start for the test
	NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`
	// Warmup period, in seconds
	WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`
	// Benchmark time, in seconds
	BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`
	// Number of workers to spawn locally (usually zero)
	SpawnLocalWorkerCount int32    `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

A single performance scenario: input to qps_json_driver

func (*Scenario) Descriptor

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

func (*Scenario) GetBenchmarkSeconds

func (m *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig

func (m *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName

func (m *Scenario) GetName() string

func (*Scenario) GetNumClients

func (m *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers

func (m *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig

func (m *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount

func (m *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds

func (m *Scenario) GetWarmupSeconds() int32

func (*Scenario) ProtoMessage

func (*Scenario) ProtoMessage()

func (*Scenario) Reset

func (m *Scenario) Reset()

func (*Scenario) String

func (m *Scenario) String() string

func (*Scenario) XXX_DiscardUnknown

func (m *Scenario) XXX_DiscardUnknown()

func (*Scenario) XXX_Marshal

func (m *Scenario) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scenario) XXX_Merge

func (m *Scenario) XXX_Merge(src proto.Message)

func (*Scenario) XXX_Size

func (m *Scenario) XXX_Size() int

func (*Scenario) XXX_Unmarshal

func (m *Scenario) XXX_Unmarshal(b []byte) error

type Scenarios

type Scenarios struct {
	Scenarios            []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A set of scenarios to be run with qps_json_driver

func (*Scenarios) Descriptor

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

func (*Scenarios) GetScenarios

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

func (*Scenarios) ProtoMessage

func (*Scenarios) ProtoMessage()

func (*Scenarios) Reset

func (m *Scenarios) Reset()

func (*Scenarios) String

func (m *Scenarios) String() string

func (*Scenarios) XXX_DiscardUnknown

func (m *Scenarios) XXX_DiscardUnknown()

func (*Scenarios) XXX_Marshal

func (m *Scenarios) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scenarios) XXX_Merge

func (m *Scenarios) XXX_Merge(src proto.Message)

func (*Scenarios) XXX_Size

func (m *Scenarios) XXX_Size() int

func (*Scenarios) XXX_Unmarshal

func (m *Scenarios) XXX_Unmarshal(b []byte) error

type SecurityParams

type SecurityParams struct {
	UseTestCa            bool     `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
	ServerHostOverride   string   `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

presence of SecurityParams implies use of TLS

func (*SecurityParams) Descriptor

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

func (*SecurityParams) GetServerHostOverride

func (m *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa

func (m *SecurityParams) GetUseTestCa() bool

func (*SecurityParams) ProtoMessage

func (*SecurityParams) ProtoMessage()

func (*SecurityParams) Reset

func (m *SecurityParams) Reset()

func (*SecurityParams) String

func (m *SecurityParams) String() string

func (*SecurityParams) XXX_DiscardUnknown

func (m *SecurityParams) XXX_DiscardUnknown()

func (*SecurityParams) XXX_Marshal

func (m *SecurityParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecurityParams) XXX_Merge

func (m *SecurityParams) XXX_Merge(src proto.Message)

func (*SecurityParams) XXX_Size

func (m *SecurityParams) XXX_Size() int

func (*SecurityParams) XXX_Unmarshal

func (m *SecurityParams) XXX_Unmarshal(b []byte) error

type ServerArgs

type ServerArgs struct {
	// Types that are valid to be assigned to Argtype:
	//	*ServerArgs_Setup
	//	*ServerArgs_Mark
	Argtype              isServerArgs_Argtype `protobuf_oneof:"argtype"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ServerArgs) Descriptor

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

func (*ServerArgs) GetArgtype

func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark

func (m *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup

func (m *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) ProtoMessage

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) Reset

func (m *ServerArgs) Reset()

func (*ServerArgs) String

func (m *ServerArgs) String() string

func (*ServerArgs) XXX_DiscardUnknown

func (m *ServerArgs) XXX_DiscardUnknown()

func (*ServerArgs) XXX_Marshal

func (m *ServerArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerArgs) XXX_Merge

func (m *ServerArgs) XXX_Merge(src proto.Message)

func (*ServerArgs) XXX_OneofWrappers

func (*ServerArgs) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerArgs) XXX_Size

func (m *ServerArgs) XXX_Size() int

func (*ServerArgs) XXX_Unmarshal

func (m *ServerArgs) XXX_Unmarshal(b []byte) error

type ServerArgs_Mark

type ServerArgs_Mark struct {
	Mark *Mark `protobuf:"bytes,2,opt,name=mark,proto3,oneof"`
}

type ServerArgs_Setup

type ServerArgs_Setup struct {
	Setup *ServerConfig `protobuf:"bytes,1,opt,name=setup,proto3,oneof"`
}

type ServerConfig

type ServerConfig struct {
	ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
	SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
	// Port on which to listen. Zero means pick unused port.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Only for async server. Number of threads used to serve the requests.
	AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"`
	// Specify the number of cores to limit server to, if desired
	CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
	// payload config, used in generic server
	PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
	// Specify the cores we should run the server on, if desired
	CoreList             []int32  `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerConfig) Descriptor

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

func (*ServerConfig) GetAsyncServerThreads

func (m *ServerConfig) GetAsyncServerThreads() int32

func (*ServerConfig) GetCoreLimit

func (m *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList

func (m *ServerConfig) GetCoreList() []int32

func (*ServerConfig) GetPayloadConfig

func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort

func (m *ServerConfig) GetPort() int32

func (*ServerConfig) GetSecurityParams

func (m *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerType

func (m *ServerConfig) GetServerType() ServerType

func (*ServerConfig) ProtoMessage

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) Reset

func (m *ServerConfig) Reset()

func (*ServerConfig) String

func (m *ServerConfig) String() string

func (*ServerConfig) XXX_DiscardUnknown

func (m *ServerConfig) XXX_DiscardUnknown()

func (*ServerConfig) XXX_Marshal

func (m *ServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerConfig) XXX_Merge

func (m *ServerConfig) XXX_Merge(src proto.Message)

func (*ServerConfig) XXX_Size

func (m *ServerConfig) XXX_Size() int

func (*ServerConfig) XXX_Unmarshal

func (m *ServerConfig) XXX_Unmarshal(b []byte) error

type ServerStats

type ServerStats struct {
	// wall clock time change in seconds since last reset
	TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	// change in user time (in seconds) used by the server since last reset
	TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
	// change in server time (in seconds) used by the server process and all
	// threads since last reset
	TimeSystem           float64  `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerStats) Descriptor

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

func (*ServerStats) GetTimeElapsed

func (m *ServerStats) GetTimeElapsed() float64

func (*ServerStats) GetTimeSystem

func (m *ServerStats) GetTimeSystem() float64

func (*ServerStats) GetTimeUser

func (m *ServerStats) GetTimeUser() float64

func (*ServerStats) ProtoMessage

func (*ServerStats) ProtoMessage()

func (*ServerStats) Reset

func (m *ServerStats) Reset()

func (*ServerStats) String

func (m *ServerStats) String() string

func (*ServerStats) XXX_DiscardUnknown

func (m *ServerStats) XXX_DiscardUnknown()

func (*ServerStats) XXX_Marshal

func (m *ServerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStats) XXX_Merge

func (m *ServerStats) XXX_Merge(src proto.Message)

func (*ServerStats) XXX_Size

func (m *ServerStats) XXX_Size() int

func (*ServerStats) XXX_Unmarshal

func (m *ServerStats) XXX_Unmarshal(b []byte) error

type ServerStatus

type ServerStatus struct {
	Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// the port bound by the server
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Number of cores available to the server
	Cores                int32    `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerStatus) Descriptor

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

func (*ServerStatus) GetCores

func (m *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort

func (m *ServerStatus) GetPort() int32

func (*ServerStatus) GetStats

func (m *ServerStatus) GetStats() *ServerStats

func (*ServerStatus) ProtoMessage

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) Reset

func (m *ServerStatus) Reset()

func (*ServerStatus) String

func (m *ServerStatus) String() string

func (*ServerStatus) XXX_DiscardUnknown

func (m *ServerStatus) XXX_DiscardUnknown()

func (*ServerStatus) XXX_Marshal

func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStatus) XXX_Merge

func (m *ServerStatus) XXX_Merge(src proto.Message)

func (*ServerStatus) XXX_Size

func (m *ServerStatus) XXX_Size() int

func (*ServerStatus) XXX_Unmarshal

func (m *ServerStatus) XXX_Unmarshal(b []byte) error

type ServerType

type ServerType int32
const (
	ServerType_SYNC_SERVER          ServerType = 0
	ServerType_ASYNC_SERVER         ServerType = 1
	ServerType_ASYNC_GENERIC_SERVER ServerType = 2
)

func (ServerType) EnumDescriptor

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

func (ServerType) String

func (x ServerType) String() string

type SimpleProtoParams

type SimpleProtoParams struct {
	ReqSize              int32    `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
	RespSize             int32    `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimpleProtoParams) Descriptor

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

func (*SimpleProtoParams) GetReqSize

func (m *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize

func (m *SimpleProtoParams) GetRespSize() int32

func (*SimpleProtoParams) ProtoMessage

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams) Reset

func (m *SimpleProtoParams) Reset()

func (*SimpleProtoParams) String

func (m *SimpleProtoParams) String() string

func (*SimpleProtoParams) XXX_DiscardUnknown

func (m *SimpleProtoParams) XXX_DiscardUnknown()

func (*SimpleProtoParams) XXX_Marshal

func (m *SimpleProtoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleProtoParams) XXX_Merge

func (m *SimpleProtoParams) XXX_Merge(src proto.Message)

func (*SimpleProtoParams) XXX_Size

func (m *SimpleProtoParams) XXX_Size() int

func (*SimpleProtoParams) XXX_Unmarshal

func (m *SimpleProtoParams) XXX_Unmarshal(b []byte) error

type SimpleRequest

type SimpleRequest struct {
	// Desired payload type in the response from the server.
	// If response_type is RANDOM, server randomly chooses one from other formats.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Desired payload size in the response from the server.
	// If response_type is COMPRESSABLE, this denotes the size before compression.
	ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Whether SimpleResponse should include username.
	FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
	// Whether SimpleResponse should include OAuth scope.
	FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
	// Compression algorithm to be used by the server for the response (stream)
	ResponseCompression CompressionType `` /* 153-byte string literal not displayed */
	// Whether server should return a given status
	ResponseStatus       *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Unary request.

func (*SimpleRequest) Descriptor

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

func (*SimpleRequest) GetFillOauthScope

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillUsername

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompression

func (m *SimpleRequest) GetResponseCompression() CompressionType

func (*SimpleRequest) GetResponseSize

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType

func (m *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String

func (m *SimpleRequest) String() string

func (*SimpleRequest) XXX_DiscardUnknown

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal

func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleRequest) XXX_Merge

func (m *SimpleRequest) XXX_Merge(src proto.Message)

func (*SimpleRequest) XXX_Size

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal

func (m *SimpleRequest) XXX_Unmarshal(b []byte) error

type SimpleResponse

type SimpleResponse struct {
	// Payload to increase message size.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The user the request came from, for verifying authentication was
	// successful when the client expected it.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// OAuth scope.
	OauthScope           string   `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor

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

func (*SimpleResponse) GetOauthScope

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetUsername

func (m *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal

func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleResponse) XXX_Merge

func (m *SimpleResponse) XXX_Merge(src proto.Message)

func (*SimpleResponse) XXX_Size

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal

func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type StreamingInputCallRequest

type StreamingInputCallRequest struct {
	// Optional input payload sent along with the request.
	Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Client-streaming request.

func (*StreamingInputCallRequest) Descriptor

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

func (*StreamingInputCallRequest) GetPayload

func (m *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) Reset

func (m *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String

func (m *StreamingInputCallRequest) String() string

func (*StreamingInputCallRequest) XXX_DiscardUnknown

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal

func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallRequest) XXX_Merge

func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingInputCallRequest) XXX_Size

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal

func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingInputCallResponse

type StreamingInputCallResponse struct {
	// Aggregated size of payloads received from the client.
	AggregatedPayloadSize int32    `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor

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

func (*StreamingInputCallResponse) GetAggregatedPayloadSize

func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) Reset

func (m *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String

func (m *StreamingInputCallResponse) String() string

func (*StreamingInputCallResponse) XXX_DiscardUnknown

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal

func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallResponse) XXX_Merge

func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingInputCallResponse) XXX_Size

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal

func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error

type StreamingOutputCallRequest

type StreamingOutputCallRequest struct {
	// Desired payload type in the response from the server.
	// If response_type is RANDOM, the payload from each response in the stream
	// might be of different types. This is to simulate a mixed type of payload
	// stream.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Configuration for each expected response message.
	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Compression algorithm to be used by the server for the response (stream)
	ResponseCompression CompressionType `` /* 153-byte string literal not displayed */
	// Whether server should return a given status
	ResponseStatus       *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor

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

func (*StreamingOutputCallRequest) GetPayload

func (m *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseCompression

func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType

func (*StreamingOutputCallRequest) GetResponseParameters

func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters

func (*StreamingOutputCallRequest) GetResponseStatus

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType

func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) Reset

func (m *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String

func (m *StreamingOutputCallRequest) String() string

func (*StreamingOutputCallRequest) XXX_DiscardUnknown

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal

func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallRequest) XXX_Merge

func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingOutputCallRequest) XXX_Size

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal

func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingOutputCallResponse

type StreamingOutputCallResponse struct {
	// Payload to increase response size.
	Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Server-streaming response, as configured by the request and parameters.

func (*StreamingOutputCallResponse) Descriptor

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

func (*StreamingOutputCallResponse) GetPayload

func (m *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) Reset

func (m *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String

func (m *StreamingOutputCallResponse) String() string

func (*StreamingOutputCallResponse) XXX_DiscardUnknown

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal

func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallResponse) XXX_Merge

func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingOutputCallResponse) XXX_Size

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal

func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error

type UniformParams

type UniformParams struct {
	InterarrivalLo       float64  `protobuf:"fixed64,1,opt,name=interarrival_lo,json=interarrivalLo,proto3" json:"interarrival_lo,omitempty"`
	InterarrivalHi       float64  `protobuf:"fixed64,2,opt,name=interarrival_hi,json=interarrivalHi,proto3" json:"interarrival_hi,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UniformParams) Descriptor

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

func (*UniformParams) GetInterarrivalHi

func (m *UniformParams) GetInterarrivalHi() float64

func (*UniformParams) GetInterarrivalLo

func (m *UniformParams) GetInterarrivalLo() float64

func (*UniformParams) ProtoMessage

func (*UniformParams) ProtoMessage()

func (*UniformParams) Reset

func (m *UniformParams) Reset()

func (*UniformParams) String

func (m *UniformParams) String() string

func (*UniformParams) XXX_DiscardUnknown

func (m *UniformParams) XXX_DiscardUnknown()

func (*UniformParams) XXX_Marshal

func (m *UniformParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UniformParams) XXX_Merge

func (m *UniformParams) XXX_Merge(src proto.Message)

func (*UniformParams) XXX_Size

func (m *UniformParams) XXX_Size() int

func (*UniformParams) XXX_Unmarshal

func (m *UniformParams) XXX_Unmarshal(b []byte) error

type UnimplementedBenchmarkServiceServer

type UnimplementedBenchmarkServiceServer struct {
}

UnimplementedBenchmarkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBenchmarkServiceServer) StreamingCall

func (*UnimplementedBenchmarkServiceServer) UnaryCall

func (*UnimplementedBenchmarkServiceServer) UnconstrainedStreamingCall

type UnimplementedWorkerServiceServer

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServiceServer) CoreCount

func (*UnimplementedWorkerServiceServer) QuitWorker

func (*UnimplementedWorkerServiceServer) QuitWorker(ctx context.Context, req *Void) (*Void, error)

func (*UnimplementedWorkerServiceServer) RunClient

func (*UnimplementedWorkerServiceServer) RunServer

type Void

type Void struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Void) Descriptor

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

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) Reset

func (m *Void) Reset()

func (*Void) String

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal

func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Void) XXX_Merge

func (m *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal

func (m *Void) XXX_Unmarshal(b []byte) error

type WorkerServiceClient

type WorkerServiceClient interface {
	// Start server with specified workload.
	// First request sent specifies the ServerConfig followed by ServerStatus
	// response. After that, a "Mark" can be sent anytime to request the latest
	// stats. Closing the stream will initiate shutdown of the test server
	// and once the shutdown has finished, the OK status is sent to terminate
	// this RPC.
	RunServer(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunServerClient, error)
	// Start client with specified workload.
	// First request sent specifies the ClientConfig followed by ClientStatus
	// response. After that, a "Mark" can be sent anytime to request the latest
	// stats. Closing the stream will initiate shutdown of the test client
	// and once the shutdown has finished, the OK status is sent to terminate
	// this RPC.
	RunClient(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunClientClient, error)
	// Just return the core count - unary call
	CoreCount(ctx context.Context, in *CoreRequest, opts ...grpc.CallOption) (*CoreResponse, error)
	// Quit this worker
	QuitWorker(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error)
}

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/code.aliyun.com/yjkj.ink/grpc#ClientConn.NewStream.

func NewWorkerServiceClient

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceServer

type WorkerServiceServer interface {
	// Start server with specified workload.
	// First request sent specifies the ServerConfig followed by ServerStatus
	// response. After that, a "Mark" can be sent anytime to request the latest
	// stats. Closing the stream will initiate shutdown of the test server
	// and once the shutdown has finished, the OK status is sent to terminate
	// this RPC.
	RunServer(WorkerService_RunServerServer) error
	// Start client with specified workload.
	// First request sent specifies the ClientConfig followed by ClientStatus
	// response. After that, a "Mark" can be sent anytime to request the latest
	// stats. Closing the stream will initiate shutdown of the test client
	// and once the shutdown has finished, the OK status is sent to terminate
	// this RPC.
	RunClient(WorkerService_RunClientServer) error
	// Just return the core count - unary call
	CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)
	// Quit this worker
	QuitWorker(context.Context, *Void) (*Void, error)
}

WorkerServiceServer is the server API for WorkerService service.

type WorkerService_RunClientClient

type WorkerService_RunClientClient interface {
	Send(*ClientArgs) error
	Recv() (*ClientStatus, error)
	grpc.ClientStream
}

type WorkerService_RunClientServer

type WorkerService_RunClientServer interface {
	Send(*ClientStatus) error
	Recv() (*ClientArgs, error)
	grpc.ServerStream
}

type WorkerService_RunServerClient

type WorkerService_RunServerClient interface {
	Send(*ServerArgs) error
	Recv() (*ServerStatus, error)
	grpc.ClientStream
}

type WorkerService_RunServerServer

type WorkerService_RunServerServer interface {
	Send(*ServerStatus) error
	Recv() (*ServerArgs, error)
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL