grpc_testing

package
v1.33.1 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 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 RegisterBenchmarkServiceService added in v1.33.1 

func RegisterBenchmarkServiceService(s grpc.ServiceRegistrar, srv *BenchmarkServiceService)

RegisterBenchmarkServiceService registers a service implementation with a gRPC server.

func RegisterWorkerServiceService added in v1.33.1 

func RegisterWorkerServiceService(s grpc.ServiceRegistrar, srv *WorkerServiceService)

RegisterWorkerServiceService registers a service implementation with a gRPC server.

Types

type BenchmarkServiceClient 

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

BenchmarkServiceClient is the client API for BenchmarkService service.

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

func NewBenchmarkServiceClient 

func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient

type BenchmarkServiceService added in v1.33.1 

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

BenchmarkServiceService is the service API for BenchmarkService service. Fields should be assigned to their respective handler implementations only before RegisterBenchmarkServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

func NewBenchmarkServiceService added in v1.33.1 

func NewBenchmarkServiceService(s interface{}) *BenchmarkServiceService

NewBenchmarkServiceService creates a new BenchmarkServiceService containing the implemented methods of the BenchmarkService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.

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 added in v1.33.1 

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

type BenchmarkService_UnconstrainedStreamingCallServer added in v1.33.1 

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 added in v1.6.0 

func (m *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize added in v1.6.0 

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 added in v1.12.0 

func (m *ByteBufferParams) XXX_DiscardUnknown()

func (*ByteBufferParams) XXX_Marshal added in v1.12.0 

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

func (*ByteBufferParams) XXX_Merge added in v1.12.0 

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

func (*ByteBufferParams) XXX_Size added in v1.12.0 

func (m *ByteBufferParams) XXX_Size() int

func (*ByteBufferParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *ClientArgs) XXX_DiscardUnknown()

func (*ClientArgs) XXX_Marshal added in v1.12.0 

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

func (*ClientArgs) XXX_Merge added in v1.12.0 

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

func (*ClientArgs) XXX_OneofWrappers added in v1.33.1 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientArgs) XXX_Size added in v1.12.0 

func (m *ClientArgs) XXX_Size() int

func (*ClientArgs) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ClientConfig) GetAsyncClientThreads() int32

func (*ClientConfig) GetClientChannels added in v1.6.0 

func (m *ClientConfig) GetClientChannels() int32

func (*ClientConfig) GetClientType added in v1.6.0 

func (m *ClientConfig) GetClientType() ClientType

func (*ClientConfig) GetCoreLimit added in v1.6.0 

func (m *ClientConfig) GetCoreLimit() int32

func (*ClientConfig) GetCoreList added in v1.6.0 

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

func (*ClientConfig) GetHistogramParams 

func (m *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig) GetLoadParams 

func (m *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig) GetOutstandingRpcsPerChannel added in v1.6.0 

func (m *ClientConfig) GetOutstandingRpcsPerChannel() int32

func (*ClientConfig) GetPayloadConfig 

func (m *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig) GetRpcType added in v1.6.0 

func (m *ClientConfig) GetRpcType() RpcType

func (*ClientConfig) GetSecurityParams 

func (m *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig) GetServerTargets added in v1.6.0 

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 added in v1.12.0 

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal added in v1.12.0 

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

func (*ClientConfig) XXX_Merge added in v1.12.0 

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

func (*ClientConfig) XXX_Size added in v1.12.0 

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem added in v1.6.0 

func (m *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser added in v1.6.0 

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 added in v1.12.0 

func (m *ClientStats) XXX_DiscardUnknown()

func (*ClientStats) XXX_Marshal added in v1.12.0 

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

func (*ClientStats) XXX_Merge added in v1.12.0 

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

func (*ClientStats) XXX_Size added in v1.12.0 

func (m *ClientStats) XXX_Size() int

func (*ClientStats) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *ClientStatus) XXX_DiscardUnknown()

func (*ClientStatus) XXX_Marshal added in v1.12.0 

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

func (*ClientStatus) XXX_Merge added in v1.12.0 

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

func (*ClientStatus) XXX_Size added in v1.12.0 

func (m *ClientStatus) XXX_Size() int

func (*ClientStatus) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *ClosedLoopParams) XXX_DiscardUnknown()

func (*ClosedLoopParams) XXX_Marshal added in v1.12.0 

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

func (*ClosedLoopParams) XXX_Merge added in v1.12.0 

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

func (*ClosedLoopParams) XXX_Size added in v1.12.0 

func (m *ClosedLoopParams) XXX_Size() int

func (*ClosedLoopParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *ComplexProtoParams) XXX_DiscardUnknown()

func (*ComplexProtoParams) XXX_Marshal added in v1.12.0 

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

func (*ComplexProtoParams) XXX_Merge added in v1.12.0 

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

func (*ComplexProtoParams) XXX_Size added in v1.12.0 

func (m *ComplexProtoParams) XXX_Size() int

func (*ComplexProtoParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *CoreRequest) XXX_DiscardUnknown()

func (*CoreRequest) XXX_Marshal added in v1.12.0 

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

func (*CoreRequest) XXX_Merge added in v1.12.0 

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

func (*CoreRequest) XXX_Size added in v1.12.0 

func (m *CoreRequest) XXX_Size() int

func (*CoreRequest) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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 added in v1.12.0 

func (m *CoreResponse) XXX_DiscardUnknown()

func (*CoreResponse) XXX_Marshal added in v1.12.0 

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

func (*CoreResponse) XXX_Merge added in v1.12.0 

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

func (*CoreResponse) XXX_Size added in v1.12.0 

func (m *CoreResponse) XXX_Size() int

func (*CoreResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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 added in v1.12.0 

func (m *DeterministicParams) XXX_DiscardUnknown()

func (*DeterministicParams) XXX_Marshal added in v1.12.0 

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

func (*DeterministicParams) XXX_Merge added in v1.12.0 

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

func (*DeterministicParams) XXX_Size added in v1.12.0 

func (m *DeterministicParams) XXX_Size() int

func (*DeterministicParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage added in v1.6.0 

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 added in v1.12.0 

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal added in v1.12.0 

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

func (*EchoStatus) XXX_Merge added in v1.12.0 

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

func (*EchoStatus) XXX_Size added in v1.12.0 

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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

func (*HistogramData) GetCount added in v1.6.0 

func (m *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen added in v1.6.0 

func (m *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen added in v1.6.0 

func (m *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum added in v1.6.0 

func (m *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares added in v1.6.0 

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 added in v1.12.0 

func (m *HistogramData) XXX_DiscardUnknown()

func (*HistogramData) XXX_Marshal added in v1.12.0 

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

func (*HistogramData) XXX_Merge added in v1.12.0 

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

func (*HistogramData) XXX_Size added in v1.12.0 

func (m *HistogramData) XXX_Size() int

func (*HistogramData) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution added in v1.6.0 

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 added in v1.12.0 

func (m *HistogramParams) XXX_DiscardUnknown()

func (*HistogramParams) XXX_Marshal added in v1.12.0 

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

func (*HistogramParams) XXX_Merge added in v1.12.0 

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

func (*HistogramParams) XXX_Size added in v1.12.0 

func (m *HistogramParams) XXX_Size() int

func (*HistogramParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *LoadParams) XXX_DiscardUnknown()

func (*LoadParams) XXX_Marshal added in v1.12.0 

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

func (*LoadParams) XXX_Merge added in v1.12.0 

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

func (*LoadParams) XXX_OneofWrappers added in v1.33.1 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoadParams) XXX_Size added in v1.12.0 

func (m *LoadParams) XXX_Size() int

func (*LoadParams) XXX_Unmarshal added in v1.12.0 

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_ added in v1.6.0 

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 added in v1.12.0 

func (m *Mark) XXX_DiscardUnknown()

func (*Mark) XXX_Marshal added in v1.12.0 

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

func (*Mark) XXX_Merge added in v1.12.0 

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

func (*Mark) XXX_Size added in v1.12.0 

func (m *Mark) XXX_Size() int

func (*Mark) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ParetoParams) GetAlpha() float64

func (*ParetoParams) GetInterarrivalBase added in v1.6.0 

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 added in v1.12.0 

func (m *ParetoParams) XXX_DiscardUnknown()

func (*ParetoParams) XXX_Marshal added in v1.12.0 

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

func (*ParetoParams) XXX_Merge added in v1.12.0 

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

func (*ParetoParams) XXX_Size added in v1.12.0 

func (m *ParetoParams) XXX_Size() int

func (*ParetoParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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

func (*Payload) GetType added in v1.6.0 

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 added in v1.12.0 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal added in v1.12.0 

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

func (*Payload) XXX_Merge added in v1.12.0 

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

func (*Payload) XXX_Size added in v1.12.0 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *PayloadConfig) XXX_DiscardUnknown()

func (*PayloadConfig) XXX_Marshal added in v1.12.0 

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

func (*PayloadConfig) XXX_Merge added in v1.12.0 

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

func (*PayloadConfig) XXX_OneofWrappers added in v1.33.1 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PayloadConfig) XXX_Size added in v1.12.0 

func (m *PayloadConfig) XXX_Size() int

func (*PayloadConfig) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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 added in v1.12.0 

func (m *PoissonParams) XXX_DiscardUnknown()

func (*PoissonParams) XXX_Marshal added in v1.12.0 

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

func (*PoissonParams) XXX_Merge added in v1.12.0 

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

func (*PoissonParams) XXX_Size added in v1.12.0 

func (m *PoissonParams) XXX_Size() int

func (*PoissonParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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

func (*ReconnectInfo) GetPassed added in v1.6.0 

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 added in v1.12.0 

func (m *ReconnectInfo) XXX_DiscardUnknown()

func (*ReconnectInfo) XXX_Marshal added in v1.12.0 

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

func (*ReconnectInfo) XXX_Merge added in v1.12.0 

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

func (*ReconnectInfo) XXX_Size added in v1.12.0 

func (m *ReconnectInfo) XXX_Size() int

func (*ReconnectInfo) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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 added in v1.12.0 

func (m *ReconnectParams) XXX_DiscardUnknown()

func (*ReconnectParams) XXX_Marshal added in v1.12.0 

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

func (*ReconnectParams) XXX_Merge added in v1.12.0 

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

func (*ReconnectParams) XXX_Size added in v1.12.0 

func (m *ReconnectParams) XXX_Size() int

func (*ReconnectParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize added in v1.6.0 

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 added in v1.12.0 

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal added in v1.12.0 

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

func (*ResponseParameters) XXX_Merge added in v1.12.0 

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

func (*ResponseParameters) XXX_Size added in v1.12.0 

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig 

func (m *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName added in v1.6.0 

func (m *Scenario) GetName() string

func (*Scenario) GetNumClients added in v1.6.0 

func (m *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers added in v1.6.0 

func (m *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig 

func (m *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount added in v1.6.0 

func (m *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds added in v1.6.0 

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 added in v1.12.0 

func (m *Scenario) XXX_DiscardUnknown()

func (*Scenario) XXX_Marshal added in v1.12.0 

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

func (*Scenario) XXX_Merge added in v1.12.0 

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

func (*Scenario) XXX_Size added in v1.12.0 

func (m *Scenario) XXX_Size() int

func (*Scenario) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *Scenarios) XXX_DiscardUnknown()

func (*Scenarios) XXX_Marshal added in v1.12.0 

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

func (*Scenarios) XXX_Merge added in v1.12.0 

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

func (*Scenarios) XXX_Size added in v1.12.0 

func (m *Scenarios) XXX_Size() int

func (*Scenarios) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa added in v1.6.0 

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 added in v1.12.0 

func (m *SecurityParams) XXX_DiscardUnknown()

func (*SecurityParams) XXX_Marshal added in v1.12.0 

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

func (*SecurityParams) XXX_Merge added in v1.12.0 

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

func (*SecurityParams) XXX_Size added in v1.12.0 

func (m *SecurityParams) XXX_Size() int

func (*SecurityParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *ServerArgs) XXX_DiscardUnknown()

func (*ServerArgs) XXX_Marshal added in v1.12.0 

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

func (*ServerArgs) XXX_Merge added in v1.12.0 

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

func (*ServerArgs) XXX_OneofWrappers added in v1.33.1 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerArgs) XXX_Size added in v1.12.0 

func (m *ServerArgs) XXX_Size() int

func (*ServerArgs) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ServerConfig) GetAsyncServerThreads() int32

func (*ServerConfig) GetCoreLimit added in v1.6.0 

func (m *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList added in v1.6.0 

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

func (*ServerConfig) GetPayloadConfig 

func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort added in v1.6.0 

func (m *ServerConfig) GetPort() int32

func (*ServerConfig) GetSecurityParams 

func (m *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerType added in v1.6.0 

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 added in v1.12.0 

func (m *ServerConfig) XXX_DiscardUnknown()

func (*ServerConfig) XXX_Marshal added in v1.12.0 

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

func (*ServerConfig) XXX_Merge added in v1.12.0 

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

func (*ServerConfig) XXX_Size added in v1.12.0 

func (m *ServerConfig) XXX_Size() int

func (*ServerConfig) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ServerStats) GetTimeElapsed() float64

func (*ServerStats) GetTimeSystem added in v1.6.0 

func (m *ServerStats) GetTimeSystem() float64

func (*ServerStats) GetTimeUser added in v1.6.0 

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 added in v1.12.0 

func (m *ServerStats) XXX_DiscardUnknown()

func (*ServerStats) XXX_Marshal added in v1.12.0 

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

func (*ServerStats) XXX_Merge added in v1.12.0 

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

func (*ServerStats) XXX_Size added in v1.12.0 

func (m *ServerStats) XXX_Size() int

func (*ServerStats) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort added in v1.6.0 

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 added in v1.12.0 

func (m *ServerStatus) XXX_DiscardUnknown()

func (*ServerStatus) XXX_Marshal added in v1.12.0 

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

func (*ServerStatus) XXX_Merge added in v1.12.0 

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

func (*ServerStatus) XXX_Size added in v1.12.0 

func (m *ServerStatus) XXX_Size() int

func (*ServerStatus) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize added in v1.6.0 

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 added in v1.12.0 

func (m *SimpleProtoParams) XXX_DiscardUnknown()

func (*SimpleProtoParams) XXX_Marshal added in v1.12.0 

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

func (*SimpleProtoParams) XXX_Merge added in v1.12.0 

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

func (*SimpleProtoParams) XXX_Size added in v1.12.0 

func (m *SimpleProtoParams) XXX_Size() int

func (*SimpleProtoParams) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillUsername added in v1.6.0 

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload 

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompression added in v1.6.0 

func (m *SimpleRequest) GetResponseCompression() CompressionType

func (*SimpleRequest) GetResponseSize added in v1.6.0 

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus 

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType added in v1.6.0 

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 added in v1.12.0 

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal added in v1.12.0 

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

func (*SimpleRequest) XXX_Merge added in v1.12.0 

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

func (*SimpleRequest) XXX_Size added in v1.12.0 

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload 

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetUsername added in v1.6.0 

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 added in v1.12.0 

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal added in v1.12.0 

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

func (*SimpleResponse) XXX_Merge added in v1.12.0 

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

func (*SimpleResponse) XXX_Size added in v1.12.0 

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal added in v1.12.0 

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

func (*StreamingInputCallRequest) XXX_Merge added in v1.12.0 

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

func (*StreamingInputCallRequest) XXX_Size added in v1.12.0 

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

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 added in v1.12.0 

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal added in v1.12.0 

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

func (*StreamingInputCallResponse) XXX_Merge added in v1.12.0 

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

func (*StreamingInputCallResponse) XXX_Size added in v1.12.0 

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *StreamingOutputCallRequest) GetResponseCompression() CompressionType

func (*StreamingOutputCallRequest) GetResponseParameters 

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

func (*StreamingOutputCallRequest) GetResponseStatus 

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType added in v1.6.0 

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 added in v1.12.0 

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal added in v1.12.0 

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

func (*StreamingOutputCallRequest) XXX_Merge added in v1.12.0 

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

func (*StreamingOutputCallRequest) XXX_Size added in v1.12.0 

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal added in v1.12.0 

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 added in v1.12.0 

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal added in v1.12.0 

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

func (*StreamingOutputCallResponse) XXX_Merge added in v1.12.0 

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

func (*StreamingOutputCallResponse) XXX_Size added in v1.12.0 

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal added in v1.12.0 

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 added in v1.6.0 

func (m *UniformParams) GetInterarrivalHi() float64

func (*UniformParams) GetInterarrivalLo added in v1.6.0 

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 added in v1.12.0 

func (m *UniformParams) XXX_DiscardUnknown()

func (*UniformParams) XXX_Marshal added in v1.12.0 

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

func (*UniformParams) XXX_Merge added in v1.12.0 

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

func (*UniformParams) XXX_Size added in v1.12.0 

func (m *UniformParams) XXX_Size() int

func (*UniformParams) XXX_Unmarshal added in v1.12.0 

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

type UnstableBenchmarkServiceService added in v1.33.1 

type UnstableBenchmarkServiceService 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
}

UnstableBenchmarkServiceService is the service API for BenchmarkService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.

type UnstableWorkerServiceService added in v1.33.1 

type UnstableWorkerServiceService 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)
}

UnstableWorkerServiceService is the service API for WorkerService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.

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 added in v1.12.0 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal added in v1.12.0 

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

func (*Void) XXX_Merge added in v1.12.0 

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

func (*Void) XXX_Size added in v1.12.0 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal added in v1.12.0 

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://pkg.go.dev/github.com/fgiudici/grpc-go/?tab=doc#ClientConn.NewStream.

func NewWorkerServiceClient 

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceService added in v1.33.1 

type WorkerServiceService struct {
	// 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 func(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 func(WorkerService_RunClientServer) error
	// Just return the core count - unary call
	CoreCount func(context.Context, *CoreRequest) (*CoreResponse, error)
	// Quit this worker
	QuitWorker func(context.Context, *Void) (*Void, error)
}

WorkerServiceService is the service API for WorkerService service. Fields should be assigned to their respective handler implementations only before RegisterWorkerServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

func NewWorkerServiceService added in v1.33.1 

func NewWorkerServiceService(s interface{}) *WorkerServiceService

NewWorkerServiceService creates a new WorkerServiceService containing the implemented methods of the WorkerService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.

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.