grpc_testing

package
v0.0.0-...-5c63a66 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2022 License: Apache-2.0 Imports: 5 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/github.com/bwhour/go-grpc/lib/grpc#ClientConn.NewStream.

func NewBenchmarkServiceClient 

func NewBenchmarkServiceClient(cc *grpc.ClientConn) 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 (dst *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 (dst *ClientArgs) XXX_Merge(src proto.Message)

func (*ClientArgs) XXX_OneofFuncs 

func (*ClientArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *LoadParams) XXX_Merge(src proto.Message)

func (*LoadParams) XXX_OneofFuncs 

func (*LoadParams) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

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 (dst *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 (dst *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 (dst *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 (dst *PayloadConfig) XXX_Merge(src proto.Message)

func (*PayloadConfig) XXX_OneofFuncs 

func (*PayloadConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *ServerArgs) XXX_Merge(src proto.Message)

func (*ServerArgs) XXX_OneofFuncs 

func (*ServerArgs) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 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 (dst *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/github.com/bwhour/go-grpc/lib/grpc#ClientConn.NewStream.

func NewWorkerServiceClient 

func NewWorkerServiceClient(cc *grpc.ClientConn) 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.