testing

package
v1.36.11-2025121620244... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 6 Imported by: 3

Documentation

Index

Constants

View Source 
const ChannelArg_IntValue_case case_ChannelArg_Value = 3
View Source 
const ChannelArg_StrValue_case case_ChannelArg_Value = 2
View Source 
const ChannelArg_Value_not_set_case case_ChannelArg_Value = 0
View Source 
const ClientArgs_Argtype_not_set_case case_ClientArgs_Argtype = 0
View Source 
const ClientArgs_Mark_case case_ClientArgs_Argtype = 2
View Source 
const ClientArgs_Setup_case case_ClientArgs_Argtype = 1
View Source 
const LoadParams_ClosedLoop_case case_LoadParams_Load = 1
View Source 
const LoadParams_Load_not_set_case case_LoadParams_Load = 0
View Source 
const LoadParams_Poisson_case case_LoadParams_Load = 2
View Source 
const PayloadConfig_BytebufParams_case case_PayloadConfig_Payload = 1
View Source 
const PayloadConfig_ComplexParams_case case_PayloadConfig_Payload = 3
View Source 
const PayloadConfig_Payload_not_set_case case_PayloadConfig_Payload = 0
View Source 
const PayloadConfig_SimpleParams_case case_PayloadConfig_Payload = 2
View Source 
const ServerArgs_Argtype_not_set_case case_ServerArgs_Argtype = 0
View Source 
const ServerArgs_Mark_case case_ServerArgs_Argtype = 2
View Source 
const ServerArgs_Setup_case case_ServerArgs_Argtype = 1

Variables

View Source 
var (
	ClientType_name = map[int32]string{
		0: "SYNC_CLIENT",
		1: "ASYNC_CLIENT",
		2: "OTHER_CLIENT",
		3: "CALLBACK_CLIENT",
	}
	ClientType_value = map[string]int32{
		"SYNC_CLIENT":     0,
		"ASYNC_CLIENT":    1,
		"OTHER_CLIENT":    2,
		"CALLBACK_CLIENT": 3,
	}
)

Enum value maps for ClientType.

View Source 
var (
	ServerType_name = map[int32]string{
		0: "SYNC_SERVER",
		1: "ASYNC_SERVER",
		2: "ASYNC_GENERIC_SERVER",
		3: "OTHER_SERVER",
		4: "CALLBACK_SERVER",
	}
	ServerType_value = map[string]int32{
		"SYNC_SERVER":          0,
		"ASYNC_SERVER":         1,
		"ASYNC_GENERIC_SERVER": 2,
		"OTHER_SERVER":         3,
		"CALLBACK_SERVER":      4,
	}
)

Enum value maps for ServerType.

View Source 
var (
	RpcType_name = map[int32]string{
		0: "UNARY",
		1: "STREAMING",
		2: "STREAMING_FROM_CLIENT",
		3: "STREAMING_FROM_SERVER",
		4: "STREAMING_BOTH_WAYS",
	}
	RpcType_value = map[string]int32{
		"UNARY":                 0,
		"STREAMING":             1,
		"STREAMING_FROM_CLIENT": 2,
		"STREAMING_FROM_SERVER": 3,
		"STREAMING_BOTH_WAYS":   4,
	}
)

Enum value maps for RpcType.

View Source 
var (
	PayloadType_name = map[int32]string{
		0: "COMPRESSABLE",
	}
	PayloadType_value = map[string]int32{
		"COMPRESSABLE": 0,
	}
)

Enum value maps for PayloadType.

View Source 
var (
	GrpclbRouteType_name = map[int32]string{
		0: "GRPCLB_ROUTE_TYPE_UNKNOWN",
		1: "GRPCLB_ROUTE_TYPE_FALLBACK",
		2: "GRPCLB_ROUTE_TYPE_BACKEND",
	}
	GrpclbRouteType_value = map[string]int32{
		"GRPCLB_ROUTE_TYPE_UNKNOWN":  0,
		"GRPCLB_ROUTE_TYPE_FALLBACK": 1,
		"GRPCLB_ROUTE_TYPE_BACKEND":  2,
	}
)

Enum value maps for GrpclbRouteType.

View Source 
var (
	LoadBalancerStatsResponse_MetadataType_name = map[int32]string{
		0: "UNKNOWN",
		1: "INITIAL",
		2: "TRAILING",
	}
	LoadBalancerStatsResponse_MetadataType_value = map[string]int32{
		"UNKNOWN":  0,
		"INITIAL":  1,
		"TRAILING": 2,
	}
)

Enum value maps for LoadBalancerStatsResponse_MetadataType.

View Source 
var (
	ClientConfigureRequest_RpcType_name = map[int32]string{
		0: "EMPTY_CALL",
		1: "UNARY_CALL",
	}
	ClientConfigureRequest_RpcType_value = map[string]int32{
		"EMPTY_CALL": 0,
		"UNARY_CALL": 1,
	}
)

Enum value maps for ClientConfigureRequest_RpcType.

View Source 
var (
	HookRequest_HookRequestCommand_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "START",
		2: "STOP",
		3: "RETURN",
	}
	HookRequest_HookRequestCommand_value = map[string]int32{
		"UNSPECIFIED": 0,
		"START":       1,
		"STOP":        2,
		"RETURN":      3,
	}
)

Enum value maps for HookRequest_HookRequestCommand.

View Source 
var File_grpc_testing_benchmark_service_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_control_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_empty_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_messages_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_payloads_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_report_qps_scenario_service_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_stats_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_test_proto protoreflect.FileDescriptor
View Source 
var File_grpc_testing_worker_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BoolValue 

type BoolValue struct {

	// The bool value.
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage 

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect 

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

func (*BoolValue) Reset 

func (x *BoolValue) Reset()

func (*BoolValue) SetValue 

func (x *BoolValue) SetValue(v bool)

func (*BoolValue) String 

func (x *BoolValue) String() string

type BoolValue_builder 

type BoolValue_builder struct {

	// The bool value.
	Value bool
	// contains filtered or unexported fields
}

func (BoolValue_builder) Build 

func (b0 BoolValue_builder) Build() *BoolValue

type ByteBufferParams 

type ByteBufferParams struct {
	ReqSize  int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
	RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ByteBufferParams) GetReqSize 

func (x *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize 

func (x *ByteBufferParams) GetRespSize() int32

func (*ByteBufferParams) ProtoMessage 

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams) ProtoReflect 

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

func (*ByteBufferParams) Reset 

func (x *ByteBufferParams) Reset()

func (*ByteBufferParams) SetReqSize 

func (x *ByteBufferParams) SetReqSize(v int32)

func (*ByteBufferParams) SetRespSize 

func (x *ByteBufferParams) SetRespSize(v int32)

func (*ByteBufferParams) String 

func (x *ByteBufferParams) String() string

type ByteBufferParams_builder 

type ByteBufferParams_builder struct {
	ReqSize  int32
	RespSize int32
	// contains filtered or unexported fields
}

func (ByteBufferParams_builder) Build 

func (b0 ByteBufferParams_builder) Build() *ByteBufferParams

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"`
	// contains filtered or unexported fields
}

func (*ChannelArg) ClearIntValue 

func (x *ChannelArg) ClearIntValue()

func (*ChannelArg) ClearStrValue 

func (x *ChannelArg) ClearStrValue()

func (*ChannelArg) ClearValue 

func (x *ChannelArg) ClearValue()

func (*ChannelArg) GetIntValue 

func (x *ChannelArg) GetIntValue() int32

func (*ChannelArg) GetName 

func (x *ChannelArg) GetName() string

func (*ChannelArg) GetStrValue 

func (x *ChannelArg) GetStrValue() string

func (*ChannelArg) GetValue 

func (x *ChannelArg) GetValue() isChannelArg_Value

func (*ChannelArg) HasIntValue 

func (x *ChannelArg) HasIntValue() bool

func (*ChannelArg) HasStrValue 

func (x *ChannelArg) HasStrValue() bool

func (*ChannelArg) HasValue 

func (x *ChannelArg) HasValue() bool

func (*ChannelArg) ProtoMessage 

func (*ChannelArg) ProtoMessage()

func (*ChannelArg) ProtoReflect 

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

func (*ChannelArg) Reset 

func (x *ChannelArg) Reset()

func (*ChannelArg) SetIntValue 

func (x *ChannelArg) SetIntValue(v int32)

func (*ChannelArg) SetName 

func (x *ChannelArg) SetName(v string)

func (*ChannelArg) SetStrValue 

func (x *ChannelArg) SetStrValue(v string)

func (*ChannelArg) String 

func (x *ChannelArg) String() string

func (*ChannelArg) WhichValue 

func (x *ChannelArg) WhichValue() case_ChannelArg_Value

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 ChannelArg_builder 

type ChannelArg_builder struct {
	Name string
	// Fields of oneof Value:
	StrValue *string
	IntValue *int32
	// contains filtered or unexported fields
}

func (ChannelArg_builder) Build 

func (b0 ChannelArg_builder) Build() *ChannelArg

type ClientArgs 

type ClientArgs struct {

	// Types that are valid to be assigned to Argtype:
	//
	//	*ClientArgs_Setup
	//	*ClientArgs_Mark
	Argtype isClientArgs_Argtype `protobuf_oneof:"argtype"`
	// contains filtered or unexported fields
}

func (*ClientArgs) ClearArgtype 

func (x *ClientArgs) ClearArgtype()

func (*ClientArgs) ClearMark 

func (x *ClientArgs) ClearMark()

func (*ClientArgs) ClearSetup 

func (x *ClientArgs) ClearSetup()

func (*ClientArgs) GetArgtype 

func (x *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark 

func (x *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup 

func (x *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) HasArgtype 

func (x *ClientArgs) HasArgtype() bool

func (*ClientArgs) HasMark 

func (x *ClientArgs) HasMark() bool

func (*ClientArgs) HasSetup 

func (x *ClientArgs) HasSetup() bool

func (*ClientArgs) ProtoMessage 

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) ProtoReflect 

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

func (*ClientArgs) Reset 

func (x *ClientArgs) Reset()

func (*ClientArgs) SetMark 

func (x *ClientArgs) SetMark(v *Mark)

func (*ClientArgs) SetSetup 

func (x *ClientArgs) SetSetup(v *ClientConfig)

func (*ClientArgs) String 

func (x *ClientArgs) String() string

func (*ClientArgs) WhichArgtype 

func (x *ClientArgs) WhichArgtype() case_ClientArgs_Argtype

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 ClientArgs_builder 

type ClientArgs_builder struct {

	// Fields of oneof Argtype:
	Setup *ClientConfig
	Mark  *Mark
	// contains filtered or unexported fields
}

func (ClientArgs_builder) Build 

func (b0 ClientArgs_builder) Build() *ClientArgs

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"`
	// If 0, disabled. Else, specifies the period between gathering latency
	// medians in milliseconds.
	MedianLatencyCollectionIntervalMillis int32 `` /* 180-byte string literal not displayed */
	// Number of client processes. 0 indicates no restriction.
	ClientProcesses int32 `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientConfig) ClearHistogramParams 

func (x *ClientConfig) ClearHistogramParams()

func (*ClientConfig) ClearLoadParams 

func (x *ClientConfig) ClearLoadParams()

func (*ClientConfig) ClearPayloadConfig 

func (x *ClientConfig) ClearPayloadConfig()

func (*ClientConfig) ClearSecurityParams 

func (x *ClientConfig) ClearSecurityParams()

func (*ClientConfig) GetAsyncClientThreads 

func (x *ClientConfig) GetAsyncClientThreads() int32

func (*ClientConfig) GetChannelArgs 

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

func (*ClientConfig) GetClientChannels 

func (x *ClientConfig) GetClientChannels() int32

func (*ClientConfig) GetClientProcesses 

func (x *ClientConfig) GetClientProcesses() int32

func (*ClientConfig) GetClientType 

func (x *ClientConfig) GetClientType() ClientType

func (*ClientConfig) GetCoreLimit 

func (x *ClientConfig) GetCoreLimit() int32

func (*ClientConfig) GetCoreList 

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

func (*ClientConfig) GetHistogramParams 

func (x *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig) GetLoadParams 

func (x *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig) GetMedianLatencyCollectionIntervalMillis 

func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32

func (*ClientConfig) GetMessagesPerStream 

func (x *ClientConfig) GetMessagesPerStream() int32

func (*ClientConfig) GetOtherClientApi 

func (x *ClientConfig) GetOtherClientApi() string

func (*ClientConfig) GetOutstandingRpcsPerChannel 

func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32

func (*ClientConfig) GetPayloadConfig 

func (x *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig) GetRpcType 

func (x *ClientConfig) GetRpcType() RpcType

func (*ClientConfig) GetSecurityParams 

func (x *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig) GetServerTargets 

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

func (*ClientConfig) GetThreadsPerCq 

func (x *ClientConfig) GetThreadsPerCq() int32

func (*ClientConfig) GetUseCoalesceApi 

func (x *ClientConfig) GetUseCoalesceApi() bool

func (*ClientConfig) HasHistogramParams 

func (x *ClientConfig) HasHistogramParams() bool

func (*ClientConfig) HasLoadParams 

func (x *ClientConfig) HasLoadParams() bool

func (*ClientConfig) HasPayloadConfig 

func (x *ClientConfig) HasPayloadConfig() bool

func (*ClientConfig) HasSecurityParams 

func (x *ClientConfig) HasSecurityParams() bool

func (*ClientConfig) ProtoMessage 

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) ProtoReflect 

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

func (*ClientConfig) Reset 

func (x *ClientConfig) Reset()

func (*ClientConfig) SetAsyncClientThreads 

func (x *ClientConfig) SetAsyncClientThreads(v int32)

func (*ClientConfig) SetChannelArgs 

func (x *ClientConfig) SetChannelArgs(v []*ChannelArg)

func (*ClientConfig) SetClientChannels 

func (x *ClientConfig) SetClientChannels(v int32)

func (*ClientConfig) SetClientProcesses 

func (x *ClientConfig) SetClientProcesses(v int32)

func (*ClientConfig) SetClientType 

func (x *ClientConfig) SetClientType(v ClientType)

func (*ClientConfig) SetCoreLimit 

func (x *ClientConfig) SetCoreLimit(v int32)

func (*ClientConfig) SetCoreList 

func (x *ClientConfig) SetCoreList(v []int32)

func (*ClientConfig) SetHistogramParams 

func (x *ClientConfig) SetHistogramParams(v *HistogramParams)

func (*ClientConfig) SetLoadParams 

func (x *ClientConfig) SetLoadParams(v *LoadParams)

func (*ClientConfig) SetMedianLatencyCollectionIntervalMillis 

func (x *ClientConfig) SetMedianLatencyCollectionIntervalMillis(v int32)

func (*ClientConfig) SetMessagesPerStream 

func (x *ClientConfig) SetMessagesPerStream(v int32)

func (*ClientConfig) SetOtherClientApi 

func (x *ClientConfig) SetOtherClientApi(v string)

func (*ClientConfig) SetOutstandingRpcsPerChannel 

func (x *ClientConfig) SetOutstandingRpcsPerChannel(v int32)

func (*ClientConfig) SetPayloadConfig 

func (x *ClientConfig) SetPayloadConfig(v *PayloadConfig)

func (*ClientConfig) SetRpcType 

func (x *ClientConfig) SetRpcType(v RpcType)

func (*ClientConfig) SetSecurityParams 

func (x *ClientConfig) SetSecurityParams(v *SecurityParams)

func (*ClientConfig) SetServerTargets 

func (x *ClientConfig) SetServerTargets(v []string)

func (*ClientConfig) SetThreadsPerCq 

func (x *ClientConfig) SetThreadsPerCq(v int32)

func (*ClientConfig) SetUseCoalesceApi 

func (x *ClientConfig) SetUseCoalesceApi(v bool)

func (*ClientConfig) String 

func (x *ClientConfig) String() string

type ClientConfig_builder 

type ClientConfig_builder struct {

	// List of targets to connect to. At least one target needs to be specified.
	ServerTargets  []string
	ClientType     ClientType
	SecurityParams *SecurityParams
	// How many concurrent RPCs to start for each channel.
	// For synchronous client, use a separate thread for each outstanding RPC.
	OutstandingRpcsPerChannel int32
	// Number of independent client channels to create.
	// i-th channel will connect to server_target[i % server_targets.size()]
	ClientChannels int32
	// Only for async client. Number of threads to use to start/manage RPCs.
	AsyncClientThreads int32
	RpcType            RpcType
	// The requested load for the entire client (aggregated over all the threads).
	LoadParams      *LoadParams
	PayloadConfig   *PayloadConfig
	HistogramParams *HistogramParams
	// Specify the cores we should run the client on, if desired
	CoreList  []int32
	CoreLimit int32
	// If we use an OTHER_CLIENT client_type, this string gives more detail
	OtherClientApi string
	ChannelArgs    []*ChannelArg
	// Number of threads that share each completion queue
	ThreadsPerCq int32
	// Number of messages on a stream before it gets finished/restarted
	MessagesPerStream int32
	// Use coalescing API when possible.
	UseCoalesceApi bool
	// If 0, disabled. Else, specifies the period between gathering latency
	// medians in milliseconds.
	MedianLatencyCollectionIntervalMillis int32
	// Number of client processes. 0 indicates no restriction.
	ClientProcesses int32
	// contains filtered or unexported fields
}

func (ClientConfig_builder) Build 

func (b0 ClientConfig_builder) Build() *ClientConfig

type ClientConfigureRequest 

type ClientConfigureRequest struct {

	// The types of RPCs the client sends.
	Types []ClientConfigureRequest_RpcType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"types,omitempty"`
	// The collection of custom metadata to be attached to RPCs sent by the client.
	Metadata []*ClientConfigureRequest_Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// The deadline to use, in seconds, for all RPCs.  If unset or zero, the
	// client will use the default from the command-line.
	TimeoutSec int32 `protobuf:"varint,3,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
	// contains filtered or unexported fields
}

Configurations for a test client.

func (*ClientConfigureRequest) GetMetadata 

func (x *ClientConfigureRequest) GetMetadata() []*ClientConfigureRequest_Metadata

func (*ClientConfigureRequest) GetTimeoutSec 

func (x *ClientConfigureRequest) GetTimeoutSec() int32

func (*ClientConfigureRequest) GetTypes 

func (x *ClientConfigureRequest) GetTypes() []ClientConfigureRequest_RpcType

func (*ClientConfigureRequest) ProtoMessage 

func (*ClientConfigureRequest) ProtoMessage()

func (*ClientConfigureRequest) ProtoReflect 

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

func (*ClientConfigureRequest) Reset 

func (x *ClientConfigureRequest) Reset()

func (*ClientConfigureRequest) SetMetadata 

func (x *ClientConfigureRequest) SetMetadata(v []*ClientConfigureRequest_Metadata)

func (*ClientConfigureRequest) SetTimeoutSec 

func (x *ClientConfigureRequest) SetTimeoutSec(v int32)

func (*ClientConfigureRequest) SetTypes 

func (x *ClientConfigureRequest) SetTypes(v []ClientConfigureRequest_RpcType)

func (*ClientConfigureRequest) String 

func (x *ClientConfigureRequest) String() string

type ClientConfigureRequest_Metadata 

type ClientConfigureRequest_Metadata struct {
	Type  ClientConfigureRequest_RpcType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"type,omitempty"`
	Key   string                         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value string                         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Metadata to be attached for the given type of RPCs.

func (*ClientConfigureRequest_Metadata) GetKey 

func (x *ClientConfigureRequest_Metadata) GetKey() string

func (*ClientConfigureRequest_Metadata) GetType 

func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType

func (*ClientConfigureRequest_Metadata) GetValue 

func (x *ClientConfigureRequest_Metadata) GetValue() string

func (*ClientConfigureRequest_Metadata) ProtoMessage 

func (*ClientConfigureRequest_Metadata) ProtoMessage()

func (*ClientConfigureRequest_Metadata) ProtoReflect 

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

func (*ClientConfigureRequest_Metadata) Reset 

func (x *ClientConfigureRequest_Metadata) Reset()

func (*ClientConfigureRequest_Metadata) SetKey 

func (x *ClientConfigureRequest_Metadata) SetKey(v string)

func (*ClientConfigureRequest_Metadata) SetType 

func (x *ClientConfigureRequest_Metadata) SetType(v ClientConfigureRequest_RpcType)

func (*ClientConfigureRequest_Metadata) SetValue 

func (x *ClientConfigureRequest_Metadata) SetValue(v string)

func (*ClientConfigureRequest_Metadata) String 

func (x *ClientConfigureRequest_Metadata) String() string

type ClientConfigureRequest_Metadata_builder 

type ClientConfigureRequest_Metadata_builder struct {
	Type  ClientConfigureRequest_RpcType
	Key   string
	Value string
	// contains filtered or unexported fields
}

func (ClientConfigureRequest_Metadata_builder) Build 

func (b0 ClientConfigureRequest_Metadata_builder) Build() *ClientConfigureRequest_Metadata

type ClientConfigureRequest_RpcType 

type ClientConfigureRequest_RpcType int32

Type of RPCs to send. 

const (
	ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0
	ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1
)

func (ClientConfigureRequest_RpcType) Descriptor 

func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor

func (ClientConfigureRequest_RpcType) Enum 

func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType

func (ClientConfigureRequest_RpcType) Number 

func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber

func (ClientConfigureRequest_RpcType) String 

func (x ClientConfigureRequest_RpcType) String() string

func (ClientConfigureRequest_RpcType) Type 

func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType

type ClientConfigureRequest_builder 

type ClientConfigureRequest_builder struct {

	// The types of RPCs the client sends.
	Types []ClientConfigureRequest_RpcType
	// The collection of custom metadata to be attached to RPCs sent by the client.
	Metadata []*ClientConfigureRequest_Metadata
	// The deadline to use, in seconds, for all RPCs.  If unset or zero, the
	// client will use the default from the command-line.
	TimeoutSec int32
	// contains filtered or unexported fields
}

func (ClientConfigureRequest_builder) Build 

func (b0 ClientConfigureRequest_builder) Build() *ClientConfigureRequest

type ClientConfigureResponse 

type ClientConfigureResponse struct {
	// contains filtered or unexported fields
}

Response for updating a test client's configuration.

func (*ClientConfigureResponse) ProtoMessage 

func (*ClientConfigureResponse) ProtoMessage()

func (*ClientConfigureResponse) ProtoReflect 

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

func (*ClientConfigureResponse) Reset 

func (x *ClientConfigureResponse) Reset()

func (*ClientConfigureResponse) String 

func (x *ClientConfigureResponse) String() string

type ClientConfigureResponse_builder 

type ClientConfigureResponse_builder struct {
	// contains filtered or unexported fields
}

func (ClientConfigureResponse_builder) Build 

func (b0 ClientConfigureResponse_builder) Build() *ClientConfigureResponse

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"`
	// contains filtered or unexported fields
}

func (*ClientStats) ClearCoreStats 

func (x *ClientStats) ClearCoreStats()

func (*ClientStats) ClearLatencies 

func (x *ClientStats) ClearLatencies()

func (*ClientStats) GetCoreStats 

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

func (*ClientStats) GetCqPollCount 

func (x *ClientStats) GetCqPollCount() uint64

func (*ClientStats) GetLatencies 

func (x *ClientStats) GetLatencies() *HistogramData

func (*ClientStats) GetRequestResults 

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

func (*ClientStats) GetTimeElapsed 

func (x *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem 

func (x *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser 

func (x *ClientStats) GetTimeUser() float64

func (*ClientStats) HasCoreStats 

func (x *ClientStats) HasCoreStats() bool

func (*ClientStats) HasLatencies 

func (x *ClientStats) HasLatencies() bool

func (*ClientStats) ProtoMessage 

func (*ClientStats) ProtoMessage()

func (*ClientStats) ProtoReflect 

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

func (*ClientStats) Reset 

func (x *ClientStats) Reset()

func (*ClientStats) SetCoreStats 

func (x *ClientStats) SetCoreStats(v *core.Stats)

func (*ClientStats) SetCqPollCount 

func (x *ClientStats) SetCqPollCount(v uint64)

func (*ClientStats) SetLatencies 

func (x *ClientStats) SetLatencies(v *HistogramData)

func (*ClientStats) SetRequestResults 

func (x *ClientStats) SetRequestResults(v []*RequestResultCount)

func (*ClientStats) SetTimeElapsed 

func (x *ClientStats) SetTimeElapsed(v float64)

func (*ClientStats) SetTimeSystem 

func (x *ClientStats) SetTimeSystem(v float64)

func (*ClientStats) SetTimeUser 

func (x *ClientStats) SetTimeUser(v float64)

func (*ClientStats) String 

func (x *ClientStats) String() string

type ClientStats_builder 

type ClientStats_builder struct {

	// Latency histogram. Data points are in nanoseconds.
	Latencies *HistogramData
	// See ServerStats for details.
	TimeElapsed float64
	TimeUser    float64
	TimeSystem  float64
	// Number of failed requests (one row per status code seen)
	RequestResults []*RequestResultCount
	// Number of polls called inside completion queue
	CqPollCount uint64
	// Core library stats
	CoreStats *core.Stats
	// contains filtered or unexported fields
}

func (ClientStats_builder) Build 

func (b0 ClientStats_builder) Build() *ClientStats

type ClientStatus 

type ClientStatus struct {
	Stats *ClientStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientStatus) ClearStats 

func (x *ClientStatus) ClearStats()

func (*ClientStatus) GetStats 

func (x *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) HasStats 

func (x *ClientStatus) HasStats() bool

func (*ClientStatus) ProtoMessage 

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) ProtoReflect 

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

func (*ClientStatus) Reset 

func (x *ClientStatus) Reset()

func (*ClientStatus) SetStats 

func (x *ClientStatus) SetStats(v *ClientStats)

func (*ClientStatus) String 

func (x *ClientStatus) String() string

type ClientStatus_builder 

type ClientStatus_builder struct {
	Stats *ClientStats
	// contains filtered or unexported fields
}

func (ClientStatus_builder) Build 

func (b0 ClientStatus_builder) Build() *ClientStatus

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 // used for some language-specific variants
	ClientType_CALLBACK_CLIENT ClientType = 3
)

func (ClientType) Descriptor 

func (ClientType) Descriptor() protoreflect.EnumDescriptor

func (ClientType) Enum 

func (x ClientType) Enum() *ClientType

func (ClientType) Number 

func (x ClientType) Number() protoreflect.EnumNumber

func (ClientType) String 

func (x ClientType) String() string

func (ClientType) Type 

func (ClientType) Type() protoreflect.EnumType

type ClosedLoopParams 

type ClosedLoopParams struct {
	// contains filtered or unexported fields
}

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

func (*ClosedLoopParams) ProtoMessage 

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams) ProtoReflect 

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

func (*ClosedLoopParams) Reset 

func (x *ClosedLoopParams) Reset()

func (*ClosedLoopParams) String 

func (x *ClosedLoopParams) String() string

type ClosedLoopParams_builder 

type ClosedLoopParams_builder struct {
	// contains filtered or unexported fields
}

func (ClosedLoopParams_builder) Build 

func (b0 ClosedLoopParams_builder) Build() *ClosedLoopParams

type ComplexProtoParams 

type ComplexProtoParams struct {
	// contains filtered or unexported fields
}

func (*ComplexProtoParams) ProtoMessage 

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams) ProtoReflect 

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

func (*ComplexProtoParams) Reset 

func (x *ComplexProtoParams) Reset()

func (*ComplexProtoParams) String 

func (x *ComplexProtoParams) String() string

type ComplexProtoParams_builder 

type ComplexProtoParams_builder struct {
	// contains filtered or unexported fields
}

func (ComplexProtoParams_builder) Build 

func (b0 ComplexProtoParams_builder) Build() *ComplexProtoParams

type CoreRequest 

type CoreRequest struct {
	// contains filtered or unexported fields
}

func (*CoreRequest) ProtoMessage 

func (*CoreRequest) ProtoMessage()

func (*CoreRequest) ProtoReflect 

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

func (*CoreRequest) Reset 

func (x *CoreRequest) Reset()

func (*CoreRequest) String 

func (x *CoreRequest) String() string

type CoreRequest_builder 

type CoreRequest_builder struct {
	// contains filtered or unexported fields
}

func (CoreRequest_builder) Build 

func (b0 CoreRequest_builder) Build() *CoreRequest

type CoreResponse 

type CoreResponse struct {

	// Number of cores available on the server
	Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
	// contains filtered or unexported fields
}

func (*CoreResponse) GetCores 

func (x *CoreResponse) GetCores() int32

func (*CoreResponse) ProtoMessage 

func (*CoreResponse) ProtoMessage()

func (*CoreResponse) ProtoReflect 

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

func (*CoreResponse) Reset 

func (x *CoreResponse) Reset()

func (*CoreResponse) SetCores 

func (x *CoreResponse) SetCores(v int32)

func (*CoreResponse) String 

func (x *CoreResponse) String() string

type CoreResponse_builder 

type CoreResponse_builder struct {

	// Number of cores available on the server
	Cores int32
	// contains filtered or unexported fields
}

func (CoreResponse_builder) Build 

func (b0 CoreResponse_builder) Build() *CoreResponse

type EchoStatus 

type EchoStatus struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

func (*EchoStatus) GetCode 

func (x *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage 

func (x *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage 

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) ProtoReflect 

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

func (*EchoStatus) Reset 

func (x *EchoStatus) Reset()

func (*EchoStatus) SetCode 

func (x *EchoStatus) SetCode(v int32)

func (*EchoStatus) SetMessage 

func (x *EchoStatus) SetMessage(v string)

func (*EchoStatus) String 

func (x *EchoStatus) String() string

type EchoStatus_builder 

type EchoStatus_builder struct {
	Code    int32
	Message string
	// contains filtered or unexported fields
}

func (EchoStatus_builder) Build 

func (b0 EchoStatus_builder) Build() *EchoStatus

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

An empty message that you can re-use to avoid defining duplicated empty messages in your project. A typical example is to use it as argument or the return value of a service API. For instance: 

service Foo {
  rpc Bar (grpc.testing.Empty) returns (grpc.testing.Empty) { };
};

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Empty_builder 

type Empty_builder struct {
	// contains filtered or unexported fields
}

func (Empty_builder) Build 

func (b0 Empty_builder) Build() *Empty

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 dependent. 

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

func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor

func (GrpclbRouteType) Enum 

func (x GrpclbRouteType) Enum() *GrpclbRouteType

func (GrpclbRouteType) Number 

func (x GrpclbRouteType) Number() protoreflect.EnumNumber

func (GrpclbRouteType) String 

func (x GrpclbRouteType) String() string

func (GrpclbRouteType) Type 

func (GrpclbRouteType) Type() protoreflect.EnumType

type HistogramData 

type HistogramData struct {
	Bucket       []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"`
	MinSeen      float64  `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"`
	MaxSeen      float64  `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"`
	Sum          float64  `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	SumOfSquares float64  `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"`
	Count        float64  `protobuf:"fixed64,6,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Histogram data based on grpc/support/histogram.c

func (*HistogramData) GetBucket 

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

func (*HistogramData) GetCount 

func (x *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen 

func (x *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen 

func (x *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum 

func (x *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares 

func (x *HistogramData) GetSumOfSquares() float64

func (*HistogramData) ProtoMessage 

func (*HistogramData) ProtoMessage()

func (*HistogramData) ProtoReflect 

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

func (*HistogramData) Reset 

func (x *HistogramData) Reset()

func (*HistogramData) SetBucket 

func (x *HistogramData) SetBucket(v []uint32)

func (*HistogramData) SetCount 

func (x *HistogramData) SetCount(v float64)

func (*HistogramData) SetMaxSeen 

func (x *HistogramData) SetMaxSeen(v float64)

func (*HistogramData) SetMinSeen 

func (x *HistogramData) SetMinSeen(v float64)

func (*HistogramData) SetSum 

func (x *HistogramData) SetSum(v float64)

func (*HistogramData) SetSumOfSquares 

func (x *HistogramData) SetSumOfSquares(v float64)

func (*HistogramData) String 

func (x *HistogramData) String() string

type HistogramData_builder 

type HistogramData_builder struct {
	Bucket       []uint32
	MinSeen      float64
	MaxSeen      float64
	Sum          float64
	SumOfSquares float64
	Count        float64
	// contains filtered or unexported fields
}

func (HistogramData_builder) Build 

func (b0 HistogramData_builder) Build() *HistogramData

type HistogramParams 

type HistogramParams struct {
	Resolution  float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`                      // first bucket is [0, 1 + resolution)
	MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"` // use enough buckets to allow this value
	// contains filtered or unexported fields
}

Histogram params based on grpc/support/histogram.c

func (*HistogramParams) GetMaxPossible 

func (x *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution 

func (x *HistogramParams) GetResolution() float64

func (*HistogramParams) ProtoMessage 

func (*HistogramParams) ProtoMessage()

func (*HistogramParams) ProtoReflect 

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

func (*HistogramParams) Reset 

func (x *HistogramParams) Reset()

func (*HistogramParams) SetMaxPossible 

func (x *HistogramParams) SetMaxPossible(v float64)

func (*HistogramParams) SetResolution 

func (x *HistogramParams) SetResolution(v float64)

func (*HistogramParams) String 

func (x *HistogramParams) String() string

type HistogramParams_builder 

type HistogramParams_builder struct {
	Resolution  float64
	MaxPossible float64
	// contains filtered or unexported fields
}

func (HistogramParams_builder) Build 

func (b0 HistogramParams_builder) Build() *HistogramParams

type HookRequest 

type HookRequest struct {
	Command               HookRequest_HookRequestCommand `protobuf:"varint,1,opt,name=command,proto3,enum=grpc.testing.HookRequest_HookRequestCommand" json:"command,omitempty"`
	GrpcCodeToReturn      int32                          `protobuf:"varint,2,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"`
	GrpcStatusDescription string                         `` /* 126-byte string literal not displayed */
	// Server port to listen to
	ServerPort int32 `protobuf:"varint,4,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	// contains filtered or unexported fields
}

func (*HookRequest) GetCommand 

func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand

func (*HookRequest) GetGrpcCodeToReturn 

func (x *HookRequest) GetGrpcCodeToReturn() int32

func (*HookRequest) GetGrpcStatusDescription 

func (x *HookRequest) GetGrpcStatusDescription() string

func (*HookRequest) GetServerPort 

func (x *HookRequest) GetServerPort() int32

func (*HookRequest) ProtoMessage 

func (*HookRequest) ProtoMessage()

func (*HookRequest) ProtoReflect 

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

func (*HookRequest) Reset 

func (x *HookRequest) Reset()

func (*HookRequest) SetCommand 

func (x *HookRequest) SetCommand(v HookRequest_HookRequestCommand)

func (*HookRequest) SetGrpcCodeToReturn 

func (x *HookRequest) SetGrpcCodeToReturn(v int32)

func (*HookRequest) SetGrpcStatusDescription 

func (x *HookRequest) SetGrpcStatusDescription(v string)

func (*HookRequest) SetServerPort 

func (x *HookRequest) SetServerPort(v int32)

func (*HookRequest) String 

func (x *HookRequest) String() string

type HookRequest_HookRequestCommand 

type HookRequest_HookRequestCommand int32
const (
	// Default value
	HookRequest_UNSPECIFIED HookRequest_HookRequestCommand = 0
	// Start the HTTP endpoint
	HookRequest_START HookRequest_HookRequestCommand = 1
	// Stop
	HookRequest_STOP HookRequest_HookRequestCommand = 2
	// Return from HTTP GET/POST
	HookRequest_RETURN HookRequest_HookRequestCommand = 3
)

func (HookRequest_HookRequestCommand) Descriptor 

func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor

func (HookRequest_HookRequestCommand) Enum 

func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand

func (HookRequest_HookRequestCommand) Number 

func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber

func (HookRequest_HookRequestCommand) String 

func (x HookRequest_HookRequestCommand) String() string

func (HookRequest_HookRequestCommand) Type 

func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType

type HookRequest_builder 

type HookRequest_builder struct {
	Command               HookRequest_HookRequestCommand
	GrpcCodeToReturn      int32
	GrpcStatusDescription string
	// Server port to listen to
	ServerPort int32
	// contains filtered or unexported fields
}

func (HookRequest_builder) Build 

func (b0 HookRequest_builder) Build() *HookRequest

type HookResponse 

type HookResponse struct {
	// contains filtered or unexported fields
}

func (*HookResponse) ProtoMessage 

func (*HookResponse) ProtoMessage()

func (*HookResponse) ProtoReflect 

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

func (*HookResponse) Reset 

func (x *HookResponse) Reset()

func (*HookResponse) String 

func (x *HookResponse) String() string

type HookResponse_builder 

type HookResponse_builder struct {
	// contains filtered or unexported fields
}

func (HookResponse_builder) Build 

func (b0 HookResponse_builder) Build() *HookResponse

type LoadBalancerAccumulatedStatsRequest 

type LoadBalancerAccumulatedStatsRequest struct {
	// contains filtered or unexported fields
}

Request for retrieving a test client's accumulated stats.

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage 

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()

func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect 

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

func (*LoadBalancerAccumulatedStatsRequest) Reset 

func (x *LoadBalancerAccumulatedStatsRequest) Reset()

func (*LoadBalancerAccumulatedStatsRequest) String 

func (x *LoadBalancerAccumulatedStatsRequest) String() string

type LoadBalancerAccumulatedStatsRequest_builder 

type LoadBalancerAccumulatedStatsRequest_builder struct {
	// contains filtered or unexported fields
}

func (LoadBalancerAccumulatedStatsRequest_builder) Build 

func (b0 LoadBalancerAccumulatedStatsRequest_builder) Build() *LoadBalancerAccumulatedStatsRequest

type LoadBalancerAccumulatedStatsResponse 

type LoadBalancerAccumulatedStatsResponse struct {

	// The total number of RPCs have ever issued for each type.
	// Deprecated: use stats_per_method.rpcs_started instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsStartedByMethod map[string]int32 `` /* 208-byte string literal not displayed */
	// The total number of RPCs have ever completed successfully for each type.
	// Deprecated: use stats_per_method.result instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsSucceededByMethod map[string]int32 `` /* 214-byte string literal not displayed */
	// The total number of RPCs have ever failed for each type.
	// Deprecated: use stats_per_method.result instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsFailedByMethod map[string]int32 `` /* 205-byte string literal not displayed */
	// Per-method RPC statistics.  The key is the RpcType in string form; e.g.
	// 'EMPTY_CALL' or 'UNARY_CALL'
	StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

Accumulated stats for RPCs sent by a test client.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod 

func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats

func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage 

func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()

func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect 

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

func (*LoadBalancerAccumulatedStatsResponse) Reset 

func (x *LoadBalancerAccumulatedStatsResponse) Reset()

func (*LoadBalancerAccumulatedStatsResponse) SetNumRpcsFailedByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) SetNumRpcsFailedByMethod(v map[string]int32)

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) SetNumRpcsStartedByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) SetNumRpcsStartedByMethod(v map[string]int32)

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) SetNumRpcsSucceededByMethod deprecated 

func (x *LoadBalancerAccumulatedStatsResponse) SetNumRpcsSucceededByMethod(v map[string]int32)

Deprecated: Marked as deprecated in grpc/testing/messages.proto.

func (*LoadBalancerAccumulatedStatsResponse) SetStatsPerMethod 

func (x *LoadBalancerAccumulatedStatsResponse) SetStatsPerMethod(v map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats)

func (*LoadBalancerAccumulatedStatsResponse) String 

func (x *LoadBalancerAccumulatedStatsResponse) String() string

type LoadBalancerAccumulatedStatsResponse_MethodStats 

type LoadBalancerAccumulatedStatsResponse_MethodStats struct {

	// The number of RPCs that were started for this method.
	RpcsStarted int32 `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"`
	// The number of RPCs that completed with each status for this method.  The
	// key is the integral value of a google.rpc.Code; the value is the count.
	Result map[int32]int32 `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage 

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect 

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

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) SetResult 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) SetResult(v map[int32]int32)

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) SetRpcsStarted 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) SetRpcsStarted(v int32)

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String 

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string

type LoadBalancerAccumulatedStatsResponse_MethodStats_builder 

type LoadBalancerAccumulatedStatsResponse_MethodStats_builder struct {

	// The number of RPCs that were started for this method.
	RpcsStarted int32
	// The number of RPCs that completed with each status for this method.  The
	// key is the integral value of a google.rpc.Code; the value is the count.
	Result map[int32]int32
	// contains filtered or unexported fields
}

func (LoadBalancerAccumulatedStatsResponse_MethodStats_builder) Build 

func (b0 LoadBalancerAccumulatedStatsResponse_MethodStats_builder) Build() *LoadBalancerAccumulatedStatsResponse_MethodStats

type LoadBalancerAccumulatedStatsResponse_builder 

type LoadBalancerAccumulatedStatsResponse_builder struct {

	// The total number of RPCs have ever issued for each type.
	// Deprecated: use stats_per_method.rpcs_started instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsStartedByMethod map[string]int32
	// The total number of RPCs have ever completed successfully for each type.
	// Deprecated: use stats_per_method.result instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsSucceededByMethod map[string]int32
	// The total number of RPCs have ever failed for each type.
	// Deprecated: use stats_per_method.result instead.
	//
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsFailedByMethod map[string]int32
	// Per-method RPC statistics.  The key is the RpcType in string form; e.g.
	// 'EMPTY_CALL' or 'UNARY_CALL'
	StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats
	// contains filtered or unexported fields
}

func (LoadBalancerAccumulatedStatsResponse_builder) Build 

func (b0 LoadBalancerAccumulatedStatsResponse_builder) Build() *LoadBalancerAccumulatedStatsResponse

type LoadBalancerStatsRequest 

type LoadBalancerStatsRequest struct {

	// Request stats for the next num_rpcs sent by client.
	NumRpcs int32 `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"`
	// If num_rpcs have not completed within timeout_sec, return partial results.
	TimeoutSec int32 `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
	// Response header + trailer metadata entries we want the values of.
	// Matching of the keys is case-insensitive as per rfc7540#section-8.1.2
	// * (asterisk) is a special value that will return all metadata entries
	MetadataKeys []string `protobuf:"bytes,3,rep,name=metadata_keys,json=metadataKeys,proto3" json:"metadata_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsRequest) GetMetadataKeys 

func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string

func (*LoadBalancerStatsRequest) GetNumRpcs 

func (x *LoadBalancerStatsRequest) GetNumRpcs() int32

func (*LoadBalancerStatsRequest) GetTimeoutSec 

func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32

func (*LoadBalancerStatsRequest) ProtoMessage 

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest) ProtoReflect 

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

func (*LoadBalancerStatsRequest) Reset 

func (x *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest) SetMetadataKeys 

func (x *LoadBalancerStatsRequest) SetMetadataKeys(v []string)

func (*LoadBalancerStatsRequest) SetNumRpcs 

func (x *LoadBalancerStatsRequest) SetNumRpcs(v int32)

func (*LoadBalancerStatsRequest) SetTimeoutSec 

func (x *LoadBalancerStatsRequest) SetTimeoutSec(v int32)

func (*LoadBalancerStatsRequest) String 

func (x *LoadBalancerStatsRequest) String() string

type LoadBalancerStatsRequest_builder 

type LoadBalancerStatsRequest_builder struct {

	// Request stats for the next num_rpcs sent by client.
	NumRpcs int32
	// If num_rpcs have not completed within timeout_sec, return partial results.
	TimeoutSec int32
	// Response header + trailer metadata entries we want the values of.
	// Matching of the keys is case-insensitive as per rfc7540#section-8.1.2
	// * (asterisk) is a special value that will return all metadata entries
	MetadataKeys []string
	// contains filtered or unexported fields
}

func (LoadBalancerStatsRequest_builder) Build 

func (b0 LoadBalancerStatsRequest_builder) Build() *LoadBalancerStatsRequest

type LoadBalancerStatsResponse 

type LoadBalancerStatsResponse struct {

	// The number of completed RPCs for each peer.
	RpcsByPeer map[string]int32 `` /* 168-byte string literal not displayed */
	// The number of RPCs that failed to record a remote peer.
	NumFailures  int32                                            `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
	RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `` /* 173-byte string literal not displayed */
	// All the metadata of all RPCs for each peer.
	MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse) GetMetadatasByPeer 

func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer

func (*LoadBalancerStatsResponse) GetNumFailures 

func (x *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod 

func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer

func (*LoadBalancerStatsResponse) GetRpcsByPeer 

func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32

func (*LoadBalancerStatsResponse) ProtoMessage 

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) ProtoReflect 

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

func (*LoadBalancerStatsResponse) Reset 

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) SetMetadatasByPeer 

func (x *LoadBalancerStatsResponse) SetMetadatasByPeer(v map[string]*LoadBalancerStatsResponse_MetadataByPeer)

func (*LoadBalancerStatsResponse) SetNumFailures 

func (x *LoadBalancerStatsResponse) SetNumFailures(v int32)

func (*LoadBalancerStatsResponse) SetRpcsByMethod 

func (x *LoadBalancerStatsResponse) SetRpcsByMethod(v map[string]*LoadBalancerStatsResponse_RpcsByPeer)

func (*LoadBalancerStatsResponse) SetRpcsByPeer 

func (x *LoadBalancerStatsResponse) SetRpcsByPeer(v map[string]int32)

func (*LoadBalancerStatsResponse) String 

func (x *LoadBalancerStatsResponse) String() string

type LoadBalancerStatsResponse_MetadataByPeer 

type LoadBalancerStatsResponse_MetadataByPeer struct {

	// List of RpcMetadata in for each RPC with a given peer
	RpcMetadata []*LoadBalancerStatsResponse_RpcMetadata `protobuf:"bytes,1,rep,name=rpc_metadata,json=rpcMetadata,proto3" json:"rpc_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata 

func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata

func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage 

func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect 

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

func (*LoadBalancerStatsResponse_MetadataByPeer) Reset 

func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset()

func (*LoadBalancerStatsResponse_MetadataByPeer) SetRpcMetadata 

func (x *LoadBalancerStatsResponse_MetadataByPeer) SetRpcMetadata(v []*LoadBalancerStatsResponse_RpcMetadata)

func (*LoadBalancerStatsResponse_MetadataByPeer) String 

func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string

type LoadBalancerStatsResponse_MetadataByPeer_builder 

type LoadBalancerStatsResponse_MetadataByPeer_builder struct {

	// List of RpcMetadata in for each RPC with a given peer
	RpcMetadata []*LoadBalancerStatsResponse_RpcMetadata
	// contains filtered or unexported fields
}

func (LoadBalancerStatsResponse_MetadataByPeer_builder) Build 

func (b0 LoadBalancerStatsResponse_MetadataByPeer_builder) Build() *LoadBalancerStatsResponse_MetadataByPeer

type LoadBalancerStatsResponse_MetadataEntry 

type LoadBalancerStatsResponse_MetadataEntry struct {

	// Key, exactly as received from the server. Case may be different from what
	// was requested in the LoadBalancerStatsRequest)
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value, exactly as received from the server.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Metadata type
	Type LoadBalancerStatsResponse_MetadataType `protobuf:"varint,3,opt,name=type,proto3,enum=grpc.testing.LoadBalancerStatsResponse_MetadataType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_MetadataEntry) GetKey 

func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string

func (*LoadBalancerStatsResponse_MetadataEntry) GetType 

func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType

func (*LoadBalancerStatsResponse_MetadataEntry) GetValue 

func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string

func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage 

func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage()

func (*LoadBalancerStatsResponse_MetadataEntry) ProtoReflect 

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

func (*LoadBalancerStatsResponse_MetadataEntry) Reset 

func (x *LoadBalancerStatsResponse_MetadataEntry) Reset()

func (*LoadBalancerStatsResponse_MetadataEntry) SetKey 

func (x *LoadBalancerStatsResponse_MetadataEntry) SetKey(v string)

func (*LoadBalancerStatsResponse_MetadataEntry) SetType 

func (x *LoadBalancerStatsResponse_MetadataEntry) SetType(v LoadBalancerStatsResponse_MetadataType)

func (*LoadBalancerStatsResponse_MetadataEntry) SetValue 

func (x *LoadBalancerStatsResponse_MetadataEntry) SetValue(v string)

func (*LoadBalancerStatsResponse_MetadataEntry) String 

func (x *LoadBalancerStatsResponse_MetadataEntry) String() string

type LoadBalancerStatsResponse_MetadataEntry_builder 

type LoadBalancerStatsResponse_MetadataEntry_builder struct {

	// Key, exactly as received from the server. Case may be different from what
	// was requested in the LoadBalancerStatsRequest)
	Key string
	// Value, exactly as received from the server.
	Value string
	// Metadata type
	Type LoadBalancerStatsResponse_MetadataType
	// contains filtered or unexported fields
}

func (LoadBalancerStatsResponse_MetadataEntry_builder) Build 

func (b0 LoadBalancerStatsResponse_MetadataEntry_builder) Build() *LoadBalancerStatsResponse_MetadataEntry

type LoadBalancerStatsResponse_MetadataType 

type LoadBalancerStatsResponse_MetadataType int32
const (
	LoadBalancerStatsResponse_UNKNOWN  LoadBalancerStatsResponse_MetadataType = 0
	LoadBalancerStatsResponse_INITIAL  LoadBalancerStatsResponse_MetadataType = 1
	LoadBalancerStatsResponse_TRAILING LoadBalancerStatsResponse_MetadataType = 2
)

func (LoadBalancerStatsResponse_MetadataType) Descriptor 

func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor

func (LoadBalancerStatsResponse_MetadataType) Enum 

func (x LoadBalancerStatsResponse_MetadataType) Enum() *LoadBalancerStatsResponse_MetadataType

func (LoadBalancerStatsResponse_MetadataType) Number 

func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber

func (LoadBalancerStatsResponse_MetadataType) String 

func (x LoadBalancerStatsResponse_MetadataType) String() string

func (LoadBalancerStatsResponse_MetadataType) Type 

func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType

type LoadBalancerStatsResponse_RpcMetadata 

type LoadBalancerStatsResponse_RpcMetadata struct {

	// metadata values for each rpc for the keys specified in
	// LoadBalancerStatsRequest.metadata_keys.
	Metadata []*LoadBalancerStatsResponse_MetadataEntry `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_RpcMetadata) GetMetadata 

func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage 

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoReflect 

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

func (*LoadBalancerStatsResponse_RpcMetadata) Reset 

func (x *LoadBalancerStatsResponse_RpcMetadata) Reset()

func (*LoadBalancerStatsResponse_RpcMetadata) SetMetadata 

func (x *LoadBalancerStatsResponse_RpcMetadata) SetMetadata(v []*LoadBalancerStatsResponse_MetadataEntry)

func (*LoadBalancerStatsResponse_RpcMetadata) String 

func (x *LoadBalancerStatsResponse_RpcMetadata) String() string

type LoadBalancerStatsResponse_RpcMetadata_builder 

type LoadBalancerStatsResponse_RpcMetadata_builder struct {

	// metadata values for each rpc for the keys specified in
	// LoadBalancerStatsRequest.metadata_keys.
	Metadata []*LoadBalancerStatsResponse_MetadataEntry
	// contains filtered or unexported fields
}

func (LoadBalancerStatsResponse_RpcMetadata_builder) Build 

func (b0 LoadBalancerStatsResponse_RpcMetadata_builder) Build() *LoadBalancerStatsResponse_RpcMetadata

type LoadBalancerStatsResponse_RpcsByPeer 

type LoadBalancerStatsResponse_RpcsByPeer struct {

	// The number of completed RPCs for each peer.
	RpcsByPeer map[string]int32 `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer 

func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage 

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect 

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

func (*LoadBalancerStatsResponse_RpcsByPeer) Reset 

func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()

func (*LoadBalancerStatsResponse_RpcsByPeer) SetRpcsByPeer 

func (x *LoadBalancerStatsResponse_RpcsByPeer) SetRpcsByPeer(v map[string]int32)

func (*LoadBalancerStatsResponse_RpcsByPeer) String 

func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string

type LoadBalancerStatsResponse_RpcsByPeer_builder 

type LoadBalancerStatsResponse_RpcsByPeer_builder struct {

	// The number of completed RPCs for each peer.
	RpcsByPeer map[string]int32
	// contains filtered or unexported fields
}

func (LoadBalancerStatsResponse_RpcsByPeer_builder) Build 

func (b0 LoadBalancerStatsResponse_RpcsByPeer_builder) Build() *LoadBalancerStatsResponse_RpcsByPeer

type LoadBalancerStatsResponse_builder 

type LoadBalancerStatsResponse_builder struct {

	// The number of completed RPCs for each peer.
	RpcsByPeer map[string]int32
	// The number of RPCs that failed to record a remote peer.
	NumFailures  int32
	RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer
	// All the metadata of all RPCs for each peer.
	MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer
	// contains filtered or unexported fields
}

func (LoadBalancerStatsResponse_builder) Build 

func (b0 LoadBalancerStatsResponse_builder) Build() *LoadBalancerStatsResponse

type LoadParams 

type LoadParams struct {

	// Types that are valid to be assigned to Load:
	//
	//	*LoadParams_ClosedLoop
	//	*LoadParams_Poisson
	Load isLoadParams_Load `protobuf_oneof:"load"`
	// contains filtered or unexported fields
}

func (*LoadParams) ClearClosedLoop 

func (x *LoadParams) ClearClosedLoop()

func (*LoadParams) ClearLoad 

func (x *LoadParams) ClearLoad()

func (*LoadParams) ClearPoisson 

func (x *LoadParams) ClearPoisson()

func (*LoadParams) GetClosedLoop 

func (x *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams) GetLoad 

func (x *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPoisson 

func (x *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) HasClosedLoop 

func (x *LoadParams) HasClosedLoop() bool

func (*LoadParams) HasLoad 

func (x *LoadParams) HasLoad() bool

func (*LoadParams) HasPoisson 

func (x *LoadParams) HasPoisson() bool

func (*LoadParams) ProtoMessage 

func (*LoadParams) ProtoMessage()

func (*LoadParams) ProtoReflect 

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

func (*LoadParams) Reset 

func (x *LoadParams) Reset()

func (*LoadParams) SetClosedLoop 

func (x *LoadParams) SetClosedLoop(v *ClosedLoopParams)

func (*LoadParams) SetPoisson 

func (x *LoadParams) SetPoisson(v *PoissonParams)

func (*LoadParams) String 

func (x *LoadParams) String() string

func (*LoadParams) WhichLoad 

func (x *LoadParams) WhichLoad() case_LoadParams_Load

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 LoadParams_builder 

type LoadParams_builder struct {

	// Fields of oneof Load:
	ClosedLoop *ClosedLoopParams
	Poisson    *PoissonParams
	// contains filtered or unexported fields
}

func (LoadParams_builder) Build 

func (b0 LoadParams_builder) Build() *LoadParams

type Mark 

type Mark struct {

	// if true, the stats will be reset after taking their snapshot.
	Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

Request current stats

func (*Mark) GetReset 

func (x *Mark) GetReset() bool

func (*Mark) GetReset_ deprecated 

func (x *Mark) GetReset_() bool

Deprecated: Use GetReset instead.

func (*Mark) ProtoMessage 

func (*Mark) ProtoMessage()

func (*Mark) ProtoReflect 

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

func (*Mark) Reset 

func (x *Mark) Reset()

func (*Mark) SetReset 

func (x *Mark) SetReset(v bool)

func (*Mark) String 

func (x *Mark) String() string

type Mark_builder 

type Mark_builder struct {

	// if true, the stats will be reset after taking their snapshot.
	Reset bool
	// contains filtered or unexported fields
}

func (Mark_builder) Build 

func (b0 Mark_builder) Build() *Mark

type MemorySize 

type MemorySize struct {
	Rss int64 `protobuf:"varint,1,opt,name=rss,proto3" json:"rss,omitempty"`
	// contains filtered or unexported fields
}

func (*MemorySize) GetRss 

func (x *MemorySize) GetRss() int64

func (*MemorySize) ProtoMessage 

func (*MemorySize) ProtoMessage()

func (*MemorySize) ProtoReflect 

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

func (*MemorySize) Reset 

func (x *MemorySize) Reset()

func (*MemorySize) SetRss 

func (x *MemorySize) SetRss(v int64)

func (*MemorySize) String 

func (x *MemorySize) String() string

type MemorySize_builder 

type MemorySize_builder struct {
	Rss int64
	// contains filtered or unexported fields
}

func (MemorySize_builder) Build 

func (b0 MemorySize_builder) Build() *MemorySize

type Payload 

type Payload struct {

	// The type of data in body.
	Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
	// Primary contents of payload.
	Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Payload) GetBody 

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

func (*Payload) GetType 

func (x *Payload) GetType() PayloadType

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) SetBody 

func (x *Payload) SetBody(v []byte)

func (*Payload) SetType 

func (x *Payload) SetType(v PayloadType)

func (*Payload) String 

func (x *Payload) String() string

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"`
	// contains filtered or unexported fields
}

func (*PayloadConfig) ClearBytebufParams 

func (x *PayloadConfig) ClearBytebufParams()

func (*PayloadConfig) ClearComplexParams 

func (x *PayloadConfig) ClearComplexParams()

func (*PayloadConfig) ClearPayload 

func (x *PayloadConfig) ClearPayload()

func (*PayloadConfig) ClearSimpleParams 

func (x *PayloadConfig) ClearSimpleParams()

func (*PayloadConfig) GetBytebufParams 

func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams 

func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload 

func (x *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams 

func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) HasBytebufParams 

func (x *PayloadConfig) HasBytebufParams() bool

func (*PayloadConfig) HasComplexParams 

func (x *PayloadConfig) HasComplexParams() bool

func (*PayloadConfig) HasPayload 

func (x *PayloadConfig) HasPayload() bool

func (*PayloadConfig) HasSimpleParams 

func (x *PayloadConfig) HasSimpleParams() bool

func (*PayloadConfig) ProtoMessage 

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) ProtoReflect 

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

func (*PayloadConfig) Reset 

func (x *PayloadConfig) Reset()

func (*PayloadConfig) SetBytebufParams 

func (x *PayloadConfig) SetBytebufParams(v *ByteBufferParams)

func (*PayloadConfig) SetComplexParams 

func (x *PayloadConfig) SetComplexParams(v *ComplexProtoParams)

func (*PayloadConfig) SetSimpleParams 

func (x *PayloadConfig) SetSimpleParams(v *SimpleProtoParams)

func (*PayloadConfig) String 

func (x *PayloadConfig) String() string

func (*PayloadConfig) WhichPayload 

func (x *PayloadConfig) WhichPayload() case_PayloadConfig_Payload

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 PayloadConfig_builder 

type PayloadConfig_builder struct {

	// Fields of oneof Payload:
	BytebufParams *ByteBufferParams
	SimpleParams  *SimpleProtoParams
	ComplexParams *ComplexProtoParams
	// contains filtered or unexported fields
}

func (PayloadConfig_builder) Build 

func (b0 PayloadConfig_builder) Build() *PayloadConfig

type PayloadType 

type PayloadType int32

The type of payload that should be returned. 

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

func (PayloadType) Descriptor 

func (PayloadType) Descriptor() protoreflect.EnumDescriptor

func (PayloadType) Enum 

func (x PayloadType) Enum() *PayloadType

func (PayloadType) Number 

func (x PayloadType) Number() protoreflect.EnumNumber

func (PayloadType) String 

func (x PayloadType) String() string

func (PayloadType) Type 

func (PayloadType) Type() protoreflect.EnumType

type Payload_builder 

type Payload_builder struct {

	// The type of data in body.
	Type PayloadType
	// Primary contents of payload.
	Body []byte
	// contains filtered or unexported fields
}

func (Payload_builder) Build 

func (b0 Payload_builder) Build() *Payload

type PoissonParams 

type PoissonParams struct {

	// The rate of arrivals (a.k.a. lambda parameter of the exp distribution).
	OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
	// contains filtered or unexported fields
}

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

func (*PoissonParams) GetOfferedLoad 

func (x *PoissonParams) GetOfferedLoad() float64

func (*PoissonParams) ProtoMessage 

func (*PoissonParams) ProtoMessage()

func (*PoissonParams) ProtoReflect 

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

func (*PoissonParams) Reset 

func (x *PoissonParams) Reset()

func (*PoissonParams) SetOfferedLoad 

func (x *PoissonParams) SetOfferedLoad(v float64)

func (*PoissonParams) String 

func (x *PoissonParams) String() string

type PoissonParams_builder 

type PoissonParams_builder struct {

	// The rate of arrivals (a.k.a. lambda parameter of the exp distribution).
	OfferedLoad float64
	// contains filtered or unexported fields
}

func (PoissonParams_builder) Build 

func (b0 PoissonParams_builder) Build() *PoissonParams

type ReconnectInfo 

type ReconnectInfo struct {
	Passed    bool    `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
	BackoffMs []int32 `protobuf:"varint,2,rep,packed,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ReconnectInfo) GetBackoffMs 

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

func (*ReconnectInfo) GetPassed 

func (x *ReconnectInfo) GetPassed() bool

func (*ReconnectInfo) ProtoMessage 

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo) ProtoReflect 

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

func (*ReconnectInfo) Reset 

func (x *ReconnectInfo) Reset()

func (*ReconnectInfo) SetBackoffMs 

func (x *ReconnectInfo) SetBackoffMs(v []int32)

func (*ReconnectInfo) SetPassed 

func (x *ReconnectInfo) SetPassed(v bool)

func (*ReconnectInfo) String 

func (x *ReconnectInfo) String() string

type ReconnectInfo_builder 

type ReconnectInfo_builder struct {
	Passed    bool
	BackoffMs []int32
	// contains filtered or unexported fields
}

func (ReconnectInfo_builder) Build 

func (b0 ReconnectInfo_builder) Build() *ReconnectInfo

type ReconnectParams 

type ReconnectParams struct {
	MaxReconnectBackoffMs int32 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*ReconnectParams) GetMaxReconnectBackoffMs 

func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32

func (*ReconnectParams) ProtoMessage 

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams) ProtoReflect 

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

func (*ReconnectParams) Reset 

func (x *ReconnectParams) Reset()

func (*ReconnectParams) SetMaxReconnectBackoffMs 

func (x *ReconnectParams) SetMaxReconnectBackoffMs(v int32)

func (*ReconnectParams) String 

func (x *ReconnectParams) String() string

type ReconnectParams_builder 

type ReconnectParams_builder struct {
	MaxReconnectBackoffMs int32
	// contains filtered or unexported fields
}

func (ReconnectParams_builder) Build 

func (b0 ReconnectParams_builder) Build() *ReconnectParams

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"`
	// contains filtered or unexported fields
}

func (*RequestResultCount) GetCount 

func (x *RequestResultCount) GetCount() int64

func (*RequestResultCount) GetStatusCode 

func (x *RequestResultCount) GetStatusCode() int32

func (*RequestResultCount) ProtoMessage 

func (*RequestResultCount) ProtoMessage()

func (*RequestResultCount) ProtoReflect 

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

func (*RequestResultCount) Reset 

func (x *RequestResultCount) Reset()

func (*RequestResultCount) SetCount 

func (x *RequestResultCount) SetCount(v int64)

func (*RequestResultCount) SetStatusCode 

func (x *RequestResultCount) SetStatusCode(v int32)

func (*RequestResultCount) String 

func (x *RequestResultCount) String() string

type RequestResultCount_builder 

type RequestResultCount_builder struct {
	StatusCode int32
	Count      int64
	// contains filtered or unexported fields
}

func (RequestResultCount_builder) Build 

func (b0 RequestResultCount_builder) Build() *RequestResultCount

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"`
	// contains filtered or unexported fields
}

Configuration for a particular response.

func (*ResponseParameters) ClearCompressed 

func (x *ResponseParameters) ClearCompressed()

func (*ResponseParameters) GetCompressed 

func (x *ResponseParameters) GetCompressed() *BoolValue

func (*ResponseParameters) GetIntervalUs 

func (x *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize 

func (x *ResponseParameters) GetSize() int32

func (*ResponseParameters) HasCompressed 

func (x *ResponseParameters) HasCompressed() bool

func (*ResponseParameters) ProtoMessage 

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) ProtoReflect 

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

func (*ResponseParameters) Reset 

func (x *ResponseParameters) Reset()

func (*ResponseParameters) SetCompressed 

func (x *ResponseParameters) SetCompressed(v *BoolValue)

func (*ResponseParameters) SetIntervalUs 

func (x *ResponseParameters) SetIntervalUs(v int32)

func (*ResponseParameters) SetSize 

func (x *ResponseParameters) SetSize(v int32)

func (*ResponseParameters) String 

func (x *ResponseParameters) String() string

type ResponseParameters_builder 

type ResponseParameters_builder struct {

	// Desired payload sizes in responses from the server.
	Size int32
	// Desired interval between consecutive responses in the response stream in
	// microseconds.
	IntervalUs int32
	// 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
	// contains filtered or unexported fields
}

func (ResponseParameters_builder) Build 

func (b0 ResponseParameters_builder) Build() *ResponseParameters

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

func (RpcType) Descriptor() protoreflect.EnumDescriptor

func (RpcType) Enum 

func (x RpcType) Enum() *RpcType

func (RpcType) Number 

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String 

func (x RpcType) String() string

func (RpcType) Type 

func (RpcType) Type() protoreflect.EnumType

type Scenario 

type Scenario struct {

	// 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 */
	// contains filtered or unexported fields
}

A single performance scenario: input to qps_json_driver

func (*Scenario) ClearClientConfig 

func (x *Scenario) ClearClientConfig()

func (*Scenario) ClearServerConfig 

func (x *Scenario) ClearServerConfig()

func (*Scenario) GetBenchmarkSeconds 

func (x *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig 

func (x *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName 

func (x *Scenario) GetName() string

func (*Scenario) GetNumClients 

func (x *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers 

func (x *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig 

func (x *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount 

func (x *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds 

func (x *Scenario) GetWarmupSeconds() int32

func (*Scenario) HasClientConfig 

func (x *Scenario) HasClientConfig() bool

func (*Scenario) HasServerConfig 

func (x *Scenario) HasServerConfig() bool

func (*Scenario) ProtoMessage 

func (*Scenario) ProtoMessage()

func (*Scenario) ProtoReflect 

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

func (*Scenario) Reset 

func (x *Scenario) Reset()

func (*Scenario) SetBenchmarkSeconds 

func (x *Scenario) SetBenchmarkSeconds(v int32)

func (*Scenario) SetClientConfig 

func (x *Scenario) SetClientConfig(v *ClientConfig)

func (*Scenario) SetName 

func (x *Scenario) SetName(v string)

func (*Scenario) SetNumClients 

func (x *Scenario) SetNumClients(v int32)

func (*Scenario) SetNumServers 

func (x *Scenario) SetNumServers(v int32)

func (*Scenario) SetServerConfig 

func (x *Scenario) SetServerConfig(v *ServerConfig)

func (*Scenario) SetSpawnLocalWorkerCount 

func (x *Scenario) SetSpawnLocalWorkerCount(v int32)

func (*Scenario) SetWarmupSeconds 

func (x *Scenario) SetWarmupSeconds(v int32)

func (*Scenario) String 

func (x *Scenario) String() string

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"`
	// contains filtered or unexported fields
}

Results of a single benchmark scenario.

func (*ScenarioResult) ClearLatencies 

func (x *ScenarioResult) ClearLatencies()

func (*ScenarioResult) ClearScenario 

func (x *ScenarioResult) ClearScenario()

func (*ScenarioResult) ClearSummary 

func (x *ScenarioResult) ClearSummary()

func (*ScenarioResult) GetClientStats 

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

func (*ScenarioResult) GetClientSuccess 

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

func (*ScenarioResult) GetLatencies 

func (x *ScenarioResult) GetLatencies() *HistogramData

func (*ScenarioResult) GetRequestResults 

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

func (*ScenarioResult) GetScenario 

func (x *ScenarioResult) GetScenario() *Scenario

func (*ScenarioResult) GetServerCores 

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

func (*ScenarioResult) GetServerStats 

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

func (*ScenarioResult) GetServerSuccess 

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

func (*ScenarioResult) GetSummary 

func (x *ScenarioResult) GetSummary() *ScenarioResultSummary

func (*ScenarioResult) HasLatencies 

func (x *ScenarioResult) HasLatencies() bool

func (*ScenarioResult) HasScenario 

func (x *ScenarioResult) HasScenario() bool

func (*ScenarioResult) HasSummary 

func (x *ScenarioResult) HasSummary() bool

func (*ScenarioResult) ProtoMessage 

func (*ScenarioResult) ProtoMessage()

func (*ScenarioResult) ProtoReflect 

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

func (*ScenarioResult) Reset 

func (x *ScenarioResult) Reset()

func (*ScenarioResult) SetClientStats 

func (x *ScenarioResult) SetClientStats(v []*ClientStats)

func (*ScenarioResult) SetClientSuccess 

func (x *ScenarioResult) SetClientSuccess(v []bool)

func (*ScenarioResult) SetLatencies 

func (x *ScenarioResult) SetLatencies(v *HistogramData)

func (*ScenarioResult) SetRequestResults 

func (x *ScenarioResult) SetRequestResults(v []*RequestResultCount)

func (*ScenarioResult) SetScenario 

func (x *ScenarioResult) SetScenario(v *Scenario)

func (*ScenarioResult) SetServerCores 

func (x *ScenarioResult) SetServerCores(v []int32)

func (*ScenarioResult) SetServerStats 

func (x *ScenarioResult) SetServerStats(v []*ServerStats)

func (*ScenarioResult) SetServerSuccess 

func (x *ScenarioResult) SetServerSuccess(v []bool)

func (*ScenarioResult) SetSummary 

func (x *ScenarioResult) SetSummary(v *ScenarioResultSummary)

func (*ScenarioResult) String 

func (x *ScenarioResult) String() string

type ScenarioResultSummary 

type ScenarioResultSummary struct {

	// Total number of operations per second over all clients. What is counted as 1 'operation' depends on the benchmark scenarios:
	// For unary benchmarks, an operation is processing of a single unary RPC.
	// For streaming benchmarks, an operation is processing of a single ping pong of request and response.
	Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
	// QPS per server core.
	QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
	// The total server cpu load based on system time across all server processes, expressed as percentage of a single cpu core.
	// For example, 85 implies 85% of a cpu core, 125 implies 125% of a cpu core. Since we are accumulating the cpu load across all the server
	// processes, the value could > 100 when there are multiple servers or a single server using multiple threads and cores.
	// Same explanation for the total client cpu load below.
	ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
	// The total server cpu load based on user time across all server processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
	// The total client cpu load based on system time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
	// The total client cpu load based on user time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	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 */
	// Start and end time for the test scenario
	StartTime *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ScenarioResultSummary) ClearEndTime 

func (x *ScenarioResultSummary) ClearEndTime()

func (*ScenarioResultSummary) ClearStartTime 

func (x *ScenarioResultSummary) ClearStartTime()

func (*ScenarioResultSummary) GetClientPollsPerRequest 

func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64

func (*ScenarioResultSummary) GetClientQueriesPerCpuSec 

func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetClientSystemTime 

func (x *ScenarioResultSummary) GetClientSystemTime() float64

func (*ScenarioResultSummary) GetClientUserTime 

func (x *ScenarioResultSummary) GetClientUserTime() float64

func (*ScenarioResultSummary) GetEndTime 

func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp

func (*ScenarioResultSummary) GetFailedRequestsPerSecond 

func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64

func (*ScenarioResultSummary) GetLatency_50 

func (x *ScenarioResultSummary) GetLatency_50() float64

func (*ScenarioResultSummary) GetLatency_90 

func (x *ScenarioResultSummary) GetLatency_90() float64

func (*ScenarioResultSummary) GetLatency_95 

func (x *ScenarioResultSummary) GetLatency_95() float64

func (*ScenarioResultSummary) GetLatency_99 

func (x *ScenarioResultSummary) GetLatency_99() float64

func (*ScenarioResultSummary) GetLatency_999 

func (x *ScenarioResultSummary) GetLatency_999() float64

func (*ScenarioResultSummary) GetQps 

func (x *ScenarioResultSummary) GetQps() float64

func (*ScenarioResultSummary) GetQpsPerServerCore 

func (x *ScenarioResultSummary) GetQpsPerServerCore() float64

func (*ScenarioResultSummary) GetServerCpuUsage 

func (x *ScenarioResultSummary) GetServerCpuUsage() float64

func (*ScenarioResultSummary) GetServerPollsPerRequest 

func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64

func (*ScenarioResultSummary) GetServerQueriesPerCpuSec 

func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetServerSystemTime 

func (x *ScenarioResultSummary) GetServerSystemTime() float64

func (*ScenarioResultSummary) GetServerUserTime 

func (x *ScenarioResultSummary) GetServerUserTime() float64

func (*ScenarioResultSummary) GetStartTime 

func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp

func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond 

func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64

func (*ScenarioResultSummary) HasEndTime 

func (x *ScenarioResultSummary) HasEndTime() bool

func (*ScenarioResultSummary) HasStartTime 

func (x *ScenarioResultSummary) HasStartTime() bool

func (*ScenarioResultSummary) ProtoMessage 

func (*ScenarioResultSummary) ProtoMessage()

func (*ScenarioResultSummary) ProtoReflect 

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

func (*ScenarioResultSummary) Reset 

func (x *ScenarioResultSummary) Reset()

func (*ScenarioResultSummary) SetClientPollsPerRequest 

func (x *ScenarioResultSummary) SetClientPollsPerRequest(v float64)

func (*ScenarioResultSummary) SetClientQueriesPerCpuSec 

func (x *ScenarioResultSummary) SetClientQueriesPerCpuSec(v float64)

func (*ScenarioResultSummary) SetClientSystemTime 

func (x *ScenarioResultSummary) SetClientSystemTime(v float64)

func (*ScenarioResultSummary) SetClientUserTime 

func (x *ScenarioResultSummary) SetClientUserTime(v float64)

func (*ScenarioResultSummary) SetEndTime 

func (x *ScenarioResultSummary) SetEndTime(v *timestamppb.Timestamp)

func (*ScenarioResultSummary) SetFailedRequestsPerSecond 

func (x *ScenarioResultSummary) SetFailedRequestsPerSecond(v float64)

func (*ScenarioResultSummary) SetLatency_50 

func (x *ScenarioResultSummary) SetLatency_50(v float64)

func (*ScenarioResultSummary) SetLatency_90 

func (x *ScenarioResultSummary) SetLatency_90(v float64)

func (*ScenarioResultSummary) SetLatency_95 

func (x *ScenarioResultSummary) SetLatency_95(v float64)

func (*ScenarioResultSummary) SetLatency_99 

func (x *ScenarioResultSummary) SetLatency_99(v float64)

func (*ScenarioResultSummary) SetLatency_999 

func (x *ScenarioResultSummary) SetLatency_999(v float64)

func (*ScenarioResultSummary) SetQps 

func (x *ScenarioResultSummary) SetQps(v float64)

func (*ScenarioResultSummary) SetQpsPerServerCore 

func (x *ScenarioResultSummary) SetQpsPerServerCore(v float64)

func (*ScenarioResultSummary) SetServerCpuUsage 

func (x *ScenarioResultSummary) SetServerCpuUsage(v float64)

func (*ScenarioResultSummary) SetServerPollsPerRequest 

func (x *ScenarioResultSummary) SetServerPollsPerRequest(v float64)

func (*ScenarioResultSummary) SetServerQueriesPerCpuSec 

func (x *ScenarioResultSummary) SetServerQueriesPerCpuSec(v float64)

func (*ScenarioResultSummary) SetServerSystemTime 

func (x *ScenarioResultSummary) SetServerSystemTime(v float64)

func (*ScenarioResultSummary) SetServerUserTime 

func (x *ScenarioResultSummary) SetServerUserTime(v float64)

func (*ScenarioResultSummary) SetStartTime 

func (x *ScenarioResultSummary) SetStartTime(v *timestamppb.Timestamp)

func (*ScenarioResultSummary) SetSuccessfulRequestsPerSecond 

func (x *ScenarioResultSummary) SetSuccessfulRequestsPerSecond(v float64)

func (*ScenarioResultSummary) String 

func (x *ScenarioResultSummary) String() string

type ScenarioResultSummary_builder 

type ScenarioResultSummary_builder struct {

	// Total number of operations per second over all clients. What is counted as 1 'operation' depends on the benchmark scenarios:
	// For unary benchmarks, an operation is processing of a single unary RPC.
	// For streaming benchmarks, an operation is processing of a single ping pong of request and response.
	Qps float64
	// QPS per server core.
	QpsPerServerCore float64
	// The total server cpu load based on system time across all server processes, expressed as percentage of a single cpu core.
	// For example, 85 implies 85% of a cpu core, 125 implies 125% of a cpu core. Since we are accumulating the cpu load across all the server
	// processes, the value could > 100 when there are multiple servers or a single server using multiple threads and cores.
	// Same explanation for the total client cpu load below.
	ServerSystemTime float64
	// The total server cpu load based on user time across all server processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	ServerUserTime float64
	// The total client cpu load based on system time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	ClientSystemTime float64
	// The total client cpu load based on user time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
	ClientUserTime float64
	// X% latency percentiles (in nanoseconds)
	Latency_50  float64
	Latency_90  float64
	Latency_95  float64
	Latency_99  float64
	Latency_999 float64
	// server cpu usage percentage
	ServerCpuUsage float64
	// Number of requests that succeeded/failed
	SuccessfulRequestsPerSecond float64
	FailedRequestsPerSecond     float64
	// Number of polls called inside completion queue per request
	ClientPollsPerRequest float64
	ServerPollsPerRequest float64
	// Queries per CPU-sec over all servers or clients
	ServerQueriesPerCpuSec float64
	ClientQueriesPerCpuSec float64
	// Start and end time for the test scenario
	StartTime *timestamppb.Timestamp
	EndTime   *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (ScenarioResultSummary_builder) Build 

func (b0 ScenarioResultSummary_builder) Build() *ScenarioResultSummary

type ScenarioResult_builder 

type ScenarioResult_builder struct {

	// Inputs used to run the scenario.
	Scenario *Scenario
	// Histograms from all clients merged into one histogram.
	Latencies *HistogramData
	// Client stats for each client
	ClientStats []*ClientStats
	// Server stats for each server
	ServerStats []*ServerStats
	// Number of cores available to each server
	ServerCores []int32
	// An after-the-fact computed summary
	Summary *ScenarioResultSummary
	// Information on success or failure of each worker
	ClientSuccess []bool
	ServerSuccess []bool
	// Number of failed requests (one row per status code seen)
	RequestResults []*RequestResultCount
	// contains filtered or unexported fields
}

func (ScenarioResult_builder) Build 

func (b0 ScenarioResult_builder) Build() *ScenarioResult

type Scenario_builder 

type Scenario_builder struct {

	// Human readable name for this scenario
	Name string
	// Client configuration
	ClientConfig *ClientConfig
	// Number of clients to start for the test
	NumClients int32
	// Server configuration
	ServerConfig *ServerConfig
	// Number of servers to start for the test
	NumServers int32
	// Warmup period, in seconds
	WarmupSeconds int32
	// Benchmark time, in seconds
	BenchmarkSeconds int32
	// Number of workers to spawn locally (usually zero)
	SpawnLocalWorkerCount int32
	// contains filtered or unexported fields
}

func (Scenario_builder) Build 

func (b0 Scenario_builder) Build() *Scenario

type Scenarios 

type Scenarios struct {
	Scenarios []*Scenario `protobuf:"bytes,1,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
	// contains filtered or unexported fields
}

A set of scenarios to be run with qps_json_driver

func (*Scenarios) GetScenarios 

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

func (*Scenarios) ProtoMessage 

func (*Scenarios) ProtoMessage()

func (*Scenarios) ProtoReflect 

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

func (*Scenarios) Reset 

func (x *Scenarios) Reset()

func (*Scenarios) SetScenarios 

func (x *Scenarios) SetScenarios(v []*Scenario)

func (*Scenarios) String 

func (x *Scenarios) String() string

type Scenarios_builder 

type Scenarios_builder struct {
	Scenarios []*Scenario
	// contains filtered or unexported fields
}

func (Scenarios_builder) Build 

func (b0 Scenarios_builder) Build() *Scenarios

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"`
	// contains filtered or unexported fields
}

presence of SecurityParams implies use of TLS

func (*SecurityParams) GetCredType 

func (x *SecurityParams) GetCredType() string

func (*SecurityParams) GetServerHostOverride 

func (x *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa 

func (x *SecurityParams) GetUseTestCa() bool

func (*SecurityParams) ProtoMessage 

func (*SecurityParams) ProtoMessage()

func (*SecurityParams) ProtoReflect 

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

func (*SecurityParams) Reset 

func (x *SecurityParams) Reset()

func (*SecurityParams) SetCredType 

func (x *SecurityParams) SetCredType(v string)

func (*SecurityParams) SetServerHostOverride 

func (x *SecurityParams) SetServerHostOverride(v string)

func (*SecurityParams) SetUseTestCa 

func (x *SecurityParams) SetUseTestCa(v bool)

func (*SecurityParams) String 

func (x *SecurityParams) String() string

type SecurityParams_builder 

type SecurityParams_builder struct {
	UseTestCa          bool
	ServerHostOverride string
	CredType           string
	// contains filtered or unexported fields
}

func (SecurityParams_builder) Build 

func (b0 SecurityParams_builder) Build() *SecurityParams

type ServerArgs 

type ServerArgs struct {

	// Types that are valid to be assigned to Argtype:
	//
	//	*ServerArgs_Setup
	//	*ServerArgs_Mark
	Argtype isServerArgs_Argtype `protobuf_oneof:"argtype"`
	// contains filtered or unexported fields
}

func (*ServerArgs) ClearArgtype 

func (x *ServerArgs) ClearArgtype()

func (*ServerArgs) ClearMark 

func (x *ServerArgs) ClearMark()

func (*ServerArgs) ClearSetup 

func (x *ServerArgs) ClearSetup()

func (*ServerArgs) GetArgtype 

func (x *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark 

func (x *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup 

func (x *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) HasArgtype 

func (x *ServerArgs) HasArgtype() bool

func (*ServerArgs) HasMark 

func (x *ServerArgs) HasMark() bool

func (*ServerArgs) HasSetup 

func (x *ServerArgs) HasSetup() bool

func (*ServerArgs) ProtoMessage 

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) ProtoReflect 

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

func (*ServerArgs) Reset 

func (x *ServerArgs) Reset()

func (*ServerArgs) SetMark 

func (x *ServerArgs) SetMark(v *Mark)

func (*ServerArgs) SetSetup 

func (x *ServerArgs) SetSetup(v *ServerConfig)

func (*ServerArgs) String 

func (x *ServerArgs) String() string

func (*ServerArgs) WhichArgtype 

func (x *ServerArgs) WhichArgtype() case_ServerArgs_Argtype

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 ServerArgs_builder 

type ServerArgs_builder struct {

	// Fields of oneof Argtype:
	Setup *ServerConfig
	Mark  *Mark
	// contains filtered or unexported fields
}

func (ServerArgs_builder) Build 

func (b0 ServerArgs_builder) Build() *ServerArgs

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"`
	// Number of server processes. 0 indicates no restriction.
	ServerProcesses int32 `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerConfig) ClearPayloadConfig 

func (x *ServerConfig) ClearPayloadConfig()

func (*ServerConfig) ClearSecurityParams 

func (x *ServerConfig) ClearSecurityParams()

func (*ServerConfig) GetAsyncServerThreads 

func (x *ServerConfig) GetAsyncServerThreads() int32

func (*ServerConfig) GetChannelArgs 

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

func (*ServerConfig) GetCoreLimit 

func (x *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList 

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

func (*ServerConfig) GetOtherServerApi 

func (x *ServerConfig) GetOtherServerApi() string

func (*ServerConfig) GetPayloadConfig 

func (x *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort 

func (x *ServerConfig) GetPort() int32

func (*ServerConfig) GetResourceQuotaSize 

func (x *ServerConfig) GetResourceQuotaSize() int32

func (*ServerConfig) GetSecurityParams 

func (x *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerProcesses 

func (x *ServerConfig) GetServerProcesses() int32

func (*ServerConfig) GetServerType 

func (x *ServerConfig) GetServerType() ServerType

func (*ServerConfig) GetThreadsPerCq 

func (x *ServerConfig) GetThreadsPerCq() int32

func (*ServerConfig) HasPayloadConfig 

func (x *ServerConfig) HasPayloadConfig() bool

func (*ServerConfig) HasSecurityParams 

func (x *ServerConfig) HasSecurityParams() bool

func (*ServerConfig) ProtoMessage 

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) ProtoReflect 

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

func (*ServerConfig) Reset 

func (x *ServerConfig) Reset()

func (*ServerConfig) SetAsyncServerThreads 

func (x *ServerConfig) SetAsyncServerThreads(v int32)

func (*ServerConfig) SetChannelArgs 

func (x *ServerConfig) SetChannelArgs(v []*ChannelArg)

func (*ServerConfig) SetCoreLimit 

func (x *ServerConfig) SetCoreLimit(v int32)

func (*ServerConfig) SetCoreList 

func (x *ServerConfig) SetCoreList(v []int32)

func (*ServerConfig) SetOtherServerApi 

func (x *ServerConfig) SetOtherServerApi(v string)

func (*ServerConfig) SetPayloadConfig 

func (x *ServerConfig) SetPayloadConfig(v *PayloadConfig)

func (*ServerConfig) SetPort 

func (x *ServerConfig) SetPort(v int32)

func (*ServerConfig) SetResourceQuotaSize 

func (x *ServerConfig) SetResourceQuotaSize(v int32)

func (*ServerConfig) SetSecurityParams 

func (x *ServerConfig) SetSecurityParams(v *SecurityParams)

func (*ServerConfig) SetServerProcesses 

func (x *ServerConfig) SetServerProcesses(v int32)

func (*ServerConfig) SetServerType 

func (x *ServerConfig) SetServerType(v ServerType)

func (*ServerConfig) SetThreadsPerCq 

func (x *ServerConfig) SetThreadsPerCq(v int32)

func (*ServerConfig) String 

func (x *ServerConfig) String() string

type ServerConfig_builder 

type ServerConfig_builder struct {
	ServerType     ServerType
	SecurityParams *SecurityParams
	// Port on which to listen. Zero means pick unused port.
	Port int32
	// Only for async server. Number of threads used to serve the requests.
	AsyncServerThreads int32
	// Specify the number of cores to limit server to, if desired
	CoreLimit int32
	// 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
	// Specify the cores we should run the server on, if desired
	CoreList []int32
	// If we use an OTHER_SERVER client_type, this string gives more detail
	OtherServerApi string
	// Number of threads that share each completion queue
	ThreadsPerCq int32
	// Buffer pool size (no buffer pool specified if unset)
	ResourceQuotaSize int32
	ChannelArgs       []*ChannelArg
	// Number of server processes. 0 indicates no restriction.
	ServerProcesses int32
	// contains filtered or unexported fields
}

func (ServerConfig_builder) Build 

func (b0 ServerConfig_builder) Build() *ServerConfig

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"`
	// contains filtered or unexported fields
}

func (*ServerStats) ClearCoreStats 

func (x *ServerStats) ClearCoreStats()

func (*ServerStats) GetCoreStats 

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

func (*ServerStats) GetCqPollCount 

func (x *ServerStats) GetCqPollCount() uint64

func (*ServerStats) GetIdleCpuTime 

func (x *ServerStats) GetIdleCpuTime() uint64

func (*ServerStats) GetTimeElapsed 

func (x *ServerStats) GetTimeElapsed() float64

func (*ServerStats) GetTimeSystem 

func (x *ServerStats) GetTimeSystem() float64

func (*ServerStats) GetTimeUser 

func (x *ServerStats) GetTimeUser() float64

func (*ServerStats) GetTotalCpuTime 

func (x *ServerStats) GetTotalCpuTime() uint64

func (*ServerStats) HasCoreStats 

func (x *ServerStats) HasCoreStats() bool

func (*ServerStats) ProtoMessage 

func (*ServerStats) ProtoMessage()

func (*ServerStats) ProtoReflect 

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

func (*ServerStats) Reset 

func (x *ServerStats) Reset()

func (*ServerStats) SetCoreStats 

func (x *ServerStats) SetCoreStats(v *core.Stats)

func (*ServerStats) SetCqPollCount 

func (x *ServerStats) SetCqPollCount(v uint64)

func (*ServerStats) SetIdleCpuTime 

func (x *ServerStats) SetIdleCpuTime(v uint64)

func (*ServerStats) SetTimeElapsed 

func (x *ServerStats) SetTimeElapsed(v float64)

func (*ServerStats) SetTimeSystem 

func (x *ServerStats) SetTimeSystem(v float64)

func (*ServerStats) SetTimeUser 

func (x *ServerStats) SetTimeUser(v float64)

func (*ServerStats) SetTotalCpuTime 

func (x *ServerStats) SetTotalCpuTime(v uint64)

func (*ServerStats) String 

func (x *ServerStats) String() string

type ServerStats_builder 

type ServerStats_builder struct {

	// wall clock time change in seconds since last reset
	TimeElapsed float64
	// change in user time (in seconds) used by the server since last reset
	TimeUser float64
	// change in server time (in seconds) used by the server process and all
	// threads since last reset
	TimeSystem float64
	// change in total cpu time of the server (data from proc/stat)
	TotalCpuTime uint64
	// change in idle time of the server (data from proc/stat)
	IdleCpuTime uint64
	// Number of polls called inside completion queue
	CqPollCount uint64
	// Core library stats
	CoreStats *core.Stats
	// contains filtered or unexported fields
}

func (ServerStats_builder) Build 

func (b0 ServerStats_builder) Build() *ServerStats

type ServerStatus 

type ServerStatus struct {
	Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// the port bound by the server
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Number of cores available to the server
	Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStatus) ClearStats 

func (x *ServerStatus) ClearStats()

func (*ServerStatus) GetCores 

func (x *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort 

func (x *ServerStatus) GetPort() int32

func (*ServerStatus) GetStats 

func (x *ServerStatus) GetStats() *ServerStats

func (*ServerStatus) HasStats 

func (x *ServerStatus) HasStats() bool

func (*ServerStatus) ProtoMessage 

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) ProtoReflect 

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

func (*ServerStatus) Reset 

func (x *ServerStatus) Reset()

func (*ServerStatus) SetCores 

func (x *ServerStatus) SetCores(v int32)

func (*ServerStatus) SetPort 

func (x *ServerStatus) SetPort(v int32)

func (*ServerStatus) SetStats 

func (x *ServerStatus) SetStats(v *ServerStats)

func (*ServerStatus) String 

func (x *ServerStatus) String() string

type ServerStatus_builder 

type ServerStatus_builder struct {
	Stats *ServerStats
	// the port bound by the server
	Port int32
	// Number of cores available to the server
	Cores int32
	// contains filtered or unexported fields
}

func (ServerStatus_builder) Build 

func (b0 ServerStatus_builder) Build() *ServerStatus

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 // used for some language-specific variants
	ServerType_CALLBACK_SERVER      ServerType = 4
)

func (ServerType) Descriptor 

func (ServerType) Descriptor() protoreflect.EnumDescriptor

func (ServerType) Enum 

func (x ServerType) Enum() *ServerType

func (ServerType) Number 

func (x ServerType) Number() protoreflect.EnumNumber

func (ServerType) String 

func (x ServerType) String() string

func (ServerType) Type 

func (ServerType) Type() protoreflect.EnumType

type SetReturnStatusRequest 

type SetReturnStatusRequest struct {
	GrpcCodeToReturn      int32  `protobuf:"varint,1,opt,name=grpc_code_to_return,json=grpcCodeToReturn,proto3" json:"grpc_code_to_return,omitempty"`
	GrpcStatusDescription string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Status that will be return to callers of the Hook method

func (*SetReturnStatusRequest) GetGrpcCodeToReturn 

func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32

func (*SetReturnStatusRequest) GetGrpcStatusDescription 

func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string

func (*SetReturnStatusRequest) ProtoMessage 

func (*SetReturnStatusRequest) ProtoMessage()

func (*SetReturnStatusRequest) ProtoReflect 

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

func (*SetReturnStatusRequest) Reset 

func (x *SetReturnStatusRequest) Reset()

func (*SetReturnStatusRequest) SetGrpcCodeToReturn 

func (x *SetReturnStatusRequest) SetGrpcCodeToReturn(v int32)

func (*SetReturnStatusRequest) SetGrpcStatusDescription 

func (x *SetReturnStatusRequest) SetGrpcStatusDescription(v string)

func (*SetReturnStatusRequest) String 

func (x *SetReturnStatusRequest) String() string

type SetReturnStatusRequest_builder 

type SetReturnStatusRequest_builder struct {
	GrpcCodeToReturn      int32
	GrpcStatusDescription string
	// contains filtered or unexported fields
}

func (SetReturnStatusRequest_builder) Build 

func (b0 SetReturnStatusRequest_builder) Build() *SetReturnStatusRequest

type SimpleProtoParams 

type SimpleProtoParams struct {
	ReqSize  int32 `protobuf:"varint,1,opt,name=req_size,json=reqSize,proto3" json:"req_size,omitempty"`
	RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleProtoParams) GetReqSize 

func (x *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize 

func (x *SimpleProtoParams) GetRespSize() int32

func (*SimpleProtoParams) ProtoMessage 

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams) ProtoReflect 

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

func (*SimpleProtoParams) Reset 

func (x *SimpleProtoParams) Reset()

func (*SimpleProtoParams) SetReqSize 

func (x *SimpleProtoParams) SetReqSize(v int32)

func (*SimpleProtoParams) SetRespSize 

func (x *SimpleProtoParams) SetRespSize(v int32)

func (*SimpleProtoParams) String 

func (x *SimpleProtoParams) String() string

type SimpleProtoParams_builder 

type SimpleProtoParams_builder struct {
	ReqSize  int32
	RespSize int32
	// contains filtered or unexported fields
}

func (SimpleProtoParams_builder) Build 

func (b0 SimpleProtoParams_builder) Build() *SimpleProtoParams

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"`
	// If set the server should record this metrics report data for the current RPC.
	OrcaPerQueryReport *TestOrcaReport `protobuf:"bytes,11,opt,name=orca_per_query_report,json=orcaPerQueryReport,proto3" json:"orca_per_query_report,omitempty"`
	// contains filtered or unexported fields
}

Unary request.

func (*SimpleRequest) ClearExpectCompressed 

func (x *SimpleRequest) ClearExpectCompressed()

func (*SimpleRequest) ClearOrcaPerQueryReport 

func (x *SimpleRequest) ClearOrcaPerQueryReport()

func (*SimpleRequest) ClearPayload 

func (x *SimpleRequest) ClearPayload()

func (*SimpleRequest) ClearResponseCompressed 

func (x *SimpleRequest) ClearResponseCompressed()

func (*SimpleRequest) ClearResponseStatus 

func (x *SimpleRequest) ClearResponseStatus()

func (*SimpleRequest) GetExpectCompressed 

func (x *SimpleRequest) GetExpectCompressed() *BoolValue

func (*SimpleRequest) GetFillGrpclbRouteType 

func (x *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope 

func (x *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId 

func (x *SimpleRequest) GetFillServerId() bool

func (*SimpleRequest) GetFillUsername 

func (x *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetOrcaPerQueryReport 

func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport

func (*SimpleRequest) GetPayload 

func (x *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompressed 

func (x *SimpleRequest) GetResponseCompressed() *BoolValue

func (*SimpleRequest) GetResponseSize 

func (x *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus 

func (x *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType 

func (x *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) HasExpectCompressed 

func (x *SimpleRequest) HasExpectCompressed() bool

func (*SimpleRequest) HasOrcaPerQueryReport 

func (x *SimpleRequest) HasOrcaPerQueryReport() bool

func (*SimpleRequest) HasPayload 

func (x *SimpleRequest) HasPayload() bool

func (*SimpleRequest) HasResponseCompressed 

func (x *SimpleRequest) HasResponseCompressed() bool

func (*SimpleRequest) HasResponseStatus 

func (x *SimpleRequest) HasResponseStatus() bool

func (*SimpleRequest) ProtoMessage 

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect 

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

func (*SimpleRequest) Reset 

func (x *SimpleRequest) Reset()

func (*SimpleRequest) SetExpectCompressed 

func (x *SimpleRequest) SetExpectCompressed(v *BoolValue)

func (*SimpleRequest) SetFillGrpclbRouteType 

func (x *SimpleRequest) SetFillGrpclbRouteType(v bool)

func (*SimpleRequest) SetFillOauthScope 

func (x *SimpleRequest) SetFillOauthScope(v bool)

func (*SimpleRequest) SetFillServerId 

func (x *SimpleRequest) SetFillServerId(v bool)

func (*SimpleRequest) SetFillUsername 

func (x *SimpleRequest) SetFillUsername(v bool)

func (*SimpleRequest) SetOrcaPerQueryReport 

func (x *SimpleRequest) SetOrcaPerQueryReport(v *TestOrcaReport)

func (*SimpleRequest) SetPayload 

func (x *SimpleRequest) SetPayload(v *Payload)

func (*SimpleRequest) SetResponseCompressed 

func (x *SimpleRequest) SetResponseCompressed(v *BoolValue)

func (*SimpleRequest) SetResponseSize 

func (x *SimpleRequest) SetResponseSize(v int32)

func (*SimpleRequest) SetResponseStatus 

func (x *SimpleRequest) SetResponseStatus(v *EchoStatus)

func (*SimpleRequest) SetResponseType 

func (x *SimpleRequest) SetResponseType(v PayloadType)

func (*SimpleRequest) String 

func (x *SimpleRequest) String() string

type SimpleRequest_builder 

type SimpleRequest_builder struct {

	// Desired payload type in the response from the server.
	// If response_type is RANDOM, server randomly chooses one from other formats.
	ResponseType PayloadType
	// Desired payload size in the response from the server.
	ResponseSize int32
	// Optional input payload sent along with the request.
	Payload *Payload
	// Whether SimpleResponse should include username.
	FillUsername bool
	// Whether SimpleResponse should include OAuth scope.
	FillOauthScope bool
	// 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
	// Whether server should return a given status
	ResponseStatus *EchoStatus
	// Whether the server should expect this request to be compressed.
	ExpectCompressed *BoolValue
	// Whether SimpleResponse should include server_id.
	FillServerId bool
	// Whether SimpleResponse should include grpclb_route_type.
	FillGrpclbRouteType bool
	// If set the server should record this metrics report data for the current RPC.
	OrcaPerQueryReport *TestOrcaReport
	// contains filtered or unexported fields
}

func (SimpleRequest_builder) Build 

func (b0 SimpleRequest_builder) Build() *SimpleRequest

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 */
	// Server hostname.
	Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

Unary response, as configured by the request.

func (*SimpleResponse) ClearPayload 

func (x *SimpleResponse) ClearPayload()

func (*SimpleResponse) GetGrpclbRouteType 

func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetHostname 

func (x *SimpleResponse) GetHostname() string

func (*SimpleResponse) GetOauthScope 

func (x *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload 

func (x *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId 

func (x *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername 

func (x *SimpleResponse) GetUsername() string

func (*SimpleResponse) HasPayload 

func (x *SimpleResponse) HasPayload() bool

func (*SimpleResponse) ProtoMessage 

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect 

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

func (*SimpleResponse) Reset 

func (x *SimpleResponse) Reset()

func (*SimpleResponse) SetGrpclbRouteType 

func (x *SimpleResponse) SetGrpclbRouteType(v GrpclbRouteType)

func (*SimpleResponse) SetHostname 

func (x *SimpleResponse) SetHostname(v string)

func (*SimpleResponse) SetOauthScope 

func (x *SimpleResponse) SetOauthScope(v string)

func (*SimpleResponse) SetPayload 

func (x *SimpleResponse) SetPayload(v *Payload)

func (*SimpleResponse) SetServerId 

func (x *SimpleResponse) SetServerId(v string)

func (*SimpleResponse) SetUsername 

func (x *SimpleResponse) SetUsername(v string)

func (*SimpleResponse) String 

func (x *SimpleResponse) String() string

type SimpleResponse_builder 

type SimpleResponse_builder struct {

	// Payload to increase message size.
	Payload *Payload
	// The user the request came from, for verifying authentication was
	// successful when the client expected it.
	Username string
	// OAuth scope.
	OauthScope string
	// 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
	// gRPCLB Path.
	GrpclbRouteType GrpclbRouteType
	// Server hostname.
	Hostname string
	// contains filtered or unexported fields
}

func (SimpleResponse_builder) Build 

func (b0 SimpleResponse_builder) Build() *SimpleResponse

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"`
	// contains filtered or unexported fields
}

Client-streaming request.

func (*StreamingInputCallRequest) ClearExpectCompressed 

func (x *StreamingInputCallRequest) ClearExpectCompressed()

func (*StreamingInputCallRequest) ClearPayload 

func (x *StreamingInputCallRequest) ClearPayload()

func (*StreamingInputCallRequest) GetExpectCompressed 

func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

func (*StreamingInputCallRequest) GetPayload 

func (x *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) HasExpectCompressed 

func (x *StreamingInputCallRequest) HasExpectCompressed() bool

func (*StreamingInputCallRequest) HasPayload 

func (x *StreamingInputCallRequest) HasPayload() bool

func (*StreamingInputCallRequest) ProtoMessage 

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) ProtoReflect 

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

func (*StreamingInputCallRequest) Reset 

func (x *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) SetExpectCompressed 

func (x *StreamingInputCallRequest) SetExpectCompressed(v *BoolValue)

func (*StreamingInputCallRequest) SetPayload 

func (x *StreamingInputCallRequest) SetPayload(v *Payload)

func (*StreamingInputCallRequest) String 

func (x *StreamingInputCallRequest) String() string

type StreamingInputCallRequest_builder 

type StreamingInputCallRequest_builder struct {

	// Optional input payload sent along with the request.
	Payload *Payload
	// 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
	// contains filtered or unexported fields
}

func (StreamingInputCallRequest_builder) Build 

func (b0 StreamingInputCallRequest_builder) Build() *StreamingInputCallRequest

type StreamingInputCallResponse 

type StreamingInputCallResponse struct {

	// Aggregated size of payloads received from the client.
	AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Client-streaming response.

func (*StreamingInputCallResponse) GetAggregatedPayloadSize 

func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage 

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) ProtoReflect 

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

func (*StreamingInputCallResponse) Reset 

func (x *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) SetAggregatedPayloadSize 

func (x *StreamingInputCallResponse) SetAggregatedPayloadSize(v int32)

func (*StreamingInputCallResponse) String 

func (x *StreamingInputCallResponse) String() string

type StreamingInputCallResponse_builder 

type StreamingInputCallResponse_builder struct {

	// Aggregated size of payloads received from the client.
	AggregatedPayloadSize int32
	// contains filtered or unexported fields
}

func (StreamingInputCallResponse_builder) Build 

func (b0 StreamingInputCallResponse_builder) Build() *StreamingInputCallResponse

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"`
	// If set the server should update this metrics report data at the OOB server.
	OrcaOobReport *TestOrcaReport `protobuf:"bytes,8,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"`
	// contains filtered or unexported fields
}

Server-streaming request.

func (*StreamingOutputCallRequest) ClearOrcaOobReport 

func (x *StreamingOutputCallRequest) ClearOrcaOobReport()

func (*StreamingOutputCallRequest) ClearPayload 

func (x *StreamingOutputCallRequest) ClearPayload()

func (*StreamingOutputCallRequest) ClearResponseStatus 

func (x *StreamingOutputCallRequest) ClearResponseStatus()

func (*StreamingOutputCallRequest) GetOrcaOobReport 

func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport

func (*StreamingOutputCallRequest) GetPayload 

func (x *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseParameters 

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

func (*StreamingOutputCallRequest) GetResponseStatus 

func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType 

func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) HasOrcaOobReport 

func (x *StreamingOutputCallRequest) HasOrcaOobReport() bool

func (*StreamingOutputCallRequest) HasPayload 

func (x *StreamingOutputCallRequest) HasPayload() bool

func (*StreamingOutputCallRequest) HasResponseStatus 

func (x *StreamingOutputCallRequest) HasResponseStatus() bool

func (*StreamingOutputCallRequest) ProtoMessage 

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) ProtoReflect 

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

func (*StreamingOutputCallRequest) Reset 

func (x *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) SetOrcaOobReport 

func (x *StreamingOutputCallRequest) SetOrcaOobReport(v *TestOrcaReport)

func (*StreamingOutputCallRequest) SetPayload 

func (x *StreamingOutputCallRequest) SetPayload(v *Payload)

func (*StreamingOutputCallRequest) SetResponseParameters 

func (x *StreamingOutputCallRequest) SetResponseParameters(v []*ResponseParameters)

func (*StreamingOutputCallRequest) SetResponseStatus 

func (x *StreamingOutputCallRequest) SetResponseStatus(v *EchoStatus)

func (*StreamingOutputCallRequest) SetResponseType 

func (x *StreamingOutputCallRequest) SetResponseType(v PayloadType)

func (*StreamingOutputCallRequest) String 

func (x *StreamingOutputCallRequest) String() string

type StreamingOutputCallRequest_builder 

type StreamingOutputCallRequest_builder 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
	// Configuration for each expected response message.
	ResponseParameters []*ResponseParameters
	// Optional input payload sent along with the request.
	Payload *Payload
	// Whether server should return a given status
	ResponseStatus *EchoStatus
	// If set the server should update this metrics report data at the OOB server.
	OrcaOobReport *TestOrcaReport
	// contains filtered or unexported fields
}

func (StreamingOutputCallRequest_builder) Build 

func (b0 StreamingOutputCallRequest_builder) Build() *StreamingOutputCallRequest

type StreamingOutputCallResponse 

type StreamingOutputCallResponse struct {

	// Payload to increase response size.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

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

func (*StreamingOutputCallResponse) ClearPayload 

func (x *StreamingOutputCallResponse) ClearPayload()

func (*StreamingOutputCallResponse) GetPayload 

func (x *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) HasPayload 

func (x *StreamingOutputCallResponse) HasPayload() bool

func (*StreamingOutputCallResponse) ProtoMessage 

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) ProtoReflect 

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

func (*StreamingOutputCallResponse) Reset 

func (x *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) SetPayload 

func (x *StreamingOutputCallResponse) SetPayload(v *Payload)

func (*StreamingOutputCallResponse) String 

func (x *StreamingOutputCallResponse) String() string

type StreamingOutputCallResponse_builder 

type StreamingOutputCallResponse_builder struct {

	// Payload to increase response size.
	Payload *Payload
	// contains filtered or unexported fields
}

func (StreamingOutputCallResponse_builder) Build 

func (b0 StreamingOutputCallResponse_builder) Build() *StreamingOutputCallResponse

type TestOrcaReport 

type TestOrcaReport struct {
	CpuUtilization    float64            `protobuf:"fixed64,1,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"`
	MemoryUtilization float64            `protobuf:"fixed64,2,opt,name=memory_utilization,json=memoryUtilization,proto3" json:"memory_utilization,omitempty"`
	RequestCost       map[string]float64 `` /* 170-byte string literal not displayed */
	Utilization       map[string]float64 `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metrics data the server will update and send to the client. It mirrors orca load report https://github.com/cncf/xds/blob/eded343319d09f30032952beda9840bbd3dcf7ac/xds/data/orca/v3/orca_load_report.proto#L15, but avoids orca dependency. Used by both per-query and out-of-band reporting tests.

func (*TestOrcaReport) GetCpuUtilization 

func (x *TestOrcaReport) GetCpuUtilization() float64

func (*TestOrcaReport) GetMemoryUtilization 

func (x *TestOrcaReport) GetMemoryUtilization() float64

func (*TestOrcaReport) GetRequestCost 

func (x *TestOrcaReport) GetRequestCost() map[string]float64

func (*TestOrcaReport) GetUtilization 

func (x *TestOrcaReport) GetUtilization() map[string]float64

func (*TestOrcaReport) ProtoMessage 

func (*TestOrcaReport) ProtoMessage()

func (*TestOrcaReport) ProtoReflect 

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

func (*TestOrcaReport) Reset 

func (x *TestOrcaReport) Reset()

func (*TestOrcaReport) SetCpuUtilization 

func (x *TestOrcaReport) SetCpuUtilization(v float64)

func (*TestOrcaReport) SetMemoryUtilization 

func (x *TestOrcaReport) SetMemoryUtilization(v float64)

func (*TestOrcaReport) SetRequestCost 

func (x *TestOrcaReport) SetRequestCost(v map[string]float64)

func (*TestOrcaReport) SetUtilization 

func (x *TestOrcaReport) SetUtilization(v map[string]float64)

func (*TestOrcaReport) String 

func (x *TestOrcaReport) String() string

type TestOrcaReport_builder 

type TestOrcaReport_builder struct {
	CpuUtilization    float64
	MemoryUtilization float64
	RequestCost       map[string]float64
	Utilization       map[string]float64
	// contains filtered or unexported fields
}

func (TestOrcaReport_builder) Build 

func (b0 TestOrcaReport_builder) Build() *TestOrcaReport

type Void 

type Void struct {
	// contains filtered or unexported fields
}

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect 

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

func (*Void) Reset 

func (x *Void) Reset()

func (*Void) String 

func (x *Void) String() string

type Void_builder 

type Void_builder struct {
	// contains filtered or unexported fields
}

func (Void_builder) Build 

func (b0 Void_builder) Build() *Void

Source Files

  • benchmark_service.pb.go
  • control.pb.go
  • empty.pb.go
  • messages.pb.go
  • payloads.pb.go
  • report_qps_scenario_service.pb.go
  • stats.pb.go
  • test.pb.go
  • worker_service.pb.go

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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