testing

package
v1.31.0-20230814203313... 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

This section is empty.

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 (
	HookRequestCommand_name = map[int32]string{
		0: "START",
		1: "STOP",
		2: "RETURN",
	}
	HookRequestCommand_value = map[string]int32{
		"START":  0,
		"STOP":   1,
		"RETURN": 2,
	}
)

Enum value maps for HookRequestCommand.

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 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 {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolValue) Descriptor deprecated

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

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

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

func (x *BoolValue) String() string

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

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

Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.

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

func (x *ByteBufferParams) String() string

type ChannelArg

type ChannelArg struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Value:
	//
	//	*ChannelArg_StrValue
	//	*ChannelArg_IntValue
	Value isChannelArg_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*ChannelArg) Descriptor deprecated

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

Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.

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 (m *ChannelArg) GetValue() isChannelArg_Value

func (*ChannelArg) ProtoMessage

func (*ChannelArg) ProtoMessage()

func (*ChannelArg) ProtoReflect

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

func (*ChannelArg) Reset

func (x *ChannelArg) Reset()

func (*ChannelArg) String

func (x *ChannelArg) String() string

type ChannelArg_IntValue

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

type ChannelArg_StrValue

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

type ClientArgs

type ClientArgs struct {

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

func (*ClientArgs) Descriptor deprecated

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

Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.

func (*ClientArgs) GetArgtype

func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark

func (x *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup

func (x *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) ProtoMessage

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) ProtoReflect

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

func (*ClientArgs) Reset

func (x *ClientArgs) Reset()

func (*ClientArgs) String

func (x *ClientArgs) String() string

type ClientArgs_Mark

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

type ClientArgs_Setup

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

type ClientConfig

type ClientConfig struct {
	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"`
	OutstandingRpcsPerChannel             int32            `` /* 141-byte string literal not displayed */
	ClientChannels                        int32            `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`
	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"`
	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"`
	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"`
	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"`
	ThreadsPerCq                          int32            `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
	MessagesPerStream                     int32            `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"`
	UseCoalesceApi                        bool             `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,omitempty"`
	MedianLatencyCollectionIntervalMillis int32            `` /* 180-byte string literal not displayed */
	ClientProcesses                       int32            `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientConfig) Descriptor deprecated

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

Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

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

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) ProtoReflect

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

func (*ClientConfig) Reset

func (x *ClientConfig) Reset()

func (*ClientConfig) String

func (x *ClientConfig) String() string

type ClientConfigureRequest

type ClientConfigureRequest struct {
	Types      []ClientConfigureRequest_RpcType   `protobuf:"varint,1,rep,packed,name=types,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"types,omitempty"`
	Metadata   []*ClientConfigureRequest_Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	TimeoutSec int32                              `protobuf:"varint,3,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientConfigureRequest) Descriptor deprecated

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

Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest) GetMetadata

func (*ClientConfigureRequest) GetTimeoutSec

func (x *ClientConfigureRequest) GetTimeoutSec() int32

func (*ClientConfigureRequest) GetTypes

func (*ClientConfigureRequest) ProtoMessage

func (*ClientConfigureRequest) ProtoMessage()

func (*ClientConfigureRequest) ProtoReflect

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

func (*ClientConfigureRequest) Reset

func (x *ClientConfigureRequest) Reset()

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
}

func (*ClientConfigureRequest_Metadata) Descriptor deprecated

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

Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest_Metadata) GetKey

func (*ClientConfigureRequest_Metadata) GetType

func (*ClientConfigureRequest_Metadata) GetValue

func (*ClientConfigureRequest_Metadata) ProtoMessage

func (*ClientConfigureRequest_Metadata) ProtoMessage()

func (*ClientConfigureRequest_Metadata) ProtoReflect

func (*ClientConfigureRequest_Metadata) Reset

func (*ClientConfigureRequest_Metadata) String

type ClientConfigureRequest_RpcType

type ClientConfigureRequest_RpcType int32
const (
	ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0
	ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1
)

func (ClientConfigureRequest_RpcType) Descriptor

func (ClientConfigureRequest_RpcType) Enum

func (ClientConfigureRequest_RpcType) EnumDescriptor deprecated

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

Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.

func (ClientConfigureRequest_RpcType) Number

func (ClientConfigureRequest_RpcType) String

func (ClientConfigureRequest_RpcType) Type

type ClientConfigureResponse

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

func (*ClientConfigureResponse) Descriptor deprecated

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

Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.

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 ClientStats

type ClientStats struct {
	Latencies      *HistogramData        `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"`
	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"`
	RequestResults []*RequestResultCount `protobuf:"bytes,5,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
	CqPollCount    uint64                `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
	CoreStats      *core.Stats           `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientStats) Descriptor deprecated

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

Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.

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

func (*ClientStats) ProtoMessage()

func (*ClientStats) ProtoReflect

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

func (*ClientStats) Reset

func (x *ClientStats) Reset()

func (*ClientStats) String

func (x *ClientStats) String() string

type ClientStatus

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

func (*ClientStatus) Descriptor deprecated

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

Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.

func (*ClientStatus) GetStats

func (x *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) ProtoMessage

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) ProtoReflect

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

func (*ClientStatus) Reset

func (x *ClientStatus) Reset()

func (*ClientStatus) String

func (x *ClientStatus) String() string

type ClientType

type ClientType int32
const (
	ClientType_SYNC_CLIENT     ClientType = 0
	ClientType_ASYNC_CLIENT    ClientType = 1
	ClientType_OTHER_CLIENT    ClientType = 2
	ClientType_CALLBACK_CLIENT ClientType = 3
)

func (ClientType) Descriptor

func (ClientType) Descriptor() protoreflect.EnumDescriptor

func (ClientType) Enum

func (x ClientType) Enum() *ClientType

func (ClientType) EnumDescriptor deprecated

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

Deprecated: Use ClientType.Descriptor instead.

func (ClientType) Number

func (x ClientType) Number() protoreflect.EnumNumber

func (ClientType) String

func (x ClientType) String() string

func (ClientType) Type

type ClosedLoopParams

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

func (*ClosedLoopParams) Descriptor deprecated

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

Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.

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 ComplexProtoParams

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

func (*ComplexProtoParams) Descriptor deprecated

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

Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.

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 CoreRequest

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

func (*CoreRequest) Descriptor deprecated

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

Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.

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 CoreResponse

type CoreResponse struct {
	Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
	// contains filtered or unexported fields
}

func (*CoreResponse) Descriptor deprecated

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

Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.

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

func (x *CoreResponse) String() string

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
}

func (*EchoStatus) Descriptor deprecated

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

Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

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

func (x *EchoStatus) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

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 GrpclbRouteType

type GrpclbRouteType int32
const (
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN  GrpclbRouteType = 0
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1
	GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND  GrpclbRouteType = 2
)

func (GrpclbRouteType) Descriptor

func (GrpclbRouteType) Enum

func (x GrpclbRouteType) Enum() *GrpclbRouteType

func (GrpclbRouteType) EnumDescriptor deprecated

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

Deprecated: Use GrpclbRouteType.Descriptor instead.

func (GrpclbRouteType) Number

func (GrpclbRouteType) String

func (x GrpclbRouteType) String() string

func (GrpclbRouteType) Type

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
}

func (*HistogramData) Descriptor deprecated

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

Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.

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

func (x *HistogramData) String() string

type HistogramParams

type HistogramParams struct {
	Resolution  float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`
	MaxPossible float64 `protobuf:"fixed64,2,opt,name=max_possible,json=maxPossible,proto3" json:"max_possible,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramParams) Descriptor deprecated

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

Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.

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

func (x *HistogramParams) String() string

type HookRequest

type HookRequest struct {
	Command               HookRequestCommand `protobuf:"varint,1,opt,name=command,proto3,enum=grpc.testing.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 */
	ServerPort            int32              `protobuf:"varint,4,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	// contains filtered or unexported fields
}

func (*HookRequest) Descriptor deprecated

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

Deprecated: Use HookRequest.ProtoReflect.Descriptor instead.

func (*HookRequest) GetCommand

func (x *HookRequest) GetCommand() 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) String

func (x *HookRequest) String() string

type HookRequestCommand

type HookRequestCommand int32
const (
	HookRequestCommand_START  HookRequestCommand = 0
	HookRequestCommand_STOP   HookRequestCommand = 1
	HookRequestCommand_RETURN HookRequestCommand = 2
)

func (HookRequestCommand) Descriptor

func (HookRequestCommand) Enum

func (HookRequestCommand) EnumDescriptor deprecated

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

Deprecated: Use HookRequestCommand.Descriptor instead.

func (HookRequestCommand) Number

func (HookRequestCommand) String

func (x HookRequestCommand) String() string

func (HookRequestCommand) Type

type HookResponse

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

func (*HookResponse) Descriptor deprecated

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

Deprecated: Use HookResponse.ProtoReflect.Descriptor instead.

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 LoadBalancerAccumulatedStatsRequest

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

func (*LoadBalancerAccumulatedStatsRequest) Descriptor deprecated

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

Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()

func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect

func (*LoadBalancerAccumulatedStatsRequest) Reset

func (*LoadBalancerAccumulatedStatsRequest) String

type LoadBalancerAccumulatedStatsResponse

type LoadBalancerAccumulatedStatsResponse struct {

	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsStartedByMethod map[string]int32 `` /* 222-byte string literal not displayed */
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsSucceededByMethod map[string]int32 `` /* 228-byte string literal not displayed */
	// Deprecated: Marked as deprecated in grpc/testing/messages.proto.
	NumRpcsFailedByMethod map[string]int32                                             `` /* 219-byte string literal not displayed */
	StatsPerMethod        map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerAccumulatedStatsResponse) Descriptor deprecated

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

Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.

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 (*LoadBalancerAccumulatedStatsResponse) ProtoMessage

func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()

func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect

func (*LoadBalancerAccumulatedStatsResponse) Reset

func (*LoadBalancerAccumulatedStatsResponse) String

type LoadBalancerAccumulatedStatsResponse_MethodStats

type LoadBalancerAccumulatedStatsResponse_MethodStats struct {
	RpcsStarted int32           `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"`
	Result      map[int32]int32 `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor deprecated

Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String

type LoadBalancerStatsRequest

type LoadBalancerStatsRequest struct {
	NumRpcs      int32    `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"`
	TimeoutSec   int32    `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
	MetadataKeys []string `protobuf:"bytes,3,rep,name=metadata_keys,json=metadataKeys,proto3" json:"metadata_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsRequest) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

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

func (x *LoadBalancerStatsRequest) String() string

type LoadBalancerStatsResponse

type LoadBalancerStatsResponse struct {
	RpcsByPeer      map[string]int32                                     `` /* 182-byte string literal not displayed */
	NumFailures     int32                                                `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
	RpcsByMethod    map[string]*LoadBalancerStatsResponse_RpcsByPeer     `` /* 187-byte string literal not displayed */
	MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse) GetMetadatasByPeer

func (*LoadBalancerStatsResponse) GetNumFailures

func (x *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod

func (*LoadBalancerStatsResponse) GetRpcsByPeer

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

func (*LoadBalancerStatsResponse) ProtoMessage

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) ProtoReflect

func (*LoadBalancerStatsResponse) Reset

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) String

func (x *LoadBalancerStatsResponse) String() string

type LoadBalancerStatsResponse_MetadataByPeer

type LoadBalancerStatsResponse_MetadataByPeer struct {
	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) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsResponse_MetadataByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata

func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage

func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect

func (*LoadBalancerStatsResponse_MetadataByPeer) Reset

func (*LoadBalancerStatsResponse_MetadataByPeer) String

type LoadBalancerStatsResponse_MetadataEntry

type LoadBalancerStatsResponse_MetadataEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsResponse_MetadataEntry.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_MetadataEntry) GetKey

func (*LoadBalancerStatsResponse_MetadataEntry) GetValue

func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage

func (*LoadBalancerStatsResponse_MetadataEntry) ProtoReflect

func (*LoadBalancerStatsResponse_MetadataEntry) Reset

func (*LoadBalancerStatsResponse_MetadataEntry) String

type LoadBalancerStatsResponse_RpcMetadata

type LoadBalancerStatsResponse_RpcMetadata struct {
	Metadata []*LoadBalancerStatsResponse_MetadataEntry `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsResponse_RpcMetadata.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcMetadata) GetMetadata

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcMetadata) ProtoReflect

func (*LoadBalancerStatsResponse_RpcMetadata) Reset

func (*LoadBalancerStatsResponse_RpcMetadata) String

type LoadBalancerStatsResponse_RpcsByPeer

type LoadBalancerStatsResponse_RpcsByPeer struct {
	RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor deprecated

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

Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

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 (*LoadBalancerStatsResponse_RpcsByPeer) Reset

func (*LoadBalancerStatsResponse_RpcsByPeer) String

type LoadParams

type LoadParams struct {

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

func (*LoadParams) Descriptor deprecated

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

Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.

func (*LoadParams) GetClosedLoop

func (x *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams) GetLoad

func (m *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPoisson

func (x *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) ProtoMessage

func (*LoadParams) ProtoMessage()

func (*LoadParams) ProtoReflect

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

func (*LoadParams) Reset

func (x *LoadParams) Reset()

func (*LoadParams) String

func (x *LoadParams) String() string

type LoadParams_ClosedLoop

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

type LoadParams_Poisson

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

type Mark

type Mark struct {
	Reset_ bool `protobuf:"varint,1,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*Mark) Descriptor deprecated

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

Deprecated: Use Mark.ProtoReflect.Descriptor instead.

func (*Mark) GetReset_

func (x *Mark) GetReset_() bool

func (*Mark) ProtoMessage

func (*Mark) ProtoMessage()

func (*Mark) ProtoReflect

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

func (*Mark) Reset

func (x *Mark) Reset()

func (*Mark) String

func (x *Mark) String() string

type MemorySize

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

func (*MemorySize) Descriptor deprecated

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

Deprecated: Use MemorySize.ProtoReflect.Descriptor instead.

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

func (x *MemorySize) String() string

type Payload

type Payload struct {
	Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
	Body []byte      `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor deprecated

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

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

func (x *Payload) String() string

type PayloadConfig

type PayloadConfig struct {

	// Types that are assignable to Payload:
	//
	//	*PayloadConfig_BytebufParams
	//	*PayloadConfig_SimpleParams
	//	*PayloadConfig_ComplexParams
	Payload isPayloadConfig_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*PayloadConfig) Descriptor deprecated

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

Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.

func (*PayloadConfig) GetBytebufParams

func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams

func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload

func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams

func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) ProtoMessage

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) ProtoReflect

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

func (*PayloadConfig) Reset

func (x *PayloadConfig) Reset()

func (*PayloadConfig) String

func (x *PayloadConfig) String() string

type PayloadConfig_BytebufParams

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

type PayloadConfig_ComplexParams

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

type PayloadConfig_SimpleParams

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

type PayloadType

type PayloadType int32
const (
	PayloadType_COMPRESSABLE PayloadType = 0
)

func (PayloadType) Descriptor

func (PayloadType) Enum

func (x PayloadType) Enum() *PayloadType

func (PayloadType) EnumDescriptor deprecated

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

Deprecated: Use PayloadType.Descriptor instead.

func (PayloadType) Number

func (x PayloadType) Number() protoreflect.EnumNumber

func (PayloadType) String

func (x PayloadType) String() string

func (PayloadType) Type

type PoissonParams

type PoissonParams struct {
	OfferedLoad float64 `protobuf:"fixed64,1,opt,name=offered_load,json=offeredLoad,proto3" json:"offered_load,omitempty"`
	// contains filtered or unexported fields
}

func (*PoissonParams) Descriptor deprecated

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

Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.

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

func (x *PoissonParams) String() string

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
}

func (*ReconnectInfo) Descriptor deprecated

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

Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.

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

func (x *ReconnectInfo) String() string

type ReconnectParams

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

func (*ReconnectParams) Descriptor deprecated

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

Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.

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

func (x *ReconnectParams) String() string

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

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

Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.

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

func (x *RequestResultCount) String() string

type ResponseParameters

type ResponseParameters struct {
	Size       int32      `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	IntervalUs int32      `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
	Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseParameters) Descriptor deprecated

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

Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.

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

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) ProtoReflect

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

func (*ResponseParameters) Reset

func (x *ResponseParameters) Reset()

func (*ResponseParameters) String

func (x *ResponseParameters) String() string

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) EnumDescriptor deprecated

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

Deprecated: Use RpcType.Descriptor instead.

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 {
	Name                  string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ClientConfig          *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
	NumClients            int32         `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	ServerConfig          *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
	NumServers            int32         `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`
	WarmupSeconds         int32         `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`
	BenchmarkSeconds      int32         `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`
	SpawnLocalWorkerCount int32         `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Scenario) Descriptor deprecated

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

Deprecated: Use Scenario.ProtoReflect.Descriptor instead.

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

func (*Scenario) ProtoMessage()

func (*Scenario) ProtoReflect

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

func (*Scenario) Reset

func (x *Scenario) Reset()

func (*Scenario) String

func (x *Scenario) String() string

type ScenarioResult

type ScenarioResult struct {
	Scenario       *Scenario              `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"`
	Latencies      *HistogramData         `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"`
	ClientStats    []*ClientStats         `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"`
	ServerStats    []*ServerStats         `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"`
	ServerCores    []int32                `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"`
	Summary        *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
	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"`
	RequestResults []*RequestResultCount  `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
	// contains filtered or unexported fields
}

func (*ScenarioResult) Descriptor deprecated

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

Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.

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

func (*ScenarioResult) ProtoMessage()

func (*ScenarioResult) ProtoReflect

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

func (*ScenarioResult) Reset

func (x *ScenarioResult) Reset()

func (*ScenarioResult) String

func (x *ScenarioResult) String() string

type ScenarioResultSummary

type ScenarioResultSummary struct {
	Qps                         float64                `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
	QpsPerServerCore            float64                `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
	ServerSystemTime            float64                `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
	ServerUserTime              float64                `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
	ClientSystemTime            float64                `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
	ClientUserTime              float64                `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"`
	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"`
	ServerCpuUsage              float64                `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"`
	SuccessfulRequestsPerSecond float64                `` /* 149-byte string literal not displayed */
	FailedRequestsPerSecond     float64                `` /* 137-byte string literal not displayed */
	ClientPollsPerRequest       float64                `` /* 131-byte string literal not displayed */
	ServerPollsPerRequest       float64                `` /* 131-byte string literal not displayed */
	ServerQueriesPerCpuSec      float64                `` /* 136-byte string literal not displayed */
	ClientQueriesPerCpuSec      float64                `` /* 136-byte string literal not displayed */
	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
}

func (*ScenarioResultSummary) Descriptor deprecated

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

Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.

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

func (*ScenarioResultSummary) ProtoMessage()

func (*ScenarioResultSummary) ProtoReflect

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

func (*ScenarioResultSummary) Reset

func (x *ScenarioResultSummary) Reset()

func (*ScenarioResultSummary) String

func (x *ScenarioResultSummary) String() string

type Scenarios

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

func (*Scenarios) Descriptor deprecated

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

Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.

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

func (x *Scenarios) String() string

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
}

func (*SecurityParams) Descriptor deprecated

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

Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.

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

func (x *SecurityParams) String() string

type ServerArgs

type ServerArgs struct {

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

func (*ServerArgs) Descriptor deprecated

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

Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.

func (*ServerArgs) GetArgtype

func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark

func (x *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup

func (x *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) ProtoMessage

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) ProtoReflect

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

func (*ServerArgs) Reset

func (x *ServerArgs) Reset()

func (*ServerArgs) String

func (x *ServerArgs) String() string

type ServerArgs_Mark

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

type ServerArgs_Setup

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

type ServerConfig

type ServerConfig struct {
	ServerType         ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
	SecurityParams     *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
	Port               int32           `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	AsyncServerThreads int32           `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"`
	CoreLimit          int32           `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
	PayloadConfig      *PayloadConfig  `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
	CoreList           []int32         `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
	OtherServerApi     string          `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"`
	ThreadsPerCq       int32           `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
	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"`
	ServerProcesses    int32           `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerConfig) Descriptor deprecated

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

Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

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

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) ProtoReflect

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

func (*ServerConfig) Reset

func (x *ServerConfig) Reset()

func (*ServerConfig) String

func (x *ServerConfig) String() string

type ServerStats

type ServerStats struct {
	TimeElapsed  float64     `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	TimeUser     float64     `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
	TimeSystem   float64     `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
	TotalCpuTime uint64      `protobuf:"varint,4,opt,name=total_cpu_time,json=totalCpuTime,proto3" json:"total_cpu_time,omitempty"`
	IdleCpuTime  uint64      `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"`
	CqPollCount  uint64      `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
	CoreStats    *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStats) Descriptor deprecated

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

Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.

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

func (*ServerStats) ProtoMessage()

func (*ServerStats) ProtoReflect

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

func (*ServerStats) Reset

func (x *ServerStats) Reset()

func (*ServerStats) String

func (x *ServerStats) String() string

type ServerStatus

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

func (*ServerStatus) Descriptor deprecated

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

Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.

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

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) ProtoReflect

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

func (*ServerStatus) Reset

func (x *ServerStatus) Reset()

func (*ServerStatus) String

func (x *ServerStatus) String() string

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
	ServerType_CALLBACK_SERVER      ServerType = 4
)

func (ServerType) Descriptor

func (ServerType) Descriptor() protoreflect.EnumDescriptor

func (ServerType) Enum

func (x ServerType) Enum() *ServerType

func (ServerType) EnumDescriptor deprecated

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

Deprecated: Use ServerType.Descriptor instead.

func (ServerType) Number

func (x ServerType) Number() protoreflect.EnumNumber

func (ServerType) String

func (x ServerType) String() string

func (ServerType) Type

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

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

Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.

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

func (x *SimpleProtoParams) String() string

type SimpleRequest

type SimpleRequest struct {
	ResponseType        PayloadType     `` /* 128-byte string literal not displayed */
	ResponseSize        int32           `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
	Payload             *Payload        `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	FillUsername        bool            `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
	FillOauthScope      bool            `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
	ResponseCompressed  *BoolValue      `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"`
	ResponseStatus      *EchoStatus     `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	ExpectCompressed    *BoolValue      `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
	FillServerId        bool            `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`
	FillGrpclbRouteType bool            `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"`
	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
}

func (*SimpleRequest) Descriptor deprecated

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

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

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect

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

func (*SimpleRequest) Reset

func (x *SimpleRequest) Reset()

func (*SimpleRequest) String

func (x *SimpleRequest) String() string

type SimpleResponse

type SimpleResponse struct {
	Payload         *Payload        `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Username        string          `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	OauthScope      string          `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
	ServerId        string          `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	GrpclbRouteType GrpclbRouteType `` /* 143-byte string literal not displayed */
	Hostname        string          `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleResponse) Descriptor deprecated

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

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

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect

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

func (*SimpleResponse) Reset

func (x *SimpleResponse) Reset()

func (*SimpleResponse) String

func (x *SimpleResponse) String() string

type StreamingInputCallRequest

type StreamingInputCallRequest struct {
	Payload          *Payload   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingInputCallRequest) Descriptor deprecated

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

Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingInputCallRequest) GetExpectCompressed

func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

func (*StreamingInputCallRequest) GetPayload

func (x *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) ProtoReflect

func (*StreamingInputCallRequest) Reset

func (x *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String

func (x *StreamingInputCallRequest) String() string

type StreamingInputCallResponse

type StreamingInputCallResponse struct {
	AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamingInputCallResponse) Descriptor deprecated

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

Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingInputCallResponse) GetAggregatedPayloadSize

func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) ProtoReflect

func (*StreamingInputCallResponse) Reset

func (x *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String

func (x *StreamingInputCallResponse) String() string

type StreamingOutputCallRequest

type StreamingOutputCallRequest struct {
	ResponseType       PayloadType           `` /* 128-byte string literal not displayed */
	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
	Payload            *Payload              `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	ResponseStatus     *EchoStatus           `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	OrcaOobReport      *TestOrcaReport       `protobuf:"bytes,8,opt,name=orca_oob_report,json=orcaOobReport,proto3" json:"orca_oob_report,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingOutputCallRequest) Descriptor deprecated

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

Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.

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

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) ProtoReflect

func (*StreamingOutputCallRequest) Reset

func (x *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String

func (x *StreamingOutputCallRequest) String() string

type StreamingOutputCallResponse

type StreamingOutputCallResponse struct {
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingOutputCallResponse) Descriptor deprecated

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

Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallResponse) GetPayload

func (x *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) ProtoReflect

func (*StreamingOutputCallResponse) Reset

func (x *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String

func (x *StreamingOutputCallResponse) String() string

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 `` /* 184-byte string literal not displayed */
	Utilization       map[string]float64 `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TestOrcaReport) Descriptor deprecated

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

Deprecated: Use TestOrcaReport.ProtoReflect.Descriptor instead.

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

func (x *TestOrcaReport) String() string

type Void

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

func (*Void) Descriptor deprecated

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

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

Jump to

Keyboard shortcuts

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