grpc_testing

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Dec 14, 2020 License: Apache-2.0 Imports: 8 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",
	2: "OTHER_CLIENT",
}
View Source
var ClientType_value = map[string]int32{
	"SYNC_CLIENT":  0,
	"ASYNC_CLIENT": 1,
	"OTHER_CLIENT": 2,
}
View Source
var GrpclbRouteType_name = map[int32]string{
	0: "GRPCLB_ROUTE_TYPE_UNKNOWN",
	1: "GRPCLB_ROUTE_TYPE_FALLBACK",
	2: "GRPCLB_ROUTE_TYPE_BACKEND",
}
View Source
var GrpclbRouteType_value = map[string]int32{
	"GRPCLB_ROUTE_TYPE_UNKNOWN":  0,
	"GRPCLB_ROUTE_TYPE_FALLBACK": 1,
	"GRPCLB_ROUTE_TYPE_BACKEND":  2,
}
View Source
var PayloadType_name = map[int32]string{
	0: "COMPRESSABLE",
}
View Source
var PayloadType_value = map[string]int32{
	"COMPRESSABLE": 0,
}
View Source
var RpcType_name = map[int32]string{
	0: "UNARY",
	1: "STREAMING",
	2: "STREAMING_FROM_CLIENT",
	3: "STREAMING_FROM_SERVER",
	4: "STREAMING_BOTH_WAYS",
}
View Source
var RpcType_value = map[string]int32{
	"UNARY":                 0,
	"STREAMING":             1,
	"STREAMING_FROM_CLIENT": 2,
	"STREAMING_FROM_SERVER": 3,
	"STREAMING_BOTH_WAYS":   4,
}
View Source
var ServerType_name = map[int32]string{
	0: "SYNC_SERVER",
	1: "ASYNC_SERVER",
	2: "ASYNC_GENERIC_SERVER",
	3: "OTHER_SERVER",
}
View Source
var ServerType_value = map[string]int32{
	"SYNC_SERVER":          0,
	"ASYNC_SERVER":         1,
	"ASYNC_GENERIC_SERVER": 2,
	"OTHER_SERVER":         3,
}

Functions

func RegisterBenchmarkServiceServer

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

func RegisterReportQpsScenarioServiceServer

func RegisterReportQpsScenarioServiceServer(s *grpc.Server, srv ReportQpsScenarioServiceServer)

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)
	// Repeated sequence of one request followed by one response.
	// Should be called streaming ping-pong
	// The server returns the client payload as-is on each response
	StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)
	// Single-sided unbounded streaming from client to server
	// The server returns the client payload as-is once the client does WritesDone
	StreamingFromClient(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingFromClientClient, error)
	// Single-sided unbounded streaming from server to client
	// The server repeatedly returns the client payload as-is
	StreamingFromServer(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (BenchmarkService_StreamingFromServerClient, error)
	// Two-sided unbounded streaming between server to client
	// Both sides send the content of their own choice to the other
	StreamingBothWays(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingBothWaysClient, 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/google.golang.org/grpc#ClientConn.NewStream.

type BenchmarkServiceServer

type BenchmarkServiceServer interface {
	// One request followed by one response.
	// The server returns the client payload as-is.
	UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
	// Repeated sequence of one request followed by one response.
	// Should be called streaming ping-pong
	// The server returns the client payload as-is on each response
	StreamingCall(BenchmarkService_StreamingCallServer) error
	// Single-sided unbounded streaming from client to server
	// The server returns the client payload as-is once the client does WritesDone
	StreamingFromClient(BenchmarkService_StreamingFromClientServer) error
	// Single-sided unbounded streaming from server to client
	// The server repeatedly returns the client payload as-is
	StreamingFromServer(*SimpleRequest, BenchmarkService_StreamingFromServerServer) error
	// Two-sided unbounded streaming between server to client
	// Both sides send the content of their own choice to the other
	StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error
}

BenchmarkServiceServer is the server API for BenchmarkService service.

type BenchmarkService_StreamingBothWaysClient

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

type BenchmarkService_StreamingBothWaysServer

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

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_StreamingFromClientClient

type BenchmarkService_StreamingFromClientClient interface {
	Send(*SimpleRequest) error
	CloseAndRecv() (*SimpleResponse, error)
	grpc.ClientStream
}

type BenchmarkService_StreamingFromClientServer

type BenchmarkService_StreamingFromClientServer interface {
	SendAndClose(*SimpleResponse) error
	Recv() (*SimpleRequest, error)
	grpc.ServerStream
}

type BenchmarkService_StreamingFromServerClient

type BenchmarkService_StreamingFromServerClient interface {
	Recv() (*SimpleResponse, error)
	grpc.ClientStream
}

type BenchmarkService_StreamingFromServerServer

type BenchmarkService_StreamingFromServerServer interface {
	Send(*SimpleResponse) error
	grpc.ServerStream
}

type BoolValue

type BoolValue struct {
	// The bool value.
	Value                bool     `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TODO(dgq): Go back to using well-known types once https://github.com/grpc/grpc/issues/6980 has been fixed. import "google/protobuf/wrappers.proto";

func (*BoolValue) Descriptor

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

func (*BoolValue) GetValue

func (m *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage

func (*BoolValue) ProtoMessage()

func (*BoolValue) Reset

func (m *BoolValue) Reset()

func (*BoolValue) String

func (m *BoolValue) String() string

func (*BoolValue) XXX_DiscardUnknown

func (m *BoolValue) XXX_DiscardUnknown()

func (*BoolValue) XXX_Marshal

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

func (*BoolValue) XXX_Merge

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

func (*BoolValue) XXX_Size

func (m *BoolValue) XXX_Size() int

func (*BoolValue) XXX_Unmarshal

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

type ByteBufferParams

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

func (*ByteBufferParams) Descriptor

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

func (*ByteBufferParams) GetReqSize

func (m *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize

func (m *ByteBufferParams) GetRespSize() int32

func (*ByteBufferParams) ProtoMessage

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams) Reset

func (m *ByteBufferParams) Reset()

func (*ByteBufferParams) String

func (m *ByteBufferParams) String() string

func (*ByteBufferParams) XXX_DiscardUnknown

func (m *ByteBufferParams) XXX_DiscardUnknown()

func (*ByteBufferParams) XXX_Marshal

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

func (*ByteBufferParams) XXX_Merge

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

func (*ByteBufferParams) XXX_Size

func (m *ByteBufferParams) XXX_Size() int

func (*ByteBufferParams) XXX_Unmarshal

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

type ChannelArg

type ChannelArg struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*ChannelArg_StrValue
	//	*ChannelArg_IntValue
	Value                isChannelArg_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ChannelArg) Descriptor

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

func (*ChannelArg) GetIntValue

func (m *ChannelArg) GetIntValue() int32

func (*ChannelArg) GetName

func (m *ChannelArg) GetName() string

func (*ChannelArg) GetStrValue

func (m *ChannelArg) GetStrValue() string

func (*ChannelArg) GetValue

func (m *ChannelArg) GetValue() isChannelArg_Value

func (*ChannelArg) ProtoMessage

func (*ChannelArg) ProtoMessage()

func (*ChannelArg) Reset

func (m *ChannelArg) Reset()

func (*ChannelArg) String

func (m *ChannelArg) String() string

func (*ChannelArg) XXX_DiscardUnknown

func (m *ChannelArg) XXX_DiscardUnknown()

func (*ChannelArg) XXX_Marshal

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

func (*ChannelArg) XXX_Merge

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

func (*ChannelArg) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ChannelArg) XXX_Size

func (m *ChannelArg) XXX_Size() int

func (*ChannelArg) XXX_Unmarshal

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

type ChannelArg_IntValue

type ChannelArg_IntValue struct {
	IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ChannelArg_StrValue

type ChannelArg_StrValue struct {
	StrValue string `protobuf:"bytes,2,opt,name=str_value,json=strValue,proto3,oneof"`
}

type ClientArgs

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

func (*ClientArgs) Descriptor

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

func (*ClientArgs) GetArgtype

func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark

func (m *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup

func (m *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) ProtoMessage

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) Reset

func (m *ClientArgs) Reset()

func (*ClientArgs) String

func (m *ClientArgs) String() string

func (*ClientArgs) XXX_DiscardUnknown

func (m *ClientArgs) XXX_DiscardUnknown()

func (*ClientArgs) XXX_Marshal

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

func (*ClientArgs) XXX_Merge

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

func (*ClientArgs) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientArgs) XXX_Size

func (m *ClientArgs) XXX_Size() int

func (*ClientArgs) XXX_Unmarshal

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

type ClientArgs_Mark

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

type ClientArgs_Setup

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

type ClientConfig

type ClientConfig struct {
	// List of targets to connect to. At least one target needs to be specified.
	ServerTargets  []string        `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"`
	ClientType     ClientType      `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
	SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
	// How many concurrent RPCs to start for each channel.
	// For synchronous client, use a separate thread for each outstanding RPC.
	OutstandingRpcsPerChannel int32 `` /* 141-byte string literal not displayed */
	// Number of independent client channels to create.
	// i-th channel will connect to server_target[i % server_targets.size()]
	ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`
	// Only for async client. Number of threads to use to start/manage RPCs.
	AsyncClientThreads int32   `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"`
	RpcType            RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"`
	// The requested load for the entire client (aggregated over all the threads).
	LoadParams      *LoadParams      `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"`
	PayloadConfig   *PayloadConfig   `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
	HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"`
	// Specify the cores we should run the client on, if desired
	CoreList  []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
	CoreLimit int32   `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
	// If we use an OTHER_CLIENT client_type, this string gives more detail
	OtherClientApi string        `protobuf:"bytes,15,opt,name=other_client_api,json=otherClientApi,proto3" json:"other_client_api,omitempty"`
	ChannelArgs    []*ChannelArg `protobuf:"bytes,16,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"`
	// Number of threads that share each completion queue
	ThreadsPerCq int32 `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
	// Number of messages on a stream before it gets finished/restarted
	MessagesPerStream int32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"`
	// Use coalescing API when possible.
	UseCoalesceApi       bool     `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,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) GetChannelArgs

func (m *ClientConfig) GetChannelArgs() []*ChannelArg

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) GetMessagesPerStream

func (m *ClientConfig) GetMessagesPerStream() int32

func (*ClientConfig) GetOtherClientApi

func (m *ClientConfig) GetOtherClientApi() string

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) GetThreadsPerCq

func (m *ClientConfig) GetThreadsPerCq() int32

func (*ClientConfig) GetUseCoalesceApi

func (m *ClientConfig) GetUseCoalesceApi() bool

func (*ClientConfig) ProtoMessage

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset

func (m *ClientConfig) Reset()

func (*ClientConfig) String

func (m *ClientConfig) String() string

func (*ClientConfig) XXX_DiscardUnknown

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal

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

func (*ClientConfig) XXX_Merge

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

func (*ClientConfig) XXX_Size

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal

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

type ClientStats

type ClientStats struct {
	// Latency histogram. Data points are in nanoseconds.
	Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"`
	// See ServerStats for details.
	TimeElapsed float64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	TimeUser    float64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
	TimeSystem  float64 `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
	// Number of failed requests (one row per status code seen)
	RequestResults []*RequestResultCount `protobuf:"bytes,5,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
	// Number of polls called inside completion queue
	CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
	// Core library stats
	CoreStats            *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ClientStats) Descriptor

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

func (*ClientStats) GetCoreStats

func (m *ClientStats) GetCoreStats() *core.Stats

func (*ClientStats) GetCqPollCount

func (m *ClientStats) GetCqPollCount() uint64

func (*ClientStats) GetLatencies

func (m *ClientStats) GetLatencies() *HistogramData

func (*ClientStats) GetRequestResults

func (m *ClientStats) GetRequestResults() []*RequestResultCount

func (*ClientStats) GetTimeElapsed

func (m *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem

func (m *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser

func (m *ClientStats) GetTimeUser() float64

func (*ClientStats) ProtoMessage

func (*ClientStats) ProtoMessage()

func (*ClientStats) Reset

func (m *ClientStats) Reset()

func (*ClientStats) String

func (m *ClientStats) String() string

func (*ClientStats) XXX_DiscardUnknown

func (m *ClientStats) XXX_DiscardUnknown()

func (*ClientStats) XXX_Marshal

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

func (*ClientStats) XXX_Merge

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

func (*ClientStats) XXX_Size

func (m *ClientStats) XXX_Size() int

func (*ClientStats) XXX_Unmarshal

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

type ClientStatus

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

func (*ClientStatus) Descriptor

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

func (*ClientStatus) GetStats

func (m *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) ProtoMessage

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) Reset

func (m *ClientStatus) Reset()

func (*ClientStatus) String

func (m *ClientStatus) String() string

func (*ClientStatus) XXX_DiscardUnknown

func (m *ClientStatus) XXX_DiscardUnknown()

func (*ClientStatus) XXX_Marshal

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

func (*ClientStatus) XXX_Merge

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

func (*ClientStatus) XXX_Size

func (m *ClientStatus) XXX_Size() int

func (*ClientStatus) XXX_Unmarshal

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

type ClientType

type ClientType int32
const (
	// Many languages support a basic distinction between using
	// sync or async client, and this allows the specification
	ClientType_SYNC_CLIENT  ClientType = 0
	ClientType_ASYNC_CLIENT ClientType = 1
	ClientType_OTHER_CLIENT ClientType = 2
)

func (ClientType) EnumDescriptor

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

func (ClientType) String

func (x ClientType) String() string

type ClosedLoopParams

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

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

func (*ClosedLoopParams) Descriptor

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

func (*ClosedLoopParams) ProtoMessage

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams) Reset

func (m *ClosedLoopParams) Reset()

func (*ClosedLoopParams) String

func (m *ClosedLoopParams) String() string

func (*ClosedLoopParams) XXX_DiscardUnknown

func (m *ClosedLoopParams) XXX_DiscardUnknown()

func (*ClosedLoopParams) XXX_Marshal

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

func (*ClosedLoopParams) XXX_Merge

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

func (*ClosedLoopParams) XXX_Size

func (m *ClosedLoopParams) XXX_Size() int

func (*ClosedLoopParams) XXX_Unmarshal

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

type ComplexProtoParams

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

func (*ComplexProtoParams) Descriptor

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

func (*ComplexProtoParams) ProtoMessage

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams) Reset

func (m *ComplexProtoParams) Reset()

func (*ComplexProtoParams) String

func (m *ComplexProtoParams) String() string

func (*ComplexProtoParams) XXX_DiscardUnknown

func (m *ComplexProtoParams) XXX_DiscardUnknown()

func (*ComplexProtoParams) XXX_Marshal

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

func (*ComplexProtoParams) XXX_Merge

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

func (*ComplexProtoParams) XXX_Size

func (m *ComplexProtoParams) XXX_Size() int

func (*ComplexProtoParams) XXX_Unmarshal

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

type CoreRequest

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

func (*CoreRequest) Descriptor

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

func (*CoreRequest) ProtoMessage

func (*CoreRequest) ProtoMessage()

func (*CoreRequest) Reset

func (m *CoreRequest) Reset()

func (*CoreRequest) String

func (m *CoreRequest) String() string

func (*CoreRequest) XXX_DiscardUnknown

func (m *CoreRequest) XXX_DiscardUnknown()

func (*CoreRequest) XXX_Marshal

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

func (*CoreRequest) XXX_Merge

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

func (*CoreRequest) XXX_Size

func (m *CoreRequest) XXX_Size() int

func (*CoreRequest) XXX_Unmarshal

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

type CoreResponse

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

func (*CoreResponse) Descriptor

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

func (*CoreResponse) GetCores

func (m *CoreResponse) GetCores() int32

func (*CoreResponse) ProtoMessage

func (*CoreResponse) ProtoMessage()

func (*CoreResponse) Reset

func (m *CoreResponse) Reset()

func (*CoreResponse) String

func (m *CoreResponse) String() string

func (*CoreResponse) XXX_DiscardUnknown

func (m *CoreResponse) XXX_DiscardUnknown()

func (*CoreResponse) XXX_Marshal

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

func (*CoreResponse) XXX_Merge

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

func (*CoreResponse) XXX_Size

func (m *CoreResponse) XXX_Size() int

func (*CoreResponse) XXX_Unmarshal

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

type EchoStatus

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

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

func (*EchoStatus) Descriptor

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

func (*EchoStatus) GetCode

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage

func (m *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) Reset

func (m *EchoStatus) Reset()

func (*EchoStatus) String

func (m *EchoStatus) String() string

func (*EchoStatus) XXX_DiscardUnknown

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal

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

func (*EchoStatus) XXX_Merge

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

func (*EchoStatus) XXX_Size

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal

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

type GrpclbRouteType

type GrpclbRouteType int32

The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependant.

const (
	// Server didn't detect the route that a client took to reach it.
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0
	// Indicates that a client reached a server via gRPCLB fallback.
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1
	// Indicates that a client reached a server as a gRPCLB-given backend.
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND GrpclbRouteType = 2
)

func (GrpclbRouteType) EnumDescriptor

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

func (GrpclbRouteType) String

func (x GrpclbRouteType) String() string

type HistogramData

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

Histogram data based on grpc/support/histogram.c

func (*HistogramData) Descriptor

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

func (*HistogramData) GetBucket

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

func (*HistogramData) GetCount

func (m *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen

func (m *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen

func (m *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum

func (m *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares

func (m *HistogramData) GetSumOfSquares() float64

func (*HistogramData) ProtoMessage

func (*HistogramData) ProtoMessage()

func (*HistogramData) Reset

func (m *HistogramData) Reset()

func (*HistogramData) String

func (m *HistogramData) String() string

func (*HistogramData) XXX_DiscardUnknown

func (m *HistogramData) XXX_DiscardUnknown()

func (*HistogramData) XXX_Marshal

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

func (*HistogramData) XXX_Merge

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

func (*HistogramData) XXX_Size

func (m *HistogramData) XXX_Size() int

func (*HistogramData) XXX_Unmarshal

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

type HistogramParams

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

Histogram params based on grpc/support/histogram.c

func (*HistogramParams) Descriptor

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

func (*HistogramParams) GetMaxPossible

func (m *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution

func (m *HistogramParams) GetResolution() float64

func (*HistogramParams) ProtoMessage

func (*HistogramParams) ProtoMessage()

func (*HistogramParams) Reset

func (m *HistogramParams) Reset()

func (*HistogramParams) String

func (m *HistogramParams) String() string

func (*HistogramParams) XXX_DiscardUnknown

func (m *HistogramParams) XXX_DiscardUnknown()

func (*HistogramParams) XXX_Marshal

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

func (*HistogramParams) XXX_Merge

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

func (*HistogramParams) XXX_Size

func (m *HistogramParams) XXX_Size() int

func (*HistogramParams) XXX_Unmarshal

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

type LoadParams

type LoadParams struct {
	// Types that are valid to be assigned to Load:
	//	*LoadParams_ClosedLoop
	//	*LoadParams_Poisson
	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) GetLoad

func (m *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPoisson

func (m *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) ProtoMessage

func (*LoadParams) ProtoMessage()

func (*LoadParams) Reset

func (m *LoadParams) Reset()

func (*LoadParams) String

func (m *LoadParams) String() string

func (*LoadParams) XXX_DiscardUnknown

func (m *LoadParams) XXX_DiscardUnknown()

func (*LoadParams) XXX_Marshal

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

func (*LoadParams) XXX_Merge

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

func (*LoadParams) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LoadParams) XXX_Size

func (m *LoadParams) XXX_Size() int

func (*LoadParams) XXX_Unmarshal

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

type LoadParams_ClosedLoop

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

type LoadParams_Poisson

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

type Mark

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

Request current stats

func (*Mark) Descriptor

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

func (*Mark) GetReset_

func (m *Mark) GetReset_() bool

func (*Mark) ProtoMessage

func (*Mark) ProtoMessage()

func (*Mark) Reset

func (m *Mark) Reset()

func (*Mark) String

func (m *Mark) String() string

func (*Mark) XXX_DiscardUnknown

func (m *Mark) XXX_DiscardUnknown()

func (*Mark) XXX_Marshal

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

func (*Mark) XXX_Merge

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

func (*Mark) XXX_Size

func (m *Mark) XXX_Size() int

func (*Mark) XXX_Unmarshal

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

type Payload

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

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

func (*Payload) Descriptor

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

func (*Payload) GetBody

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

func (*Payload) GetType

func (m *Payload) GetType() PayloadType

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

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

func (*Payload) XXX_Merge

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

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

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

type PayloadConfig

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

func (*PayloadConfig) Descriptor

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

func (*PayloadConfig) GetBytebufParams

func (m *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams

func (m *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload

func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams

func (m *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) ProtoMessage

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) Reset

func (m *PayloadConfig) Reset()

func (*PayloadConfig) String

func (m *PayloadConfig) String() string

func (*PayloadConfig) XXX_DiscardUnknown

func (m *PayloadConfig) XXX_DiscardUnknown()

func (*PayloadConfig) XXX_Marshal

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

func (*PayloadConfig) XXX_Merge

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

func (*PayloadConfig) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PayloadConfig) XXX_Size

func (m *PayloadConfig) XXX_Size() int

func (*PayloadConfig) XXX_Unmarshal

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

type PayloadConfig_BytebufParams

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

type PayloadConfig_ComplexParams

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

type PayloadConfig_SimpleParams

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

type PayloadType

type PayloadType int32

The type of payload that should be returned.

const (
	// Compressable text format.
	PayloadType_COMPRESSABLE PayloadType = 0
)

func (PayloadType) EnumDescriptor

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

func (PayloadType) String

func (x PayloadType) String() string

type PoissonParams

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

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

func (*PoissonParams) Descriptor

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

func (*PoissonParams) GetOfferedLoad

func (m *PoissonParams) GetOfferedLoad() float64

func (*PoissonParams) ProtoMessage

func (*PoissonParams) ProtoMessage()

func (*PoissonParams) Reset

func (m *PoissonParams) Reset()

func (*PoissonParams) String

func (m *PoissonParams) String() string

func (*PoissonParams) XXX_DiscardUnknown

func (m *PoissonParams) XXX_DiscardUnknown()

func (*PoissonParams) XXX_Marshal

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

func (*PoissonParams) XXX_Merge

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

func (*PoissonParams) XXX_Size

func (m *PoissonParams) XXX_Size() int

func (*PoissonParams) XXX_Unmarshal

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

type ReconnectInfo

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

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

func (*ReconnectInfo) Descriptor

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

func (*ReconnectInfo) GetBackoffMs

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

func (*ReconnectInfo) GetPassed

func (m *ReconnectInfo) GetPassed() bool

func (*ReconnectInfo) ProtoMessage

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo) Reset

func (m *ReconnectInfo) Reset()

func (*ReconnectInfo) String

func (m *ReconnectInfo) String() string

func (*ReconnectInfo) XXX_DiscardUnknown

func (m *ReconnectInfo) XXX_DiscardUnknown()

func (*ReconnectInfo) XXX_Marshal

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

func (*ReconnectInfo) XXX_Merge

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

func (*ReconnectInfo) XXX_Size

func (m *ReconnectInfo) XXX_Size() int

func (*ReconnectInfo) XXX_Unmarshal

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

type ReconnectParams

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

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

func (*ReconnectParams) Descriptor

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

func (*ReconnectParams) GetMaxReconnectBackoffMs

func (m *ReconnectParams) GetMaxReconnectBackoffMs() int32

func (*ReconnectParams) ProtoMessage

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams) Reset

func (m *ReconnectParams) Reset()

func (*ReconnectParams) String

func (m *ReconnectParams) String() string

func (*ReconnectParams) XXX_DiscardUnknown

func (m *ReconnectParams) XXX_DiscardUnknown()

func (*ReconnectParams) XXX_Marshal

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

func (*ReconnectParams) XXX_Merge

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

func (*ReconnectParams) XXX_Size

func (m *ReconnectParams) XXX_Size() int

func (*ReconnectParams) XXX_Unmarshal

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

type ReportQpsScenarioServiceClient

type ReportQpsScenarioServiceClient interface {
	// Report results of a QPS test benchmark scenario.
	ReportScenario(ctx context.Context, in *ScenarioResult, opts ...grpc.CallOption) (*Void, error)
}

ReportQpsScenarioServiceClient is the client API for ReportQpsScenarioService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ReportQpsScenarioServiceServer

type ReportQpsScenarioServiceServer interface {
	// Report results of a QPS test benchmark scenario.
	ReportScenario(context.Context, *ScenarioResult) (*Void, error)
}

ReportQpsScenarioServiceServer is the server API for ReportQpsScenarioService service.

type RequestResultCount

type RequestResultCount struct {
	StatusCode           int32    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestResultCount) Descriptor

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

func (*RequestResultCount) GetCount

func (m *RequestResultCount) GetCount() int64

func (*RequestResultCount) GetStatusCode

func (m *RequestResultCount) GetStatusCode() int32

func (*RequestResultCount) ProtoMessage

func (*RequestResultCount) ProtoMessage()

func (*RequestResultCount) Reset

func (m *RequestResultCount) Reset()

func (*RequestResultCount) String

func (m *RequestResultCount) String() string

func (*RequestResultCount) XXX_DiscardUnknown

func (m *RequestResultCount) XXX_DiscardUnknown()

func (*RequestResultCount) XXX_Marshal

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

func (*RequestResultCount) XXX_Merge

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

func (*RequestResultCount) XXX_Size

func (m *RequestResultCount) XXX_Size() int

func (*RequestResultCount) XXX_Unmarshal

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

type ResponseParameters

type ResponseParameters struct {
	// Desired payload sizes in responses from the server.
	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"`
	// Whether to request the server to compress the response. This field is
	// "nullable" in order to interoperate seamlessly with clients not able to
	// implement the full compression tests by introspecting the call to verify
	// the response's compression status.
	Compressed           *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,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) GetCompressed

func (m *ResponseParameters) GetCompressed() *BoolValue

func (*ResponseParameters) GetIntervalUs

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize

func (m *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) Reset

func (m *ResponseParameters) Reset()

func (*ResponseParameters) String

func (m *ResponseParameters) String() string

func (*ResponseParameters) XXX_DiscardUnknown

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal

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

func (*ResponseParameters) XXX_Merge

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

func (*ResponseParameters) XXX_Size

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal

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

type RpcType

type RpcType int32
const (
	RpcType_UNARY                 RpcType = 0
	RpcType_STREAMING             RpcType = 1
	RpcType_STREAMING_FROM_CLIENT RpcType = 2
	RpcType_STREAMING_FROM_SERVER RpcType = 3
	RpcType_STREAMING_BOTH_WAYS   RpcType = 4
)

func (RpcType) EnumDescriptor

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

func (RpcType) String

func (x RpcType) String() string

type Scenario

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

A single performance scenario: input to qps_json_driver

func (*Scenario) Descriptor

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

func (*Scenario) GetBenchmarkSeconds

func (m *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig

func (m *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName

func (m *Scenario) GetName() string

func (*Scenario) GetNumClients

func (m *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers

func (m *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig

func (m *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount

func (m *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds

func (m *Scenario) GetWarmupSeconds() int32

func (*Scenario) ProtoMessage

func (*Scenario) ProtoMessage()

func (*Scenario) Reset

func (m *Scenario) Reset()

func (*Scenario) String

func (m *Scenario) String() string

func (*Scenario) XXX_DiscardUnknown

func (m *Scenario) XXX_DiscardUnknown()

func (*Scenario) XXX_Marshal

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

func (*Scenario) XXX_Merge

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

func (*Scenario) XXX_Size

func (m *Scenario) XXX_Size() int

func (*Scenario) XXX_Unmarshal

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

type ScenarioResult

type ScenarioResult struct {
	// Inputs used to run the scenario.
	Scenario *Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"`
	// Histograms from all clients merged into one histogram.
	Latencies *HistogramData `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"`
	// Client stats for each client
	ClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"`
	// Server stats for each server
	ServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"`
	// Number of cores available to each server
	ServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"`
	// An after-the-fact computed summary
	Summary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
	// Information on success or failure of each worker
	ClientSuccess []bool `protobuf:"varint,7,rep,packed,name=client_success,json=clientSuccess,proto3" json:"client_success,omitempty"`
	ServerSuccess []bool `protobuf:"varint,8,rep,packed,name=server_success,json=serverSuccess,proto3" json:"server_success,omitempty"`
	// Number of failed requests (one row per status code seen)
	RequestResults       []*RequestResultCount `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Results of a single benchmark scenario.

func (*ScenarioResult) Descriptor

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

func (*ScenarioResult) GetClientStats

func (m *ScenarioResult) GetClientStats() []*ClientStats

func (*ScenarioResult) GetClientSuccess

func (m *ScenarioResult) GetClientSuccess() []bool

func (*ScenarioResult) GetLatencies

func (m *ScenarioResult) GetLatencies() *HistogramData

func (*ScenarioResult) GetRequestResults

func (m *ScenarioResult) GetRequestResults() []*RequestResultCount

func (*ScenarioResult) GetScenario

func (m *ScenarioResult) GetScenario() *Scenario

func (*ScenarioResult) GetServerCores

func (m *ScenarioResult) GetServerCores() []int32

func (*ScenarioResult) GetServerStats

func (m *ScenarioResult) GetServerStats() []*ServerStats

func (*ScenarioResult) GetServerSuccess

func (m *ScenarioResult) GetServerSuccess() []bool

func (*ScenarioResult) GetSummary

func (m *ScenarioResult) GetSummary() *ScenarioResultSummary

func (*ScenarioResult) ProtoMessage

func (*ScenarioResult) ProtoMessage()

func (*ScenarioResult) Reset

func (m *ScenarioResult) Reset()

func (*ScenarioResult) String

func (m *ScenarioResult) String() string

func (*ScenarioResult) XXX_DiscardUnknown

func (m *ScenarioResult) XXX_DiscardUnknown()

func (*ScenarioResult) XXX_Marshal

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

func (*ScenarioResult) XXX_Merge

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

func (*ScenarioResult) XXX_Size

func (m *ScenarioResult) XXX_Size() int

func (*ScenarioResult) XXX_Unmarshal

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

type ScenarioResultSummary

type ScenarioResultSummary struct {
	// Total number of operations per second over all clients.
	Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
	// QPS per one server core.
	QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
	// server load based on system_time (0.85 => 85%)
	ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
	// server load based on user_time (0.85 => 85%)
	ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
	// client load based on system_time (0.85 => 85%)
	ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
	// client load based on user_time (0.85 => 85%)
	ClientUserTime float64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"`
	// X% latency percentiles (in nanoseconds)
	Latency_50  float64 `protobuf:"fixed64,7,opt,name=latency_50,json=latency50,proto3" json:"latency_50,omitempty"`
	Latency_90  float64 `protobuf:"fixed64,8,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"`
	Latency_95  float64 `protobuf:"fixed64,9,opt,name=latency_95,json=latency95,proto3" json:"latency_95,omitempty"`
	Latency_99  float64 `protobuf:"fixed64,10,opt,name=latency_99,json=latency99,proto3" json:"latency_99,omitempty"`
	Latency_999 float64 `protobuf:"fixed64,11,opt,name=latency_999,json=latency999,proto3" json:"latency_999,omitempty"`
	// server cpu usage percentage
	ServerCpuUsage float64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"`
	// Number of requests that succeeded/failed
	SuccessfulRequestsPerSecond float64 `` /* 149-byte string literal not displayed */
	FailedRequestsPerSecond     float64 `` /* 137-byte string literal not displayed */
	// Number of polls called inside completion queue per request
	ClientPollsPerRequest float64 `` /* 131-byte string literal not displayed */
	ServerPollsPerRequest float64 `` /* 131-byte string literal not displayed */
	// Queries per CPU-sec over all servers or clients
	ServerQueriesPerCpuSec float64  `` /* 136-byte string literal not displayed */
	ClientQueriesPerCpuSec float64  `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

Basic summary that can be computed from ClientStats and ServerStats once the scenario has finished.

func (*ScenarioResultSummary) Descriptor

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

func (*ScenarioResultSummary) GetClientPollsPerRequest

func (m *ScenarioResultSummary) GetClientPollsPerRequest() float64

func (*ScenarioResultSummary) GetClientQueriesPerCpuSec

func (m *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetClientSystemTime

func (m *ScenarioResultSummary) GetClientSystemTime() float64

func (*ScenarioResultSummary) GetClientUserTime

func (m *ScenarioResultSummary) GetClientUserTime() float64

func (*ScenarioResultSummary) GetFailedRequestsPerSecond

func (m *ScenarioResultSummary) GetFailedRequestsPerSecond() float64

func (*ScenarioResultSummary) GetLatency_50

func (m *ScenarioResultSummary) GetLatency_50() float64

func (*ScenarioResultSummary) GetLatency_90

func (m *ScenarioResultSummary) GetLatency_90() float64

func (*ScenarioResultSummary) GetLatency_95

func (m *ScenarioResultSummary) GetLatency_95() float64

func (*ScenarioResultSummary) GetLatency_99

func (m *ScenarioResultSummary) GetLatency_99() float64

func (*ScenarioResultSummary) GetLatency_999

func (m *ScenarioResultSummary) GetLatency_999() float64

func (*ScenarioResultSummary) GetQps

func (m *ScenarioResultSummary) GetQps() float64

func (*ScenarioResultSummary) GetQpsPerServerCore

func (m *ScenarioResultSummary) GetQpsPerServerCore() float64

func (*ScenarioResultSummary) GetServerCpuUsage

func (m *ScenarioResultSummary) GetServerCpuUsage() float64

func (*ScenarioResultSummary) GetServerPollsPerRequest

func (m *ScenarioResultSummary) GetServerPollsPerRequest() float64

func (*ScenarioResultSummary) GetServerQueriesPerCpuSec

func (m *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetServerSystemTime

func (m *ScenarioResultSummary) GetServerSystemTime() float64

func (*ScenarioResultSummary) GetServerUserTime

func (m *ScenarioResultSummary) GetServerUserTime() float64

func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond

func (m *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64

func (*ScenarioResultSummary) ProtoMessage

func (*ScenarioResultSummary) ProtoMessage()

func (*ScenarioResultSummary) Reset

func (m *ScenarioResultSummary) Reset()

func (*ScenarioResultSummary) String

func (m *ScenarioResultSummary) String() string

func (*ScenarioResultSummary) XXX_DiscardUnknown

func (m *ScenarioResultSummary) XXX_DiscardUnknown()

func (*ScenarioResultSummary) XXX_Marshal

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

func (*ScenarioResultSummary) XXX_Merge

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

func (*ScenarioResultSummary) XXX_Size

func (m *ScenarioResultSummary) XXX_Size() int

func (*ScenarioResultSummary) XXX_Unmarshal

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

type Scenarios

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

A set of scenarios to be run with qps_json_driver

func (*Scenarios) Descriptor

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

func (*Scenarios) GetScenarios

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

func (*Scenarios) ProtoMessage

func (*Scenarios) ProtoMessage()

func (*Scenarios) Reset

func (m *Scenarios) Reset()

func (*Scenarios) String

func (m *Scenarios) String() string

func (*Scenarios) XXX_DiscardUnknown

func (m *Scenarios) XXX_DiscardUnknown()

func (*Scenarios) XXX_Marshal

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

func (*Scenarios) XXX_Merge

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

func (*Scenarios) XXX_Size

func (m *Scenarios) XXX_Size() int

func (*Scenarios) XXX_Unmarshal

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

type SecurityParams

type SecurityParams struct {
	UseTestCa            bool     `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
	ServerHostOverride   string   `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
	CredType             string   `protobuf:"bytes,3,opt,name=cred_type,json=credType,proto3" json:"cred_type,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) GetCredType

func (m *SecurityParams) GetCredType() string

func (*SecurityParams) GetServerHostOverride

func (m *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa

func (m *SecurityParams) GetUseTestCa() bool

func (*SecurityParams) ProtoMessage

func (*SecurityParams) ProtoMessage()

func (*SecurityParams) Reset

func (m *SecurityParams) Reset()

func (*SecurityParams) String

func (m *SecurityParams) String() string

func (*SecurityParams) XXX_DiscardUnknown

func (m *SecurityParams) XXX_DiscardUnknown()

func (*SecurityParams) XXX_Marshal

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

func (*SecurityParams) XXX_Merge

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

func (*SecurityParams) XXX_Size

func (m *SecurityParams) XXX_Size() int

func (*SecurityParams) XXX_Unmarshal

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

type ServerArgs

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

func (*ServerArgs) Descriptor

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

func (*ServerArgs) GetArgtype

func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark

func (m *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup

func (m *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) ProtoMessage

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) Reset

func (m *ServerArgs) Reset()

func (*ServerArgs) String

func (m *ServerArgs) String() string

func (*ServerArgs) XXX_DiscardUnknown

func (m *ServerArgs) XXX_DiscardUnknown()

func (*ServerArgs) XXX_Marshal

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

func (*ServerArgs) XXX_Merge

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

func (*ServerArgs) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerArgs) XXX_Size

func (m *ServerArgs) XXX_Size() int

func (*ServerArgs) XXX_Unmarshal

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

type ServerArgs_Mark

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

type ServerArgs_Setup

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

type ServerConfig

type ServerConfig struct {
	ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
	SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
	// Port on which to listen. Zero means pick unused port.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Only for async server. Number of threads used to serve the requests.
	AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"`
	// Specify the number of cores to limit server to, if desired
	CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
	// payload config, used in generic server.
	// Note this must NOT be used in proto (non-generic) servers. For proto servers,
	// 'response sizes' must be configured from the 'response_size' field of the
	// 'SimpleRequest' objects in RPC requests.
	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"`
	// If we use an OTHER_SERVER client_type, this string gives more detail
	OtherServerApi string `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"`
	// Number of threads that share each completion queue
	ThreadsPerCq int32 `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
	// Buffer pool size (no buffer pool specified if unset)
	ResourceQuotaSize    int32         `protobuf:"varint,1001,opt,name=resource_quota_size,json=resourceQuotaSize,proto3" json:"resource_quota_size,omitempty"`
	ChannelArgs          []*ChannelArg `protobuf:"bytes,1002,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,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) GetChannelArgs

func (m *ServerConfig) GetChannelArgs() []*ChannelArg

func (*ServerConfig) GetCoreLimit

func (m *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList

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

func (*ServerConfig) GetOtherServerApi

func (m *ServerConfig) GetOtherServerApi() string

func (*ServerConfig) GetPayloadConfig

func (m *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort

func (m *ServerConfig) GetPort() int32

func (*ServerConfig) GetResourceQuotaSize

func (m *ServerConfig) GetResourceQuotaSize() int32

func (*ServerConfig) GetSecurityParams

func (m *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerType

func (m *ServerConfig) GetServerType() ServerType

func (*ServerConfig) GetThreadsPerCq

func (m *ServerConfig) GetThreadsPerCq() int32

func (*ServerConfig) ProtoMessage

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) Reset

func (m *ServerConfig) Reset()

func (*ServerConfig) String

func (m *ServerConfig) String() string

func (*ServerConfig) XXX_DiscardUnknown

func (m *ServerConfig) XXX_DiscardUnknown()

func (*ServerConfig) XXX_Marshal

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

func (*ServerConfig) XXX_Merge

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

func (*ServerConfig) XXX_Size

func (m *ServerConfig) XXX_Size() int

func (*ServerConfig) XXX_Unmarshal

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

type ServerStats

type ServerStats struct {
	// wall clock time change in seconds since last reset
	TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	// change in user time (in seconds) used by the server since last reset
	TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
	// change in server time (in seconds) used by the server process and all
	// threads since last reset
	TimeSystem float64 `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
	// change in total cpu time of the server (data from proc/stat)
	TotalCpuTime uint64 `protobuf:"varint,4,opt,name=total_cpu_time,json=totalCpuTime,proto3" json:"total_cpu_time,omitempty"`
	// change in idle time of the server (data from proc/stat)
	IdleCpuTime uint64 `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"`
	// Number of polls called inside completion queue
	CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
	// Core library stats
	CoreStats            *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ServerStats) Descriptor

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

func (*ServerStats) GetCoreStats

func (m *ServerStats) GetCoreStats() *core.Stats

func (*ServerStats) GetCqPollCount

func (m *ServerStats) GetCqPollCount() uint64

func (*ServerStats) GetIdleCpuTime

func (m *ServerStats) GetIdleCpuTime() uint64

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) GetTotalCpuTime

func (m *ServerStats) GetTotalCpuTime() uint64

func (*ServerStats) ProtoMessage

func (*ServerStats) ProtoMessage()

func (*ServerStats) Reset

func (m *ServerStats) Reset()

func (*ServerStats) String

func (m *ServerStats) String() string

func (*ServerStats) XXX_DiscardUnknown

func (m *ServerStats) XXX_DiscardUnknown()

func (*ServerStats) XXX_Marshal

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

func (*ServerStats) XXX_Merge

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

func (*ServerStats) XXX_Size

func (m *ServerStats) XXX_Size() int

func (*ServerStats) XXX_Unmarshal

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

type ServerStatus

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

func (*ServerStatus) Descriptor

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

func (*ServerStatus) GetCores

func (m *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort

func (m *ServerStatus) GetPort() int32

func (*ServerStatus) GetStats

func (m *ServerStatus) GetStats() *ServerStats

func (*ServerStatus) ProtoMessage

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) Reset

func (m *ServerStatus) Reset()

func (*ServerStatus) String

func (m *ServerStatus) String() string

func (*ServerStatus) XXX_DiscardUnknown

func (m *ServerStatus) XXX_DiscardUnknown()

func (*ServerStatus) XXX_Marshal

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

func (*ServerStatus) XXX_Merge

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

func (*ServerStatus) XXX_Size

func (m *ServerStatus) XXX_Size() int

func (*ServerStatus) XXX_Unmarshal

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

type ServerType

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

func (ServerType) EnumDescriptor

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

func (ServerType) String

func (x ServerType) String() string

type SimpleProtoParams

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

func (*SimpleProtoParams) Descriptor

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

func (*SimpleProtoParams) GetReqSize

func (m *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize

func (m *SimpleProtoParams) GetRespSize() int32

func (*SimpleProtoParams) ProtoMessage

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams) Reset

func (m *SimpleProtoParams) Reset()

func (*SimpleProtoParams) String

func (m *SimpleProtoParams) String() string

func (*SimpleProtoParams) XXX_DiscardUnknown

func (m *SimpleProtoParams) XXX_DiscardUnknown()

func (*SimpleProtoParams) XXX_Marshal

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

func (*SimpleProtoParams) XXX_Merge

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

func (*SimpleProtoParams) XXX_Size

func (m *SimpleProtoParams) XXX_Size() int

func (*SimpleProtoParams) XXX_Unmarshal

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

type SimpleRequest

type SimpleRequest struct {
	// Desired payload type in the response from the server.
	// If response_type is RANDOM, server randomly chooses one from other formats.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Desired payload size in the response from the server.
	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"`
	// Whether to request the server to compress the response. This field is
	// "nullable" in order to interoperate seamlessly with clients not able to
	// implement the full compression tests by introspecting the call to verify
	// the response's compression status.
	ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"`
	// Whether server should return a given status
	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	// Whether the server should expect this request to be compressed.
	ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
	// Whether SimpleResponse should include server_id.
	FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`
	// Whether SimpleResponse should include grpclb_route_type.
	FillGrpclbRouteType  bool     `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,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) GetExpectCompressed

func (m *SimpleRequest) GetExpectCompressed() *BoolValue

func (*SimpleRequest) GetFillGrpclbRouteType

func (m *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId

func (m *SimpleRequest) GetFillServerId() bool

func (*SimpleRequest) GetFillUsername

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompressed

func (m *SimpleRequest) GetResponseCompressed() *BoolValue

func (*SimpleRequest) GetResponseSize

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType

func (m *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String

func (m *SimpleRequest) String() string

func (*SimpleRequest) XXX_DiscardUnknown

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal

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

func (*SimpleRequest) XXX_Merge

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

func (*SimpleRequest) XXX_Size

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal

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

type SimpleResponse

type SimpleResponse struct {
	// Payload to increase message size.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The user the request came from, for verifying authentication was
	// successful when the client expected it.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// OAuth scope.
	OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
	// Server ID. This must be unique among different server instances,
	// but the same across all RPC's made to a particular server instance.
	ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// gRPCLB Path.
	GrpclbRouteType      GrpclbRouteType `` /* 143-byte string literal not displayed */
	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) GetGrpclbRouteType

func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetOauthScope

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId

func (m *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername

func (m *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal

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

func (*SimpleResponse) XXX_Merge

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

func (*SimpleResponse) XXX_Size

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal

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

type StreamingInputCallRequest

type StreamingInputCallRequest struct {
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Whether the server should expect this request to be compressed. This field
	// is "nullable" in order to interoperate seamlessly with servers not able to
	// implement the full compression tests by introspecting the call to verify
	// the request's compression status.
	ExpectCompressed     *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,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) GetExpectCompressed

func (m *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

func (*StreamingInputCallRequest) GetPayload

func (m *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) Reset

func (m *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String

func (m *StreamingInputCallRequest) String() string

func (*StreamingInputCallRequest) XXX_DiscardUnknown

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal

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

func (*StreamingInputCallRequest) XXX_Merge

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

func (*StreamingInputCallRequest) XXX_Size

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal

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

type StreamingInputCallResponse

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

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor

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

func (*StreamingInputCallResponse) GetAggregatedPayloadSize

func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) Reset

func (m *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String

func (m *StreamingInputCallResponse) String() string

func (*StreamingInputCallResponse) XXX_DiscardUnknown

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal

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

func (*StreamingInputCallResponse) XXX_Merge

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

func (*StreamingInputCallResponse) XXX_Size

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal

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

type StreamingOutputCallRequest

type StreamingOutputCallRequest struct {
	// Desired payload type in the response from the server.
	// If response_type is RANDOM, the payload from each response in the stream
	// might be of different types. This is to simulate a mixed type of payload
	// stream.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Configuration for each expected response message.
	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// 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) GetResponseParameters

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

func (*StreamingOutputCallRequest) GetResponseStatus

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType

func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) Reset

func (m *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String

func (m *StreamingOutputCallRequest) String() string

func (*StreamingOutputCallRequest) XXX_DiscardUnknown

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal

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

func (*StreamingOutputCallRequest) XXX_Merge

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

func (*StreamingOutputCallRequest) XXX_Size

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal

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

type StreamingOutputCallResponse

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

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

func (*StreamingOutputCallResponse) Descriptor

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

func (*StreamingOutputCallResponse) GetPayload

func (m *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) Reset

func (m *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String

func (m *StreamingOutputCallResponse) String() string

func (*StreamingOutputCallResponse) XXX_DiscardUnknown

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal

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

func (*StreamingOutputCallResponse) XXX_Merge

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

func (*StreamingOutputCallResponse) XXX_Size

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal

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

type UnimplementedBenchmarkServiceServer

type UnimplementedBenchmarkServiceServer struct {
}

UnimplementedBenchmarkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBenchmarkServiceServer) StreamingBothWays

func (*UnimplementedBenchmarkServiceServer) StreamingCall

func (*UnimplementedBenchmarkServiceServer) StreamingFromClient

func (*UnimplementedBenchmarkServiceServer) StreamingFromServer

func (*UnimplementedBenchmarkServiceServer) UnaryCall

type UnimplementedReportQpsScenarioServiceServer

type UnimplementedReportQpsScenarioServiceServer struct {
}

UnimplementedReportQpsScenarioServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReportQpsScenarioServiceServer) ReportScenario

type UnimplementedWorkerServiceServer

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServiceServer) CoreCount

func (*UnimplementedWorkerServiceServer) QuitWorker

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

func (*UnimplementedWorkerServiceServer) RunClient

func (*UnimplementedWorkerServiceServer) RunServer

type Void

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

func (*Void) Descriptor

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

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) Reset

func (m *Void) Reset()

func (*Void) String

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal

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

func (*Void) XXX_Merge

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

func (*Void) XXX_Size

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal

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

type WorkerServiceClient

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

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type WorkerServiceServer

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

WorkerServiceServer is the server API for WorkerService service.

type WorkerService_RunClientClient

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

type WorkerService_RunClientServer

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

type WorkerService_RunServerClient

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

type WorkerService_RunServerServer

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

Jump to

Keyboard shortcuts

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