Movatterモバイル変換

[0]ホーム
URL:

grpc_testing

package
v1.77.0Latest Latest
Warning

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

Go to latest Published: Nov 17, 2025 License:Apache-2.0Imports:11Imported by:1,262

Details

Repository

github.com/grpc/grpc-go

Links

Documentation

Index

Constants

View Source
const (BenchmarkService_UnaryCall_FullMethodName           = "/grpc.testing.BenchmarkService/UnaryCall"BenchmarkService_StreamingCall_FullMethodName       = "/grpc.testing.BenchmarkService/StreamingCall"BenchmarkService_StreamingFromClient_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromClient"BenchmarkService_StreamingFromServer_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromServer"BenchmarkService_StreamingBothWays_FullMethodName   = "/grpc.testing.BenchmarkService/StreamingBothWays")
View Source
const (TestService_EmptyCall_FullMethodName           = "/grpc.testing.TestService/EmptyCall"TestService_UnaryCall_FullMethodName           = "/grpc.testing.TestService/UnaryCall"TestService_CacheableUnaryCall_FullMethodName  = "/grpc.testing.TestService/CacheableUnaryCall"TestService_StreamingOutputCall_FullMethodName = "/grpc.testing.TestService/StreamingOutputCall"TestService_StreamingInputCall_FullMethodName  = "/grpc.testing.TestService/StreamingInputCall"TestService_FullDuplexCall_FullMethodName      = "/grpc.testing.TestService/FullDuplexCall"TestService_HalfDuplexCall_FullMethodName      = "/grpc.testing.TestService/HalfDuplexCall"TestService_UnimplementedCall_FullMethodName   = "/grpc.testing.TestService/UnimplementedCall")
View Source
const (ReconnectService_Start_FullMethodName = "/grpc.testing.ReconnectService/Start"ReconnectService_Stop_FullMethodName  = "/grpc.testing.ReconnectService/Stop")
View Source
const (LoadBalancerStatsService_GetClientStats_FullMethodName            = "/grpc.testing.LoadBalancerStatsService/GetClientStats"LoadBalancerStatsService_GetClientAccumulatedStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientAccumulatedStats")
View Source
const (HookService_Hook_FullMethodName              = "/grpc.testing.HookService/Hook"HookService_SetReturnStatus_FullMethodName   = "/grpc.testing.HookService/SetReturnStatus"HookService_ClearReturnStatus_FullMethodName = "/grpc.testing.HookService/ClearReturnStatus")
View Source
const (XdsUpdateHealthService_SetServing_FullMethodName      = "/grpc.testing.XdsUpdateHealthService/SetServing"XdsUpdateHealthService_SetNotServing_FullMethodName   = "/grpc.testing.XdsUpdateHealthService/SetNotServing"XdsUpdateHealthService_SendHookRequest_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SendHookRequest")
View Source
const (WorkerService_RunServer_FullMethodName  = "/grpc.testing.WorkerService/RunServer"WorkerService_RunClient_FullMethodName  = "/grpc.testing.WorkerService/RunClient"WorkerService_CoreCount_FullMethodName  = "/grpc.testing.WorkerService/CoreCount"WorkerService_QuitWorker_FullMethodName = "/grpc.testing.WorkerService/QuitWorker")
View Source
const (ReportQpsScenarioService_ReportScenario_FullMethodName = "/grpc.testing.ReportQpsScenarioService/ReportScenario")
View Source
const (UnimplementedService_UnimplementedCall_FullMethodName = "/grpc.testing.UnimplementedService/UnimplementedCall")
View Source
const (XdsUpdateClientConfigureService_Configure_FullMethodName = "/grpc.testing.XdsUpdateClientConfigureService/Configure")

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 BenchmarkService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.BenchmarkService",HandlerType: (*BenchmarkServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "UnaryCall",Handler:    _BenchmarkService_UnaryCall_Handler,},},Streams: []grpc.StreamDesc{{StreamName:    "StreamingCall",Handler:       _BenchmarkService_StreamingCall_Handler,ServerStreams:true,ClientStreams:true,},{StreamName:    "StreamingFromClient",Handler:       _BenchmarkService_StreamingFromClient_Handler,ClientStreams:true,},{StreamName:    "StreamingFromServer",Handler:       _BenchmarkService_StreamingFromServer_Handler,ServerStreams:true,},{StreamName:    "StreamingBothWays",Handler:       _BenchmarkService_StreamingBothWays_Handler,ServerStreams:true,ClientStreams:true,},},Metadata: "grpc/testing/benchmark_service.proto",}

BenchmarkService_ServiceDesc is the grpc.ServiceDesc for BenchmarkService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var File_grpc_testing_benchmark_service_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_control_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_empty_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_messages_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_payloads_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_report_qps_scenario_service_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_stats_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_test_protoprotoreflect.FileDescriptor
View Source
var File_grpc_testing_worker_service_protoprotoreflect.FileDescriptor
View Source
var HookService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.HookService",HandlerType: (*HookServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "Hook",Handler:    _HookService_Hook_Handler,},{MethodName: "SetReturnStatus",Handler:    _HookService_SetReturnStatus_Handler,},{MethodName: "ClearReturnStatus",Handler:    _HookService_ClearReturnStatus_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

HookService_ServiceDesc is the grpc.ServiceDesc for HookService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var LoadBalancerStatsService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.LoadBalancerStatsService",HandlerType: (*LoadBalancerStatsServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "GetClientStats",Handler:    _LoadBalancerStatsService_GetClientStats_Handler,},{MethodName: "GetClientAccumulatedStats",Handler:    _LoadBalancerStatsService_GetClientAccumulatedStats_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

LoadBalancerStatsService_ServiceDesc is the grpc.ServiceDesc for LoadBalancerStatsService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var ReconnectService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.ReconnectService",HandlerType: (*ReconnectServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "Start",Handler:    _ReconnectService_Start_Handler,},{MethodName: "Stop",Handler:    _ReconnectService_Stop_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

ReconnectService_ServiceDesc is the grpc.ServiceDesc for ReconnectService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var ReportQpsScenarioService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.ReportQpsScenarioService",HandlerType: (*ReportQpsScenarioServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "ReportScenario",Handler:    _ReportQpsScenarioService_ReportScenario_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/report_qps_scenario_service.proto",}

ReportQpsScenarioService_ServiceDesc is the grpc.ServiceDesc for ReportQpsScenarioService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var TestService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.TestService",HandlerType: (*TestServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "EmptyCall",Handler:    _TestService_EmptyCall_Handler,},{MethodName: "UnaryCall",Handler:    _TestService_UnaryCall_Handler,},{MethodName: "CacheableUnaryCall",Handler:    _TestService_CacheableUnaryCall_Handler,},{MethodName: "UnimplementedCall",Handler:    _TestService_UnimplementedCall_Handler,},},Streams: []grpc.StreamDesc{{StreamName:    "StreamingOutputCall",Handler:       _TestService_StreamingOutputCall_Handler,ServerStreams:true,},{StreamName:    "StreamingInputCall",Handler:       _TestService_StreamingInputCall_Handler,ClientStreams:true,},{StreamName:    "FullDuplexCall",Handler:       _TestService_FullDuplexCall_Handler,ServerStreams:true,ClientStreams:true,},{StreamName:    "HalfDuplexCall",Handler:       _TestService_HalfDuplexCall_Handler,ServerStreams:true,ClientStreams:true,},},Metadata: "grpc/testing/test.proto",}

TestService_ServiceDesc is the grpc.ServiceDesc for TestService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var UnimplementedService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.UnimplementedService",HandlerType: (*UnimplementedServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "UnimplementedCall",Handler:    _UnimplementedService_UnimplementedCall_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

UnimplementedService_ServiceDesc is the grpc.ServiceDesc for UnimplementedService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var WorkerService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.WorkerService",HandlerType: (*WorkerServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "CoreCount",Handler:    _WorkerService_CoreCount_Handler,},{MethodName: "QuitWorker",Handler:    _WorkerService_QuitWorker_Handler,},},Streams: []grpc.StreamDesc{{StreamName:    "RunServer",Handler:       _WorkerService_RunServer_Handler,ServerStreams:true,ClientStreams:true,},{StreamName:    "RunClient",Handler:       _WorkerService_RunClient_Handler,ServerStreams:true,ClientStreams:true,},},Metadata: "grpc/testing/worker_service.proto",}

WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var XdsUpdateClientConfigureService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.XdsUpdateClientConfigureService",HandlerType: (*XdsUpdateClientConfigureServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "Configure",Handler:    _XdsUpdateClientConfigureService_Configure_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

XdsUpdateClientConfigureService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateClientConfigureService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

View Source
var XdsUpdateHealthService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.testing.XdsUpdateHealthService",HandlerType: (*XdsUpdateHealthServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "SetServing",Handler:    _XdsUpdateHealthService_SetServing_Handler,},{MethodName: "SetNotServing",Handler:    _XdsUpdateHealthService_SetNotServing_Handler,},{MethodName: "SendHookRequest",Handler:    _XdsUpdateHealthService_SendHookRequest_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc/testing/test.proto",}

XdsUpdateHealthService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateHealthService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

Functions

funcRegisterBenchmarkServiceServeradded inv1.35.0

func RegisterBenchmarkServiceServer(sgrpc.ServiceRegistrar, srvBenchmarkServiceServer)

funcRegisterHookServiceServeradded inv1.58.0

func RegisterHookServiceServer(sgrpc.ServiceRegistrar, srvHookServiceServer)

funcRegisterLoadBalancerStatsServiceServeradded inv1.28.0

func RegisterLoadBalancerStatsServiceServer(sgrpc.ServiceRegistrar, srvLoadBalancerStatsServiceServer)

funcRegisterReconnectServiceServeradded inv1.35.0

func RegisterReconnectServiceServer(sgrpc.ServiceRegistrar, srvReconnectServiceServer)

funcRegisterReportQpsScenarioServiceServeradded inv1.35.0

func RegisterReportQpsScenarioServiceServer(sgrpc.ServiceRegistrar, srvReportQpsScenarioServiceServer)

funcRegisterTestServiceServer

func RegisterTestServiceServer(sgrpc.ServiceRegistrar, srvTestServiceServer)

funcRegisterUnimplementedServiceServeradded inv1.0.5

func RegisterUnimplementedServiceServer(sgrpc.ServiceRegistrar, srvUnimplementedServiceServer)

funcRegisterWorkerServiceServeradded inv1.35.0

func RegisterWorkerServiceServer(sgrpc.ServiceRegistrar, srvWorkerServiceServer)

funcRegisterXdsUpdateClientConfigureServiceServeradded inv1.35.0

func RegisterXdsUpdateClientConfigureServiceServer(sgrpc.ServiceRegistrar, srvXdsUpdateClientConfigureServiceServer)

funcRegisterXdsUpdateHealthServiceServeradded inv1.35.0

func RegisterXdsUpdateHealthServiceServer(sgrpc.ServiceRegistrar, srvXdsUpdateHealthServiceServer)

Types

typeBenchmarkServiceClientadded inv1.35.0

type BenchmarkServiceClient interface {// One request followed by one response.// The server returns the client payload as-is.UnaryCall(ctxcontext.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse,error)// Repeated sequence of one request followed by one response.// Should be called streaming ping-pong// The server returns the client payload as-is on each responseStreamingCall(ctxcontext.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest,SimpleResponse],error)// Single-sided unbounded streaming from client to server// The server returns the client payload as-is once the client does WritesDoneStreamingFromClient(ctxcontext.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SimpleRequest,SimpleResponse],error)// Single-sided unbounded streaming from server to client// The server repeatedly returns the client payload as-isStreamingFromServer(ctxcontext.Context, in *SimpleRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SimpleResponse],error)// Two-sided unbounded streaming between server to client// Both sides send the content of their own choice to the otherStreamingBothWays(ctxcontext.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest,SimpleResponse],error)}

BenchmarkServiceClient is the client API for BenchmarkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

funcNewBenchmarkServiceClientadded inv1.35.0

func NewBenchmarkServiceClient(ccgrpc.ClientConnInterface)BenchmarkServiceClient

typeBenchmarkServiceServeradded inv1.35.0

type BenchmarkServiceServer interface {// One request followed by one response.// The server returns the client payload as-is.UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse,error)// Repeated sequence of one request followed by one response.// Should be called streaming ping-pong// The server returns the client payload as-is on each responseStreamingCall(grpc.BidiStreamingServer[SimpleRequest,SimpleResponse])error// Single-sided unbounded streaming from client to server// The server returns the client payload as-is once the client does WritesDoneStreamingFromClient(grpc.ClientStreamingServer[SimpleRequest,SimpleResponse])error// Single-sided unbounded streaming from server to client// The server repeatedly returns the client payload as-isStreamingFromServer(*SimpleRequest,grpc.ServerStreamingServer[SimpleResponse])error// Two-sided unbounded streaming between server to client// Both sides send the content of their own choice to the otherStreamingBothWays(grpc.BidiStreamingServer[SimpleRequest,SimpleResponse])error// contains filtered or unexported methods}

BenchmarkServiceServer is the server API for BenchmarkService service.All implementations must embed UnimplementedBenchmarkServiceServerfor forward compatibility.

typeBenchmarkService_StreamingBothWaysClientadded inv1.35.0

type BenchmarkService_StreamingBothWaysClient =grpc.BidiStreamingClient[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingBothWaysServeradded inv1.35.0

type BenchmarkService_StreamingBothWaysServer =grpc.BidiStreamingServer[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingCallClientadded inv1.35.0

type BenchmarkService_StreamingCallClient =grpc.BidiStreamingClient[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingCallServeradded inv1.35.0

type BenchmarkService_StreamingCallServer =grpc.BidiStreamingServer[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingFromClientClientadded inv1.35.0

type BenchmarkService_StreamingFromClientClient =grpc.ClientStreamingClient[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingFromClientServeradded inv1.35.0

type BenchmarkService_StreamingFromClientServer =grpc.ClientStreamingServer[SimpleRequest,SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingFromServerClientadded inv1.35.0

type BenchmarkService_StreamingFromServerClient =grpc.ServerStreamingClient[SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBenchmarkService_StreamingFromServerServeradded inv1.35.0

type BenchmarkService_StreamingFromServerServer =grpc.ServerStreamingServer[SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeBoolValueadded inv1.35.0

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

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

func (*BoolValue)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue)GetValueadded inv1.35.0

func (x *BoolValue) GetValue()bool

func (*BoolValue)ProtoMessageadded inv1.35.0

func (*BoolValue) ProtoMessage()

func (*BoolValue)ProtoReflectadded inv1.35.0

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

func (*BoolValue)Resetadded inv1.35.0

func (x *BoolValue) Reset()

func (*BoolValue)Stringadded inv1.35.0

func (x *BoolValue) String()string

typeByteBufferParamsadded inv1.35.0

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

func (*ByteBufferParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.

func (*ByteBufferParams)GetReqSizeadded inv1.35.0

func (x *ByteBufferParams) GetReqSize()int32

func (*ByteBufferParams)GetRespSizeadded inv1.35.0

func (x *ByteBufferParams) GetRespSize()int32

func (*ByteBufferParams)ProtoMessageadded inv1.35.0

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams)ProtoReflectadded inv1.35.0

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

func (*ByteBufferParams)Resetadded inv1.35.0

func (x *ByteBufferParams) Reset()

func (*ByteBufferParams)Stringadded inv1.35.0

func (x *ByteBufferParams) String()string

typeChannelArgadded inv1.35.0

type ChannelArg struct {Namestring `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`// Types that are valid to be assigned to Value:////*ChannelArg_StrValue//*ChannelArg_IntValueValue isChannelArg_Value `protobuf_oneof:"value"`// contains filtered or unexported fields}

func (*ChannelArg)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.

func (*ChannelArg)GetIntValueadded inv1.35.0

func (x *ChannelArg) GetIntValue()int32

func (*ChannelArg)GetNameadded inv1.35.0

func (x *ChannelArg) GetName()string

func (*ChannelArg)GetStrValueadded inv1.35.0

func (x *ChannelArg) GetStrValue()string

func (*ChannelArg)GetValueadded inv1.35.0

func (x *ChannelArg) GetValue() isChannelArg_Value

func (*ChannelArg)ProtoMessageadded inv1.35.0

func (*ChannelArg) ProtoMessage()

func (*ChannelArg)ProtoReflectadded inv1.35.0

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

func (*ChannelArg)Resetadded inv1.35.0

func (x *ChannelArg) Reset()

func (*ChannelArg)Stringadded inv1.35.0

func (x *ChannelArg) String()string

typeChannelArg_IntValueadded inv1.35.0

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

typeChannelArg_StrValueadded inv1.35.0

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

typeClientArgsadded inv1.35.0

type ClientArgs struct {// Types that are valid to be assigned to Argtype:////*ClientArgs_Setup//*ClientArgs_MarkArgtype isClientArgs_Argtype `protobuf_oneof:"argtype"`// contains filtered or unexported fields}

func (*ClientArgs)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.

func (*ClientArgs)GetArgtypeadded inv1.35.0

func (x *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs)GetMarkadded inv1.35.0

func (x *ClientArgs) GetMark() *Mark

func (*ClientArgs)GetSetupadded inv1.35.0

func (x *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs)ProtoMessageadded inv1.35.0

func (*ClientArgs) ProtoMessage()

func (*ClientArgs)ProtoReflectadded inv1.35.0

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

func (*ClientArgs)Resetadded inv1.35.0

func (x *ClientArgs) Reset()

func (*ClientArgs)Stringadded inv1.35.0

func (x *ClientArgs) String()string

typeClientArgs_Markadded inv1.35.0

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

typeClientArgs_Setupadded inv1.35.0

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

typeClientConfigadded inv1.35.0

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"`ClientTypeClientType      `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.OutstandingRpcsPerChannelint32 ``/* 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()]ClientChannelsint32 `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.AsyncClientThreadsint32   `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"`RpcTypeRpcType `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 desiredCoreList  []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`CoreLimitint32   `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 detailOtherClientApistring        `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 queueThreadsPerCqint32 `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/restartedMessagesPerStreamint32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"`// Use coalescing API when possible.UseCoalesceApibool `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.MedianLatencyCollectionIntervalMillisint32 ``/* 180-byte string literal not displayed */// Number of client processes. 0 indicates no restriction.ClientProcessesint32 `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"`// contains filtered or unexported fields}

func (*ClientConfig)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

func (*ClientConfig)GetAsyncClientThreadsadded inv1.35.0

func (x *ClientConfig) GetAsyncClientThreads()int32

func (*ClientConfig)GetChannelArgsadded inv1.35.0

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

func (*ClientConfig)GetClientChannelsadded inv1.35.0

func (x *ClientConfig) GetClientChannels()int32

func (*ClientConfig)GetClientProcessesadded inv1.35.0

func (x *ClientConfig) GetClientProcesses()int32

func (*ClientConfig)GetClientTypeadded inv1.35.0

func (x *ClientConfig) GetClientType()ClientType

func (*ClientConfig)GetCoreLimitadded inv1.35.0

func (x *ClientConfig) GetCoreLimit()int32

func (*ClientConfig)GetCoreListadded inv1.35.0

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

func (*ClientConfig)GetHistogramParamsadded inv1.35.0

func (x *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig)GetLoadParamsadded inv1.35.0

func (x *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig)GetMedianLatencyCollectionIntervalMillisadded inv1.35.0

func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis()int32

func (*ClientConfig)GetMessagesPerStreamadded inv1.35.0

func (x *ClientConfig) GetMessagesPerStream()int32

func (*ClientConfig)GetOtherClientApiadded inv1.35.0

func (x *ClientConfig) GetOtherClientApi()string

func (*ClientConfig)GetOutstandingRpcsPerChanneladded inv1.35.0

func (x *ClientConfig) GetOutstandingRpcsPerChannel()int32

func (*ClientConfig)GetPayloadConfigadded inv1.35.0

func (x *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig)GetRpcTypeadded inv1.35.0

func (x *ClientConfig) GetRpcType()RpcType

func (*ClientConfig)GetSecurityParamsadded inv1.35.0

func (x *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig)GetServerTargetsadded inv1.35.0

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

func (*ClientConfig)GetThreadsPerCqadded inv1.35.0

func (x *ClientConfig) GetThreadsPerCq()int32

func (*ClientConfig)GetUseCoalesceApiadded inv1.35.0

func (x *ClientConfig) GetUseCoalesceApi()bool

func (*ClientConfig)ProtoMessageadded inv1.35.0

func (*ClientConfig) ProtoMessage()

func (*ClientConfig)ProtoReflectadded inv1.35.0

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

func (*ClientConfig)Resetadded inv1.35.0

func (x *ClientConfig) Reset()

func (*ClientConfig)Stringadded inv1.35.0

func (x *ClientConfig) String()string

typeClientConfigureRequestadded inv1.35.0

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.TimeoutSecint32 `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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest)GetMetadataadded inv1.35.0

func (*ClientConfigureRequest)GetTimeoutSecadded inv1.36.0

func (x *ClientConfigureRequest) GetTimeoutSec()int32

func (*ClientConfigureRequest)GetTypesadded inv1.35.0

func (*ClientConfigureRequest)ProtoMessageadded inv1.35.0

func (*ClientConfigureRequest) ProtoMessage()

func (*ClientConfigureRequest)ProtoReflectadded inv1.35.0

func (*ClientConfigureRequest)Resetadded inv1.35.0

func (x *ClientConfigureRequest) Reset()

func (*ClientConfigureRequest)Stringadded inv1.35.0

func (x *ClientConfigureRequest) String()string

typeClientConfigureRequest_Metadataadded inv1.35.0

type ClientConfigureRequest_Metadata struct {TypeClientConfigureRequest_RpcType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.ClientConfigureRequest_RpcType" json:"type,omitempty"`Keystring                         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`Valuestring                         `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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest_Metadata)GetKeyadded inv1.35.0

func (*ClientConfigureRequest_Metadata)GetTypeadded inv1.35.0

func (*ClientConfigureRequest_Metadata)GetValueadded inv1.35.0

func (*ClientConfigureRequest_Metadata)ProtoMessageadded inv1.35.0

func (*ClientConfigureRequest_Metadata) ProtoMessage()

func (*ClientConfigureRequest_Metadata)ProtoReflectadded inv1.35.0

func (*ClientConfigureRequest_Metadata)Resetadded inv1.35.0

func (*ClientConfigureRequest_Metadata)Stringadded inv1.35.0

typeClientConfigureRequest_RpcTypeadded inv1.35.0

type ClientConfigureRequest_RpcTypeint32

Type of RPCs to send.

const (ClientConfigureRequest_EMPTY_CALLClientConfigureRequest_RpcType = 0ClientConfigureRequest_UNARY_CALLClientConfigureRequest_RpcType = 1)

func (ClientConfigureRequest_RpcType)Descriptoradded inv1.35.0

func (ClientConfigureRequest_RpcType)Enumadded inv1.35.0

func (ClientConfigureRequest_RpcType)EnumDescriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.

func (ClientConfigureRequest_RpcType)Numberadded inv1.35.0

func (ClientConfigureRequest_RpcType)Stringadded inv1.35.0

func (ClientConfigureRequest_RpcType)Typeadded inv1.35.0

typeClientConfigureResponseadded inv1.35.0

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

Response for updating a test client's configuration.

func (*ClientConfigureResponse)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.

func (*ClientConfigureResponse)ProtoMessageadded inv1.35.0

func (*ClientConfigureResponse) ProtoMessage()

func (*ClientConfigureResponse)ProtoReflectadded inv1.35.0

func (*ClientConfigureResponse)Resetadded inv1.35.0

func (x *ClientConfigureResponse) Reset()

func (*ClientConfigureResponse)Stringadded inv1.35.0

typeClientStatsadded inv1.35.0

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.TimeElapsedfloat64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`TimeUserfloat64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`TimeSystemfloat64 `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 queueCqPollCountuint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`// Core library statsCoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`// contains filtered or unexported fields}

func (*ClientStats)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.

func (*ClientStats)GetCoreStatsadded inv1.35.0

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

func (*ClientStats)GetCqPollCountadded inv1.35.0

func (x *ClientStats) GetCqPollCount()uint64

func (*ClientStats)GetLatenciesadded inv1.35.0

func (x *ClientStats) GetLatencies() *HistogramData

func (*ClientStats)GetRequestResultsadded inv1.35.0

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

func (*ClientStats)GetTimeElapsedadded inv1.35.0

func (x *ClientStats) GetTimeElapsed()float64

func (*ClientStats)GetTimeSystemadded inv1.35.0

func (x *ClientStats) GetTimeSystem()float64

func (*ClientStats)GetTimeUseradded inv1.35.0

func (x *ClientStats) GetTimeUser()float64

func (*ClientStats)ProtoMessageadded inv1.35.0

func (*ClientStats) ProtoMessage()

func (*ClientStats)ProtoReflectadded inv1.35.0

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

func (*ClientStats)Resetadded inv1.35.0

func (x *ClientStats) Reset()

func (*ClientStats)Stringadded inv1.35.0

func (x *ClientStats) String()string

typeClientStatusadded inv1.35.0

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

func (*ClientStatus)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.

func (*ClientStatus)GetStatsadded inv1.35.0

func (x *ClientStatus) GetStats() *ClientStats

func (*ClientStatus)ProtoMessageadded inv1.35.0

func (*ClientStatus) ProtoMessage()

func (*ClientStatus)ProtoReflectadded inv1.35.0

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

func (*ClientStatus)Resetadded inv1.35.0

func (x *ClientStatus) Reset()

func (*ClientStatus)Stringadded inv1.35.0

func (x *ClientStatus) String()string

typeClientTypeadded inv1.35.0

type ClientTypeint32
const (// Many languages support a basic distinction between using// sync or async client, and this allows the specificationClientType_SYNC_CLIENTClientType = 0ClientType_ASYNC_CLIENTClientType = 1ClientType_OTHER_CLIENTClientType = 2// used for some language-specific variantsClientType_CALLBACK_CLIENTClientType = 3)

func (ClientType)Descriptoradded inv1.35.0

func (ClientType)Enumadded inv1.35.0

func (xClientType) Enum() *ClientType

func (ClientType)EnumDescriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClientType.Descriptor instead.

func (ClientType)Numberadded inv1.35.0

func (ClientType)Stringadded inv1.35.0

func (xClientType) String()string

func (ClientType)Typeadded inv1.35.0

typeClosedLoopParamsadded inv1.35.0

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

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

func (*ClosedLoopParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.

func (*ClosedLoopParams)ProtoMessageadded inv1.35.0

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams)ProtoReflectadded inv1.35.0

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

func (*ClosedLoopParams)Resetadded inv1.35.0

func (x *ClosedLoopParams) Reset()

func (*ClosedLoopParams)Stringadded inv1.35.0

func (x *ClosedLoopParams) String()string

typeComplexProtoParamsadded inv1.35.0

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

func (*ComplexProtoParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.

func (*ComplexProtoParams)ProtoMessageadded inv1.35.0

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams)ProtoReflectadded inv1.35.0

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

func (*ComplexProtoParams)Resetadded inv1.35.0

func (x *ComplexProtoParams) Reset()

func (*ComplexProtoParams)Stringadded inv1.35.0

func (x *ComplexProtoParams) String()string

typeCoreRequestadded inv1.35.0

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

func (*CoreRequest)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.

func (*CoreRequest)ProtoMessageadded inv1.35.0

func (*CoreRequest) ProtoMessage()

func (*CoreRequest)ProtoReflectadded inv1.35.0

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

func (*CoreRequest)Resetadded inv1.35.0

func (x *CoreRequest) Reset()

func (*CoreRequest)Stringadded inv1.35.0

func (x *CoreRequest) String()string

typeCoreResponseadded inv1.35.0

type CoreResponse struct {// Number of cores available on the serverCoresint32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`// contains filtered or unexported fields}

func (*CoreResponse)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.

func (*CoreResponse)GetCoresadded inv1.35.0

func (x *CoreResponse) GetCores()int32

func (*CoreResponse)ProtoMessageadded inv1.35.0

func (*CoreResponse) ProtoMessage()

func (*CoreResponse)ProtoReflectadded inv1.35.0

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

func (*CoreResponse)Resetadded inv1.35.0

func (x *CoreResponse) Reset()

func (*CoreResponse)Stringadded inv1.35.0

func (x *CoreResponse) String()string

typeEchoStatusadded inv1.0.3

type EchoStatus struct {Codeint32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`Messagestring `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 testclients to specify a status that the server should attempt to return.

func (*EchoStatus)Descriptordeprecatedadded inv1.0.3

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

Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

func (*EchoStatus)GetCodeadded inv1.0.3

func (x *EchoStatus) GetCode()int32

func (*EchoStatus)GetMessageadded inv1.0.3

func (x *EchoStatus) GetMessage()string

func (*EchoStatus)ProtoMessageadded inv1.0.3

func (*EchoStatus) ProtoMessage()

func (*EchoStatus)ProtoReflectadded inv1.33.2

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

func (*EchoStatus)Resetadded inv1.0.3

func (x *EchoStatus) Reset()

func (*EchoStatus)Stringadded inv1.0.3

func (x *EchoStatus) String()string

typeEmpty

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

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

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

func (*Empty)Descriptordeprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty)ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty)ProtoReflectadded inv1.33.2

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

func (*Empty)Reset

func (x *Empty) Reset()

func (*Empty)String

func (x *Empty) String()string

typeGrpclbRouteTypeadded inv1.26.0

type GrpclbRouteTypeint32

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 reachedthe server via the "gRPCLB fallback" path, and "backend" if it detectsthat the RPC reached the server via "gRPCLB backend" path (i.e. if it gotthe address of this server from the gRPCLB server BalanceLoad RPC). Exactlyhow 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_UNKNOWNGrpclbRouteType = 0// Indicates that a client reached a server via gRPCLB fallback.GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACKGrpclbRouteType = 1// Indicates that a client reached a server as a gRPCLB-given backend.GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKENDGrpclbRouteType = 2)

func (GrpclbRouteType)Descriptoradded inv1.33.2

func (GrpclbRouteType)Enumadded inv1.33.2

func (GrpclbRouteType)EnumDescriptordeprecatedadded inv1.26.0

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

Deprecated: Use GrpclbRouteType.Descriptor instead.

func (GrpclbRouteType)Numberadded inv1.33.2

func (GrpclbRouteType)Stringadded inv1.26.0

func (xGrpclbRouteType) String()string

func (GrpclbRouteType)Typeadded inv1.33.2

typeHistogramDataadded inv1.35.0

type HistogramData struct {Bucket       []uint32 `protobuf:"varint,1,rep,packed,name=bucket,proto3" json:"bucket,omitempty"`MinSeenfloat64  `protobuf:"fixed64,2,opt,name=min_seen,json=minSeen,proto3" json:"min_seen,omitempty"`MaxSeenfloat64  `protobuf:"fixed64,3,opt,name=max_seen,json=maxSeen,proto3" json:"max_seen,omitempty"`Sumfloat64  `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`SumOfSquaresfloat64  `protobuf:"fixed64,5,opt,name=sum_of_squares,json=sumOfSquares,proto3" json:"sum_of_squares,omitempty"`Countfloat64  `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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.

func (*HistogramData)GetBucketadded inv1.35.0

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

func (*HistogramData)GetCountadded inv1.35.0

func (x *HistogramData) GetCount()float64

func (*HistogramData)GetMaxSeenadded inv1.35.0

func (x *HistogramData) GetMaxSeen()float64

func (*HistogramData)GetMinSeenadded inv1.35.0

func (x *HistogramData) GetMinSeen()float64

func (*HistogramData)GetSumadded inv1.35.0

func (x *HistogramData) GetSum()float64

func (*HistogramData)GetSumOfSquaresadded inv1.35.0

func (x *HistogramData) GetSumOfSquares()float64

func (*HistogramData)ProtoMessageadded inv1.35.0

func (*HistogramData) ProtoMessage()

func (*HistogramData)ProtoReflectadded inv1.35.0

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

func (*HistogramData)Resetadded inv1.35.0

func (x *HistogramData) Reset()

func (*HistogramData)Stringadded inv1.35.0

func (x *HistogramData) String()string

typeHistogramParamsadded inv1.35.0

type HistogramParams struct {Resolutionfloat64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`// first bucket is [0, 1 + resolution)MaxPossiblefloat64 `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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.

func (*HistogramParams)GetMaxPossibleadded inv1.35.0

func (x *HistogramParams) GetMaxPossible()float64

func (*HistogramParams)GetResolutionadded inv1.35.0

func (x *HistogramParams) GetResolution()float64

func (*HistogramParams)ProtoMessageadded inv1.35.0

func (*HistogramParams) ProtoMessage()

func (*HistogramParams)ProtoReflectadded inv1.35.0

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

func (*HistogramParams)Resetadded inv1.35.0

func (x *HistogramParams) Reset()

func (*HistogramParams)Stringadded inv1.35.0

func (x *HistogramParams) String()string

typeHookRequestadded inv1.58.0

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

func (*HookRequest)Descriptordeprecatedadded inv1.58.0

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

Deprecated: Use HookRequest.ProtoReflect.Descriptor instead.

func (*HookRequest)GetCommandadded inv1.58.0

func (*HookRequest)GetGrpcCodeToReturnadded inv1.58.0

func (x *HookRequest) GetGrpcCodeToReturn()int32

func (*HookRequest)GetGrpcStatusDescriptionadded inv1.58.0

func (x *HookRequest) GetGrpcStatusDescription()string

func (*HookRequest)GetServerPortadded inv1.58.0

func (x *HookRequest) GetServerPort()int32

func (*HookRequest)ProtoMessageadded inv1.58.0

func (*HookRequest) ProtoMessage()

func (*HookRequest)ProtoReflectadded inv1.58.0

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

func (*HookRequest)Resetadded inv1.58.0

func (x *HookRequest) Reset()

func (*HookRequest)Stringadded inv1.58.0

func (x *HookRequest) String()string

typeHookRequest_HookRequestCommandadded inv1.59.0

type HookRequest_HookRequestCommandint32
const (// Default valueHookRequest_UNSPECIFIEDHookRequest_HookRequestCommand = 0// Start the HTTP endpointHookRequest_STARTHookRequest_HookRequestCommand = 1// StopHookRequest_STOPHookRequest_HookRequestCommand = 2// Return from HTTP GET/POSTHookRequest_RETURNHookRequest_HookRequestCommand = 3)

func (HookRequest_HookRequestCommand)Descriptoradded inv1.59.0

func (HookRequest_HookRequestCommand)Enumadded inv1.59.0

func (HookRequest_HookRequestCommand)EnumDescriptordeprecatedadded inv1.59.0

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

Deprecated: Use HookRequest_HookRequestCommand.Descriptor instead.

func (HookRequest_HookRequestCommand)Numberadded inv1.59.0

func (HookRequest_HookRequestCommand)Stringadded inv1.59.0

func (HookRequest_HookRequestCommand)Typeadded inv1.59.0

typeHookResponseadded inv1.58.0

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

func (*HookResponse)Descriptordeprecatedadded inv1.58.0

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

Deprecated: Use HookResponse.ProtoReflect.Descriptor instead.

func (*HookResponse)ProtoMessageadded inv1.58.0

func (*HookResponse) ProtoMessage()

func (*HookResponse)ProtoReflectadded inv1.58.0

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

func (*HookResponse)Resetadded inv1.58.0

func (x *HookResponse) Reset()

func (*HookResponse)Stringadded inv1.58.0

func (x *HookResponse) String()string

typeHookServiceClientadded inv1.58.0

type HookServiceClient interface {// Sends a request that will "hang" until the return status is set by a call// to a SetReturnStatusHook(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)// Sets a return status for pending and upcoming calls to HookSetReturnStatus(ctxcontext.Context, in *SetReturnStatusRequest, opts ...grpc.CallOption) (*Empty,error)// Clears the return status. Incoming calls to Hook will "hang"ClearReturnStatus(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)}

HookServiceClient is the client API for HookService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Hook service. Used to keep Kubernetes from shutting the pod down.

funcNewHookServiceClientadded inv1.58.0

func NewHookServiceClient(ccgrpc.ClientConnInterface)HookServiceClient

typeHookServiceServeradded inv1.58.0

type HookServiceServer interface {// Sends a request that will "hang" until the return status is set by a call// to a SetReturnStatusHook(context.Context, *Empty) (*Empty,error)// Sets a return status for pending and upcoming calls to HookSetReturnStatus(context.Context, *SetReturnStatusRequest) (*Empty,error)// Clears the return status. Incoming calls to Hook will "hang"ClearReturnStatus(context.Context, *Empty) (*Empty,error)// contains filtered or unexported methods}

HookServiceServer is the server API for HookService service.All implementations must embed UnimplementedHookServiceServerfor forward compatibility.

Hook service. Used to keep Kubernetes from shutting the pod down.

typeLoadBalancerAccumulatedStatsRequestadded inv1.35.0

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

Request for retrieving a test client's accumulated stats.

func (*LoadBalancerAccumulatedStatsRequest)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsRequest)ProtoMessageadded inv1.35.0

func (*LoadBalancerAccumulatedStatsRequest)ProtoReflectadded inv1.35.0

func (*LoadBalancerAccumulatedStatsRequest)Resetadded inv1.35.0

func (*LoadBalancerAccumulatedStatsRequest)Stringadded inv1.35.0

typeLoadBalancerAccumulatedStatsResponseadded inv1.35.0

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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsResponse)GetNumRpcsFailedByMethoddeprecatedadded inv1.35.0

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

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

func (*LoadBalancerAccumulatedStatsResponse)GetNumRpcsStartedByMethoddeprecatedadded inv1.35.0

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

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

func (*LoadBalancerAccumulatedStatsResponse)GetNumRpcsSucceededByMethoddeprecatedadded inv1.35.0

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

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

func (*LoadBalancerAccumulatedStatsResponse)GetStatsPerMethodadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse)ProtoMessageadded inv1.35.0

func (*LoadBalancerAccumulatedStatsResponse)ProtoReflectadded inv1.35.0

func (*LoadBalancerAccumulatedStatsResponse)Resetadded inv1.35.0

func (*LoadBalancerAccumulatedStatsResponse)Stringadded inv1.35.0

typeLoadBalancerAccumulatedStatsResponse_MethodStatsadded inv1.36.0

type LoadBalancerAccumulatedStatsResponse_MethodStats struct {// The number of RPCs that were started for this method.RpcsStartedint32 `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)Descriptordeprecatedadded inv1.36.0

Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)GetResultadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)GetRpcsStartedadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)ProtoMessageadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)ProtoReflectadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)Resetadded inv1.36.0

func (*LoadBalancerAccumulatedStatsResponse_MethodStats)Stringadded inv1.36.0

typeLoadBalancerStatsRequestadded inv1.28.0

type LoadBalancerStatsRequest struct {// Request stats for the next num_rpcs sent by client.NumRpcsint32 `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.TimeoutSecint32 `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 entriesMetadataKeys []string `protobuf:"bytes,3,rep,name=metadata_keys,json=metadataKeys,proto3" json:"metadata_keys,omitempty"`// contains filtered or unexported fields}

func (*LoadBalancerStatsRequest)Descriptordeprecatedadded inv1.28.0

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

Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsRequest)GetMetadataKeysadded inv1.58.0

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

func (*LoadBalancerStatsRequest)GetNumRpcsadded inv1.28.0

func (x *LoadBalancerStatsRequest) GetNumRpcs()int32

func (*LoadBalancerStatsRequest)GetTimeoutSecadded inv1.28.0

func (x *LoadBalancerStatsRequest) GetTimeoutSec()int32

func (*LoadBalancerStatsRequest)ProtoMessageadded inv1.28.0

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest)ProtoReflectadded inv1.33.2

func (*LoadBalancerStatsRequest)Resetadded inv1.28.0

func (x *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest)Stringadded inv1.28.0

typeLoadBalancerStatsResponseadded inv1.28.0

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.NumFailuresint32                                            `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)Descriptordeprecatedadded inv1.28.0

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

Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse)GetMetadatasByPeeradded inv1.58.0

func (*LoadBalancerStatsResponse)GetNumFailuresadded inv1.28.0

func (x *LoadBalancerStatsResponse) GetNumFailures()int32

func (*LoadBalancerStatsResponse)GetRpcsByMethodadded inv1.31.0

func (*LoadBalancerStatsResponse)GetRpcsByPeeradded inv1.28.0

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

func (*LoadBalancerStatsResponse)ProtoMessageadded inv1.28.0

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse)ProtoReflectadded inv1.33.2

func (*LoadBalancerStatsResponse)Resetadded inv1.28.0

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse)Stringadded inv1.28.0

typeLoadBalancerStatsResponse_MetadataByPeeradded inv1.58.0

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

func (*LoadBalancerStatsResponse_MetadataByPeer)Descriptordeprecatedadded inv1.58.0

Deprecated: Use LoadBalancerStatsResponse_MetadataByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_MetadataByPeer)GetRpcMetadataadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataByPeer)ProtoMessageadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataByPeer)ProtoReflectadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataByPeer)Resetadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataByPeer)Stringadded inv1.58.0

typeLoadBalancerStatsResponse_MetadataEntryadded inv1.58.0

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

func (*LoadBalancerStatsResponse_MetadataEntry)Descriptordeprecatedadded inv1.58.0

Deprecated: Use LoadBalancerStatsResponse_MetadataEntry.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_MetadataEntry)GetKeyadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)GetTypeadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)GetValueadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)ProtoMessageadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)ProtoReflectadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)Resetadded inv1.58.0

func (*LoadBalancerStatsResponse_MetadataEntry)Stringadded inv1.58.0

typeLoadBalancerStatsResponse_MetadataTypeadded inv1.58.0

type LoadBalancerStatsResponse_MetadataTypeint32
const (LoadBalancerStatsResponse_UNKNOWNLoadBalancerStatsResponse_MetadataType = 0LoadBalancerStatsResponse_INITIALLoadBalancerStatsResponse_MetadataType = 1LoadBalancerStatsResponse_TRAILINGLoadBalancerStatsResponse_MetadataType = 2)

func (LoadBalancerStatsResponse_MetadataType)Descriptoradded inv1.58.0

func (LoadBalancerStatsResponse_MetadataType)Enumadded inv1.58.0

func (LoadBalancerStatsResponse_MetadataType)EnumDescriptordeprecatedadded inv1.58.0

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

Deprecated: Use LoadBalancerStatsResponse_MetadataType.Descriptor instead.

func (LoadBalancerStatsResponse_MetadataType)Numberadded inv1.58.0

func (LoadBalancerStatsResponse_MetadataType)Stringadded inv1.58.0

func (LoadBalancerStatsResponse_MetadataType)Typeadded inv1.58.0

typeLoadBalancerStatsResponse_RpcMetadataadded inv1.58.0

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)Descriptordeprecatedadded inv1.58.0

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

Deprecated: Use LoadBalancerStatsResponse_RpcMetadata.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcMetadata)GetMetadataadded inv1.58.0

func (*LoadBalancerStatsResponse_RpcMetadata)ProtoMessageadded inv1.58.0

func (*LoadBalancerStatsResponse_RpcMetadata)ProtoReflectadded inv1.58.0

func (*LoadBalancerStatsResponse_RpcMetadata)Resetadded inv1.58.0

func (*LoadBalancerStatsResponse_RpcMetadata)Stringadded inv1.58.0

typeLoadBalancerStatsResponse_RpcsByPeeradded inv1.31.0

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)Descriptordeprecatedadded inv1.31.0

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

Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcsByPeer)GetRpcsByPeeradded inv1.31.0

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

func (*LoadBalancerStatsResponse_RpcsByPeer)ProtoMessageadded inv1.31.0

func (*LoadBalancerStatsResponse_RpcsByPeer)ProtoReflectadded inv1.33.2

func (*LoadBalancerStatsResponse_RpcsByPeer)Resetadded inv1.31.0

func (*LoadBalancerStatsResponse_RpcsByPeer)Stringadded inv1.31.0

typeLoadBalancerStatsServiceClientadded inv1.28.0

type LoadBalancerStatsServiceClient interface {// Gets the backend distribution for RPCs sent by a test client.GetClientStats(ctxcontext.Context, in *LoadBalancerStatsRequest, opts ...grpc.CallOption) (*LoadBalancerStatsResponse,error)// Gets the accumulated stats for RPCs sent by a test client.GetClientAccumulatedStats(ctxcontext.Context, in *LoadBalancerAccumulatedStatsRequest, opts ...grpc.CallOption) (*LoadBalancerAccumulatedStatsResponse,error)}

LoadBalancerStatsServiceClient is the client API for LoadBalancerStatsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A service used to obtain stats for verifying LB behavior.

funcNewLoadBalancerStatsServiceClientadded inv1.28.0

func NewLoadBalancerStatsServiceClient(ccgrpc.ClientConnInterface)LoadBalancerStatsServiceClient

typeLoadBalancerStatsServiceServeradded inv1.28.0

type LoadBalancerStatsServiceServer interface {// Gets the backend distribution for RPCs sent by a test client.GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse,error)// Gets the accumulated stats for RPCs sent by a test client.GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse,error)// contains filtered or unexported methods}

LoadBalancerStatsServiceServer is the server API for LoadBalancerStatsService service.All implementations must embed UnimplementedLoadBalancerStatsServiceServerfor forward compatibility.

A service used to obtain stats for verifying LB behavior.

typeLoadParamsadded inv1.35.0

type LoadParams struct {// Types that are valid to be assigned to Load:////*LoadParams_ClosedLoop//*LoadParams_PoissonLoad isLoadParams_Load `protobuf_oneof:"load"`// contains filtered or unexported fields}

func (*LoadParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.

func (*LoadParams)GetClosedLoopadded inv1.35.0

func (x *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams)GetLoadadded inv1.35.0

func (x *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams)GetPoissonadded inv1.35.0

func (x *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams)ProtoMessageadded inv1.35.0

func (*LoadParams) ProtoMessage()

func (*LoadParams)ProtoReflectadded inv1.35.0

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

func (*LoadParams)Resetadded inv1.35.0

func (x *LoadParams) Reset()

func (*LoadParams)Stringadded inv1.35.0

func (x *LoadParams) String()string

typeLoadParams_ClosedLoopadded inv1.35.0

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

typeLoadParams_Poissonadded inv1.35.0

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

typeMarkadded inv1.35.0

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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use Mark.ProtoReflect.Descriptor instead.

func (*Mark)GetReset_added inv1.35.0

func (x *Mark) GetReset_()bool

func (*Mark)ProtoMessageadded inv1.35.0

func (*Mark) ProtoMessage()

func (*Mark)ProtoReflectadded inv1.35.0

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

func (*Mark)Resetadded inv1.35.0

func (x *Mark) Reset()

func (*Mark)Stringadded inv1.35.0

func (x *Mark) String()string

typeMemorySizeadded inv1.58.0

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

func (*MemorySize)Descriptordeprecatedadded inv1.58.0

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

Deprecated: Use MemorySize.ProtoReflect.Descriptor instead.

func (*MemorySize)GetRssadded inv1.58.0

func (x *MemorySize) GetRss()int64

func (*MemorySize)ProtoMessageadded inv1.58.0

func (*MemorySize) ProtoMessage()

func (*MemorySize)ProtoReflectadded inv1.58.0

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

func (*MemorySize)Resetadded inv1.58.0

func (x *MemorySize) Reset()

func (*MemorySize)Stringadded inv1.58.0

func (x *MemorySize) String()string

typePayload

type Payload struct {// The type of data in body.TypePayloadType `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)Descriptordeprecated

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)ProtoReflectadded inv1.33.2

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

func (*Payload)Reset

func (x *Payload) Reset()

func (*Payload)String

func (x *Payload) String()string

typePayloadConfigadded inv1.35.0

type PayloadConfig struct {// Types that are valid to be assigned to Payload:////*PayloadConfig_BytebufParams//*PayloadConfig_SimpleParams//*PayloadConfig_ComplexParamsPayload isPayloadConfig_Payload `protobuf_oneof:"payload"`// contains filtered or unexported fields}

func (*PayloadConfig)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.

func (*PayloadConfig)GetBytebufParamsadded inv1.35.0

func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig)GetComplexParamsadded inv1.35.0

func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig)GetPayloadadded inv1.35.0

func (x *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig)GetSimpleParamsadded inv1.35.0

func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig)ProtoMessageadded inv1.35.0

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig)ProtoReflectadded inv1.35.0

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

func (*PayloadConfig)Resetadded inv1.35.0

func (x *PayloadConfig) Reset()

func (*PayloadConfig)Stringadded inv1.35.0

func (x *PayloadConfig) String()string

typePayloadConfig_BytebufParamsadded inv1.35.0

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

typePayloadConfig_ComplexParamsadded inv1.35.0

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

typePayloadConfig_SimpleParamsadded inv1.35.0

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

typePayloadType

type PayloadTypeint32

The type of payload that should be returned.

const (// Compressable text format.PayloadType_COMPRESSABLEPayloadType = 0)

func (PayloadType)Descriptoradded inv1.33.2

func (PayloadType)Enum

func (xPayloadType) Enum() *PayloadType

func (PayloadType)EnumDescriptordeprecated

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

Deprecated: Use PayloadType.Descriptor instead.

func (PayloadType)Numberadded inv1.33.2

func (PayloadType)String

func (xPayloadType) String()string

func (PayloadType)Typeadded inv1.33.2

typePoissonParamsadded inv1.35.0

type PoissonParams struct {// The rate of arrivals (a.k.a. lambda parameter of the exp distribution).OfferedLoadfloat64 `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 representationof activity coming in from independent identical stationary sources.

func (*PoissonParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.

func (*PoissonParams)GetOfferedLoadadded inv1.35.0

func (x *PoissonParams) GetOfferedLoad()float64

func (*PoissonParams)ProtoMessageadded inv1.35.0

func (*PoissonParams) ProtoMessage()

func (*PoissonParams)ProtoReflectadded inv1.35.0

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

func (*PoissonParams)Resetadded inv1.35.0

func (x *PoissonParams) Reset()

func (*PoissonParams)Stringadded inv1.35.0

func (x *PoissonParams) String()string

typeReconnectInfoadded inv1.35.0

type ReconnectInfo struct {Passedbool    `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 thereconnect backoffs it saw.

func (*ReconnectInfo)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.

func (*ReconnectInfo)GetBackoffMsadded inv1.35.0

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

func (*ReconnectInfo)GetPassedadded inv1.35.0

func (x *ReconnectInfo) GetPassed()bool

func (*ReconnectInfo)ProtoMessageadded inv1.35.0

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo)ProtoReflectadded inv1.35.0

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

func (*ReconnectInfo)Resetadded inv1.35.0

func (x *ReconnectInfo) Reset()

func (*ReconnectInfo)Stringadded inv1.35.0

func (x *ReconnectInfo) String()string

typeReconnectParamsadded inv1.35.0

type ReconnectParams struct {MaxReconnectBackoffMsint32 ``/* 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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.

func (*ReconnectParams)GetMaxReconnectBackoffMsadded inv1.35.0

func (x *ReconnectParams) GetMaxReconnectBackoffMs()int32

func (*ReconnectParams)ProtoMessageadded inv1.35.0

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams)ProtoReflectadded inv1.35.0

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

func (*ReconnectParams)Resetadded inv1.35.0

func (x *ReconnectParams) Reset()

func (*ReconnectParams)Stringadded inv1.35.0

func (x *ReconnectParams) String()string

typeReconnectServiceClientadded inv1.35.0

type ReconnectServiceClient interface {Start(ctxcontext.Context, in *ReconnectParams, opts ...grpc.CallOption) (*Empty,error)Stop(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*ReconnectInfo,error)}

ReconnectServiceClient is the client API for ReconnectService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A service used to control reconnect server.

funcNewReconnectServiceClientadded inv1.35.0

func NewReconnectServiceClient(ccgrpc.ClientConnInterface)ReconnectServiceClient

typeReconnectServiceServeradded inv1.35.0

type ReconnectServiceServer interface {Start(context.Context, *ReconnectParams) (*Empty,error)Stop(context.Context, *Empty) (*ReconnectInfo,error)// contains filtered or unexported methods}

ReconnectServiceServer is the server API for ReconnectService service.All implementations must embed UnimplementedReconnectServiceServerfor forward compatibility.

A service used to control reconnect server.

typeReportQpsScenarioServiceClientadded inv1.35.0

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

ReportQpsScenarioServiceClient is the client API for ReportQpsScenarioService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

funcNewReportQpsScenarioServiceClientadded inv1.35.0

func NewReportQpsScenarioServiceClient(ccgrpc.ClientConnInterface)ReportQpsScenarioServiceClient

typeReportQpsScenarioServiceServeradded inv1.35.0

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

ReportQpsScenarioServiceServer is the server API for ReportQpsScenarioService service.All implementations must embed UnimplementedReportQpsScenarioServiceServerfor forward compatibility.

typeRequestResultCountadded inv1.35.0

type RequestResultCount struct {StatusCodeint32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`Countint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`// contains filtered or unexported fields}

func (*RequestResultCount)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.

func (*RequestResultCount)GetCountadded inv1.35.0

func (x *RequestResultCount) GetCount()int64

func (*RequestResultCount)GetStatusCodeadded inv1.35.0

func (x *RequestResultCount) GetStatusCode()int32

func (*RequestResultCount)ProtoMessageadded inv1.35.0

func (*RequestResultCount) ProtoMessage()

func (*RequestResultCount)ProtoReflectadded inv1.35.0

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

func (*RequestResultCount)Resetadded inv1.35.0

func (x *RequestResultCount) Reset()

func (*RequestResultCount)Stringadded inv1.35.0

func (x *RequestResultCount) String()string

typeResponseParameters

type ResponseParameters struct {// Desired payload sizes in responses from the server.Sizeint32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`// Desired interval between consecutive responses in the response stream in// microseconds.IntervalUsint32 `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)Descriptordeprecated

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

Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.

func (*ResponseParameters)GetCompressedadded inv1.35.0

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)ProtoReflectadded inv1.33.2

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

func (*ResponseParameters)Reset

func (x *ResponseParameters) Reset()

func (*ResponseParameters)String

func (x *ResponseParameters) String()string

typeRpcTypeadded inv1.35.0

type RpcTypeint32
const (RpcType_UNARYRpcType = 0RpcType_STREAMINGRpcType = 1RpcType_STREAMING_FROM_CLIENTRpcType = 2RpcType_STREAMING_FROM_SERVERRpcType = 3RpcType_STREAMING_BOTH_WAYSRpcType = 4)

func (RpcType)Descriptoradded inv1.35.0

func (RpcType)Enumadded inv1.35.0

func (xRpcType) Enum() *RpcType

func (RpcType)EnumDescriptordeprecatedadded inv1.35.0

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

Deprecated: Use RpcType.Descriptor instead.

func (RpcType)Numberadded inv1.35.0

func (RpcType)Stringadded inv1.35.0

func (xRpcType) String()string

func (RpcType)Typeadded inv1.35.0

typeScenarioadded inv1.35.0

type Scenario struct {// Human readable name for this scenarioNamestring `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`// Client configurationClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`// Number of clients to start for the testNumClientsint32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`// Server configurationServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`// Number of servers to start for the testNumServersint32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`// Warmup period, in secondsWarmupSecondsint32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`// Benchmark time, in secondsBenchmarkSecondsint32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`// Number of workers to spawn locally (usually zero)SpawnLocalWorkerCountint32 ``/* 129-byte string literal not displayed */// contains filtered or unexported fields}

A single performance scenario: input to qps_json_driver

func (*Scenario)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use Scenario.ProtoReflect.Descriptor instead.

func (*Scenario)GetBenchmarkSecondsadded inv1.35.0

func (x *Scenario) GetBenchmarkSeconds()int32

func (*Scenario)GetClientConfigadded inv1.35.0

func (x *Scenario) GetClientConfig() *ClientConfig

func (*Scenario)GetNameadded inv1.35.0

func (x *Scenario) GetName()string

func (*Scenario)GetNumClientsadded inv1.35.0

func (x *Scenario) GetNumClients()int32

func (*Scenario)GetNumServersadded inv1.35.0

func (x *Scenario) GetNumServers()int32

func (*Scenario)GetServerConfigadded inv1.35.0

func (x *Scenario) GetServerConfig() *ServerConfig

func (*Scenario)GetSpawnLocalWorkerCountadded inv1.35.0

func (x *Scenario) GetSpawnLocalWorkerCount()int32

func (*Scenario)GetWarmupSecondsadded inv1.35.0

func (x *Scenario) GetWarmupSeconds()int32

func (*Scenario)ProtoMessageadded inv1.35.0

func (*Scenario) ProtoMessage()

func (*Scenario)ProtoReflectadded inv1.35.0

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

func (*Scenario)Resetadded inv1.35.0

func (x *Scenario) Reset()

func (*Scenario)Stringadded inv1.35.0

func (x *Scenario) String()string

typeScenarioResultadded inv1.35.0

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 clientClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"`// Server stats for each serverServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"`// Number of cores available to each serverServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"`// An after-the-fact computed summarySummary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`// Information on success or failure of each workerClientSuccess []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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.

func (*ScenarioResult)GetClientStatsadded inv1.35.0

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

func (*ScenarioResult)GetClientSuccessadded inv1.35.0

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

func (*ScenarioResult)GetLatenciesadded inv1.35.0

func (x *ScenarioResult) GetLatencies() *HistogramData

func (*ScenarioResult)GetRequestResultsadded inv1.35.0

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

func (*ScenarioResult)GetScenarioadded inv1.35.0

func (x *ScenarioResult) GetScenario() *Scenario

func (*ScenarioResult)GetServerCoresadded inv1.35.0

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

func (*ScenarioResult)GetServerStatsadded inv1.35.0

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

func (*ScenarioResult)GetServerSuccessadded inv1.35.0

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

func (*ScenarioResult)GetSummaryadded inv1.35.0

func (x *ScenarioResult) GetSummary() *ScenarioResultSummary

func (*ScenarioResult)ProtoMessageadded inv1.35.0

func (*ScenarioResult) ProtoMessage()

func (*ScenarioResult)ProtoReflectadded inv1.35.0

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

func (*ScenarioResult)Resetadded inv1.35.0

func (x *ScenarioResult) Reset()

func (*ScenarioResult)Stringadded inv1.35.0

func (x *ScenarioResult) String()string

typeScenarioResultSummaryadded inv1.35.0

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.Qpsfloat64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`// QPS per server core.QpsPerServerCorefloat64 `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.ServerSystemTimefloat64 `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%)ServerUserTimefloat64 `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%)ClientSystemTimefloat64 `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%)ClientUserTimefloat64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"`// X% latency percentiles (in nanoseconds)Latency_50float64 `protobuf:"fixed64,7,opt,name=latency_50,json=latency50,proto3" json:"latency_50,omitempty"`Latency_90float64 `protobuf:"fixed64,8,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"`Latency_95float64 `protobuf:"fixed64,9,opt,name=latency_95,json=latency95,proto3" json:"latency_95,omitempty"`Latency_99float64 `protobuf:"fixed64,10,opt,name=latency_99,json=latency99,proto3" json:"latency_99,omitempty"`Latency_999float64 `protobuf:"fixed64,11,opt,name=latency_999,json=latency999,proto3" json:"latency_999,omitempty"`// server cpu usage percentageServerCpuUsagefloat64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"`// Number of requests that succeeded/failedSuccessfulRequestsPerSecondfloat64 ``/* 149-byte string literal not displayed */FailedRequestsPerSecondfloat64 ``/* 137-byte string literal not displayed */// Number of polls called inside completion queue per requestClientPollsPerRequestfloat64 ``/* 131-byte string literal not displayed */ServerPollsPerRequestfloat64 ``/* 131-byte string literal not displayed */// Queries per CPU-sec over all servers or clientsServerQueriesPerCpuSecfloat64 ``/* 136-byte string literal not displayed */ClientQueriesPerCpuSecfloat64 ``/* 136-byte string literal not displayed */// Start and end time for the test scenarioStartTime *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 ServerStatsonce the scenario has finished.

func (*ScenarioResultSummary)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.

func (*ScenarioResultSummary)GetClientPollsPerRequestadded inv1.35.0

func (x *ScenarioResultSummary) GetClientPollsPerRequest()float64

func (*ScenarioResultSummary)GetClientQueriesPerCpuSecadded inv1.35.0

func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec()float64

func (*ScenarioResultSummary)GetClientSystemTimeadded inv1.35.0

func (x *ScenarioResultSummary) GetClientSystemTime()float64

func (*ScenarioResultSummary)GetClientUserTimeadded inv1.35.0

func (x *ScenarioResultSummary) GetClientUserTime()float64

func (*ScenarioResultSummary)GetEndTimeadded inv1.48.0

func (*ScenarioResultSummary)GetFailedRequestsPerSecondadded inv1.35.0

func (x *ScenarioResultSummary) GetFailedRequestsPerSecond()float64

func (*ScenarioResultSummary)GetLatency_50added inv1.35.0

func (x *ScenarioResultSummary) GetLatency_50()float64

func (*ScenarioResultSummary)GetLatency_90added inv1.35.0

func (x *ScenarioResultSummary) GetLatency_90()float64

func (*ScenarioResultSummary)GetLatency_95added inv1.35.0

func (x *ScenarioResultSummary) GetLatency_95()float64

func (*ScenarioResultSummary)GetLatency_99added inv1.35.0

func (x *ScenarioResultSummary) GetLatency_99()float64

func (*ScenarioResultSummary)GetLatency_999added inv1.35.0

func (x *ScenarioResultSummary) GetLatency_999()float64

func (*ScenarioResultSummary)GetQpsadded inv1.35.0

func (x *ScenarioResultSummary) GetQps()float64

func (*ScenarioResultSummary)GetQpsPerServerCoreadded inv1.35.0

func (x *ScenarioResultSummary) GetQpsPerServerCore()float64

func (*ScenarioResultSummary)GetServerCpuUsageadded inv1.35.0

func (x *ScenarioResultSummary) GetServerCpuUsage()float64

func (*ScenarioResultSummary)GetServerPollsPerRequestadded inv1.35.0

func (x *ScenarioResultSummary) GetServerPollsPerRequest()float64

func (*ScenarioResultSummary)GetServerQueriesPerCpuSecadded inv1.35.0

func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec()float64

func (*ScenarioResultSummary)GetServerSystemTimeadded inv1.35.0

func (x *ScenarioResultSummary) GetServerSystemTime()float64

func (*ScenarioResultSummary)GetServerUserTimeadded inv1.35.0

func (x *ScenarioResultSummary) GetServerUserTime()float64

func (*ScenarioResultSummary)GetStartTimeadded inv1.48.0

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

func (*ScenarioResultSummary)GetSuccessfulRequestsPerSecondadded inv1.35.0

func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond()float64

func (*ScenarioResultSummary)ProtoMessageadded inv1.35.0

func (*ScenarioResultSummary) ProtoMessage()

func (*ScenarioResultSummary)ProtoReflectadded inv1.35.0

func (*ScenarioResultSummary)Resetadded inv1.35.0

func (x *ScenarioResultSummary) Reset()

func (*ScenarioResultSummary)Stringadded inv1.35.0

func (x *ScenarioResultSummary) String()string

typeScenariosadded inv1.35.0

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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.

func (*Scenarios)GetScenariosadded inv1.35.0

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

func (*Scenarios)ProtoMessageadded inv1.35.0

func (*Scenarios) ProtoMessage()

func (*Scenarios)ProtoReflectadded inv1.35.0

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

func (*Scenarios)Resetadded inv1.35.0

func (x *Scenarios) Reset()

func (*Scenarios)Stringadded inv1.35.0

func (x *Scenarios) String()string

typeSecurityParamsadded inv1.35.0

type SecurityParams struct {UseTestCabool   `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`ServerHostOverridestring `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`CredTypestring `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)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.

func (*SecurityParams)GetCredTypeadded inv1.35.0

func (x *SecurityParams) GetCredType()string

func (*SecurityParams)GetServerHostOverrideadded inv1.35.0

func (x *SecurityParams) GetServerHostOverride()string

func (*SecurityParams)GetUseTestCaadded inv1.35.0

func (x *SecurityParams) GetUseTestCa()bool

func (*SecurityParams)ProtoMessageadded inv1.35.0

func (*SecurityParams) ProtoMessage()

func (*SecurityParams)ProtoReflectadded inv1.35.0

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

func (*SecurityParams)Resetadded inv1.35.0

func (x *SecurityParams) Reset()

func (*SecurityParams)Stringadded inv1.35.0

func (x *SecurityParams) String()string

typeServerArgsadded inv1.35.0

type ServerArgs struct {// Types that are valid to be assigned to Argtype:////*ServerArgs_Setup//*ServerArgs_MarkArgtype isServerArgs_Argtype `protobuf_oneof:"argtype"`// contains filtered or unexported fields}

func (*ServerArgs)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.

func (*ServerArgs)GetArgtypeadded inv1.35.0

func (x *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs)GetMarkadded inv1.35.0

func (x *ServerArgs) GetMark() *Mark

func (*ServerArgs)GetSetupadded inv1.35.0

func (x *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs)ProtoMessageadded inv1.35.0

func (*ServerArgs) ProtoMessage()

func (*ServerArgs)ProtoReflectadded inv1.35.0

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

func (*ServerArgs)Resetadded inv1.35.0

func (x *ServerArgs) Reset()

func (*ServerArgs)Stringadded inv1.35.0

func (x *ServerArgs) String()string

typeServerArgs_Markadded inv1.35.0

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

typeServerArgs_Setupadded inv1.35.0

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

typeServerConfigadded inv1.35.0

type ServerConfig struct {ServerTypeServerType      `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.Portint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`// Only for async server. Number of threads used to serve the requests.AsyncServerThreadsint32 `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 desiredCoreLimitint32 `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 desiredCoreList []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 detailOtherServerApistring `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"`// Number of threads that share each completion queueThreadsPerCqint32 `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)ResourceQuotaSizeint32         `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.ServerProcessesint32 `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"`// contains filtered or unexported fields}

func (*ServerConfig)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

func (*ServerConfig)GetAsyncServerThreadsadded inv1.35.0

func (x *ServerConfig) GetAsyncServerThreads()int32

func (*ServerConfig)GetChannelArgsadded inv1.35.0

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

func (*ServerConfig)GetCoreLimitadded inv1.35.0

func (x *ServerConfig) GetCoreLimit()int32

func (*ServerConfig)GetCoreListadded inv1.35.0

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

func (*ServerConfig)GetOtherServerApiadded inv1.35.0

func (x *ServerConfig) GetOtherServerApi()string

func (*ServerConfig)GetPayloadConfigadded inv1.35.0

func (x *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig)GetPortadded inv1.35.0

func (x *ServerConfig) GetPort()int32

func (*ServerConfig)GetResourceQuotaSizeadded inv1.35.0

func (x *ServerConfig) GetResourceQuotaSize()int32

func (*ServerConfig)GetSecurityParamsadded inv1.35.0

func (x *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig)GetServerProcessesadded inv1.35.0

func (x *ServerConfig) GetServerProcesses()int32

func (*ServerConfig)GetServerTypeadded inv1.35.0

func (x *ServerConfig) GetServerType()ServerType

func (*ServerConfig)GetThreadsPerCqadded inv1.35.0

func (x *ServerConfig) GetThreadsPerCq()int32

func (*ServerConfig)ProtoMessageadded inv1.35.0

func (*ServerConfig) ProtoMessage()

func (*ServerConfig)ProtoReflectadded inv1.35.0

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

func (*ServerConfig)Resetadded inv1.35.0

func (x *ServerConfig) Reset()

func (*ServerConfig)Stringadded inv1.35.0

func (x *ServerConfig) String()string

typeServerStatsadded inv1.35.0

type ServerStats struct {// wall clock time change in seconds since last resetTimeElapsedfloat64 `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 resetTimeUserfloat64 `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 resetTimeSystemfloat64 `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)TotalCpuTimeuint64 `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)IdleCpuTimeuint64 `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"`// Number of polls called inside completion queueCqPollCountuint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`// Core library statsCoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`// contains filtered or unexported fields}

func (*ServerStats)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.

func (*ServerStats)GetCoreStatsadded inv1.35.0

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

func (*ServerStats)GetCqPollCountadded inv1.35.0

func (x *ServerStats) GetCqPollCount()uint64

func (*ServerStats)GetIdleCpuTimeadded inv1.35.0

func (x *ServerStats) GetIdleCpuTime()uint64

func (*ServerStats)GetTimeElapsedadded inv1.35.0

func (x *ServerStats) GetTimeElapsed()float64

func (*ServerStats)GetTimeSystemadded inv1.35.0

func (x *ServerStats) GetTimeSystem()float64

func (*ServerStats)GetTimeUseradded inv1.35.0

func (x *ServerStats) GetTimeUser()float64

func (*ServerStats)GetTotalCpuTimeadded inv1.35.0

func (x *ServerStats) GetTotalCpuTime()uint64

func (*ServerStats)ProtoMessageadded inv1.35.0

func (*ServerStats) ProtoMessage()

func (*ServerStats)ProtoReflectadded inv1.35.0

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

func (*ServerStats)Resetadded inv1.35.0

func (x *ServerStats) Reset()

func (*ServerStats)Stringadded inv1.35.0

func (x *ServerStats) String()string

typeServerStatusadded inv1.35.0

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

func (*ServerStatus)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.

func (*ServerStatus)GetCoresadded inv1.35.0

func (x *ServerStatus) GetCores()int32

func (*ServerStatus)GetPortadded inv1.35.0

func (x *ServerStatus) GetPort()int32

func (*ServerStatus)GetStatsadded inv1.35.0

func (x *ServerStatus) GetStats() *ServerStats

func (*ServerStatus)ProtoMessageadded inv1.35.0

func (*ServerStatus) ProtoMessage()

func (*ServerStatus)ProtoReflectadded inv1.35.0

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

func (*ServerStatus)Resetadded inv1.35.0

func (x *ServerStatus) Reset()

func (*ServerStatus)Stringadded inv1.35.0

func (x *ServerStatus) String()string

typeServerTypeadded inv1.35.0

type ServerTypeint32
const (ServerType_SYNC_SERVERServerType = 0ServerType_ASYNC_SERVERServerType = 1ServerType_ASYNC_GENERIC_SERVERServerType = 2ServerType_OTHER_SERVERServerType = 3// used for some language-specific variantsServerType_CALLBACK_SERVERServerType = 4)

func (ServerType)Descriptoradded inv1.35.0

func (ServerType)Enumadded inv1.35.0

func (xServerType) Enum() *ServerType

func (ServerType)EnumDescriptordeprecatedadded inv1.35.0

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

Deprecated: Use ServerType.Descriptor instead.

func (ServerType)Numberadded inv1.35.0

func (ServerType)Stringadded inv1.35.0

func (xServerType) String()string

func (ServerType)Typeadded inv1.35.0

typeSetReturnStatusRequestadded inv1.59.0

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

Status that will be return to callers of the Hook method

func (*SetReturnStatusRequest)Descriptordeprecatedadded inv1.59.0

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

Deprecated: Use SetReturnStatusRequest.ProtoReflect.Descriptor instead.

func (*SetReturnStatusRequest)GetGrpcCodeToReturnadded inv1.59.0

func (x *SetReturnStatusRequest) GetGrpcCodeToReturn()int32

func (*SetReturnStatusRequest)GetGrpcStatusDescriptionadded inv1.59.0

func (x *SetReturnStatusRequest) GetGrpcStatusDescription()string

func (*SetReturnStatusRequest)ProtoMessageadded inv1.59.0

func (*SetReturnStatusRequest) ProtoMessage()

func (*SetReturnStatusRequest)ProtoReflectadded inv1.59.0

func (*SetReturnStatusRequest)Resetadded inv1.59.0

func (x *SetReturnStatusRequest) Reset()

func (*SetReturnStatusRequest)Stringadded inv1.59.0

func (x *SetReturnStatusRequest) String()string

typeSimpleProtoParamsadded inv1.35.0

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

func (*SimpleProtoParams)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.

func (*SimpleProtoParams)GetReqSizeadded inv1.35.0

func (x *SimpleProtoParams) GetReqSize()int32

func (*SimpleProtoParams)GetRespSizeadded inv1.35.0

func (x *SimpleProtoParams) GetRespSize()int32

func (*SimpleProtoParams)ProtoMessageadded inv1.35.0

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams)ProtoReflectadded inv1.35.0

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

func (*SimpleProtoParams)Resetadded inv1.35.0

func (x *SimpleProtoParams) Reset()

func (*SimpleProtoParams)Stringadded inv1.35.0

func (x *SimpleProtoParams) String()string

typeSimpleRequest

type SimpleRequest struct {// Desired payload type in the response from the server.// If response_type is RANDOM, server randomly chooses one from other formats.ResponseTypePayloadType ``/* 128-byte string literal not displayed */// Desired payload size in the response from the server.ResponseSizeint32 `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.FillUsernamebool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`// Whether SimpleResponse should include OAuth scope.FillOauthScopebool `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 statusResponseStatus *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.FillServerIdbool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`// Whether SimpleResponse should include grpclb_route_type.FillGrpclbRouteTypebool `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)Descriptordeprecated

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

func (*SimpleRequest)GetExpectCompressedadded inv1.35.0

func (x *SimpleRequest) GetExpectCompressed() *BoolValue

func (*SimpleRequest)GetFillGrpclbRouteTypeadded inv1.26.0

func (x *SimpleRequest) GetFillGrpclbRouteType()bool

func (*SimpleRequest)GetFillOauthScope

func (x *SimpleRequest) GetFillOauthScope()bool

func (*SimpleRequest)GetFillServerIdadded inv1.21.0

func (x *SimpleRequest) GetFillServerId()bool

func (*SimpleRequest)GetFillUsername

func (x *SimpleRequest) GetFillUsername()bool

func (*SimpleRequest)GetOrcaPerQueryReportadded inv1.48.0

func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport

func (*SimpleRequest)GetPayload

func (x *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest)GetResponseCompressedadded inv1.35.0

func (x *SimpleRequest) GetResponseCompressed() *BoolValue

func (*SimpleRequest)GetResponseSize

func (x *SimpleRequest) GetResponseSize()int32

func (*SimpleRequest)GetResponseStatusadded inv1.0.3

func (x *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest)GetResponseType

func (x *SimpleRequest) GetResponseType()PayloadType

func (*SimpleRequest)ProtoMessage

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest)ProtoReflectadded inv1.33.2

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

func (*SimpleRequest)Reset

func (x *SimpleRequest) Reset()

func (*SimpleRequest)String

func (x *SimpleRequest) String()string

typeSimpleResponse

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.Usernamestring `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`// OAuth scope.OauthScopestring `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.ServerIdstring `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`// gRPCLB Path.GrpclbRouteTypeGrpclbRouteType ``/* 143-byte string literal not displayed */// Server hostname.Hostnamestring `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`// contains filtered or unexported fields}

Unary response, as configured by the request.

func (*SimpleResponse)Descriptordeprecated

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse)GetGrpclbRouteTypeadded inv1.26.0

func (x *SimpleResponse) GetGrpclbRouteType()GrpclbRouteType

func (*SimpleResponse)GetHostnameadded inv1.28.0

func (x *SimpleResponse) GetHostname()string

func (*SimpleResponse)GetOauthScope

func (x *SimpleResponse) GetOauthScope()string

func (*SimpleResponse)GetPayload

func (x *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse)GetServerIdadded inv1.21.0

func (x *SimpleResponse) GetServerId()string

func (*SimpleResponse)GetUsername

func (x *SimpleResponse) GetUsername()string

func (*SimpleResponse)ProtoMessage

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse)ProtoReflectadded inv1.33.2

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

func (*SimpleResponse)Reset

func (x *SimpleResponse) Reset()

func (*SimpleResponse)String

func (x *SimpleResponse) String()string

typeStreamingInputCallRequest

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

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

Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingInputCallRequest)GetExpectCompressedadded inv1.35.0

func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

func (*StreamingInputCallRequest)GetPayload

func (x *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest)ProtoMessage

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest)ProtoReflectadded inv1.33.2

func (*StreamingInputCallRequest)Reset

func (x *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest)String

typeStreamingInputCallResponse

type StreamingInputCallResponse struct {// Aggregated size of payloads received from the client.AggregatedPayloadSizeint32 ``/* 127-byte string literal not displayed */// contains filtered or unexported fields}

Client-streaming response.

func (*StreamingInputCallResponse)Descriptordeprecated

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)ProtoReflectadded inv1.33.2

func (*StreamingInputCallResponse)Reset

func (x *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse)String

typeStreamingOutputCallRequest

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.ResponseTypePayloadType ``/* 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 statusResponseStatus *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)Descriptordeprecated

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

Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallRequest)GetOrcaOobReportadded inv1.48.0

func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport

func (*StreamingOutputCallRequest)GetPayload

func (x *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest)GetResponseParameters

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

func (*StreamingOutputCallRequest)GetResponseStatusadded inv1.0.3

func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest)GetResponseType

func (x *StreamingOutputCallRequest) GetResponseType()PayloadType

func (*StreamingOutputCallRequest)ProtoMessage

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest)ProtoReflectadded inv1.33.2

func (*StreamingOutputCallRequest)Reset

func (x *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest)String

typeStreamingOutputCallResponse

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

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)ProtoReflectadded inv1.33.2

func (*StreamingOutputCallResponse)Reset

func (x *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse)String

typeTestOrcaReportadded inv1.48.0

type TestOrcaReport struct {CpuUtilizationfloat64            `protobuf:"fixed64,1,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"`MemoryUtilizationfloat64            `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 reporthttps://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)Descriptordeprecatedadded inv1.48.0

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

Deprecated: Use TestOrcaReport.ProtoReflect.Descriptor instead.

func (*TestOrcaReport)GetCpuUtilizationadded inv1.48.0

func (x *TestOrcaReport) GetCpuUtilization()float64

func (*TestOrcaReport)GetMemoryUtilizationadded inv1.48.0

func (x *TestOrcaReport) GetMemoryUtilization()float64

func (*TestOrcaReport)GetRequestCostadded inv1.48.0

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

func (*TestOrcaReport)GetUtilizationadded inv1.48.0

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

func (*TestOrcaReport)ProtoMessageadded inv1.48.0

func (*TestOrcaReport) ProtoMessage()

func (*TestOrcaReport)ProtoReflectadded inv1.48.0

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

func (*TestOrcaReport)Resetadded inv1.48.0

func (x *TestOrcaReport) Reset()

func (*TestOrcaReport)Stringadded inv1.48.0

func (x *TestOrcaReport) String()string

typeTestServiceClient

type TestServiceClient interface {// One empty request followed by one empty response.EmptyCall(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)// One request followed by one response.UnaryCall(ctxcontext.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse,error)// One request followed by one response. Response has cache control// headers set such that a caching HTTP proxy (such as GFE) can// satisfy subsequent requests.CacheableUnaryCall(ctxcontext.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse,error)// One request followed by a sequence of responses (streamed download).// The server returns the payload with client desired type and sizes.StreamingOutputCall(ctxcontext.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamingOutputCallResponse],error)// A sequence of requests followed by one response (streamed upload).// The server returns the aggregated size of client payload as the result.StreamingInputCall(ctxcontext.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StreamingInputCallRequest,StreamingInputCallResponse],error)// A sequence of requests with each request served by the server immediately.// As one request could lead to multiple responses, this interface// demonstrates the idea of full duplexing.FullDuplexCall(ctxcontext.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamingOutputCallRequest,StreamingOutputCallResponse],error)// A sequence of requests followed by a sequence of responses.// The server buffers all the client requests and then serves them in order. A// stream of responses are returned to the client when the server starts with// first request.HalfDuplexCall(ctxcontext.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamingOutputCallRequest,StreamingOutputCallResponse],error)// The test server will not implement this method. It will be used// to test the behavior when clients call unimplemented methods.UnimplementedCall(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)}

TestServiceClient is the client API for TestService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A simple service to test the various types of RPCs and experiment withperformance with various types of payload.

typeTestServiceServer

type TestServiceServer interface {// One empty request followed by one empty response.EmptyCall(context.Context, *Empty) (*Empty,error)// One request followed by one response.UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse,error)// One request followed by one response. Response has cache control// headers set such that a caching HTTP proxy (such as GFE) can// satisfy subsequent requests.CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse,error)// One request followed by a sequence of responses (streamed download).// The server returns the payload with client desired type and sizes.StreamingOutputCall(*StreamingOutputCallRequest,grpc.ServerStreamingServer[StreamingOutputCallResponse])error// A sequence of requests followed by one response (streamed upload).// The server returns the aggregated size of client payload as the result.StreamingInputCall(grpc.ClientStreamingServer[StreamingInputCallRequest,StreamingInputCallResponse])error// A sequence of requests with each request served by the server immediately.// As one request could lead to multiple responses, this interface// demonstrates the idea of full duplexing.FullDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest,StreamingOutputCallResponse])error// A sequence of requests followed by a sequence of responses.// The server buffers all the client requests and then serves them in order. A// stream of responses are returned to the client when the server starts with// first request.HalfDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest,StreamingOutputCallResponse])error// The test server will not implement this method. It will be used// to test the behavior when clients call unimplemented methods.UnimplementedCall(context.Context, *Empty) (*Empty,error)// contains filtered or unexported methods}

TestServiceServer is the server API for TestService service.All implementations must embed UnimplementedTestServiceServerfor forward compatibility.

A simple service to test the various types of RPCs and experiment withperformance with various types of payload.

typeTestService_FullDuplexCallClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_FullDuplexCallServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_HalfDuplexCallClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_HalfDuplexCallServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_StreamingInputCallClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_StreamingInputCallServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_StreamingOutputCallClient

type TestService_StreamingOutputCallClient =grpc.ServerStreamingClient[StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeTestService_StreamingOutputCallServer

type TestService_StreamingOutputCallServer =grpc.ServerStreamingServer[StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeUnimplementedBenchmarkServiceServeradded inv1.35.0

type UnimplementedBenchmarkServiceServer struct{}

UnimplementedBenchmarkServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedBenchmarkServiceServer)StreamingBothWaysadded inv1.35.0

func (UnimplementedBenchmarkServiceServer)StreamingCalladded inv1.35.0

func (UnimplementedBenchmarkServiceServer)StreamingFromClientadded inv1.35.0

func (UnimplementedBenchmarkServiceServer)StreamingFromServeradded inv1.35.0

func (UnimplementedBenchmarkServiceServer)UnaryCalladded inv1.35.0

typeUnimplementedHookServiceServeradded inv1.58.0

type UnimplementedHookServiceServer struct{}

UnimplementedHookServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedHookServiceServer)ClearReturnStatusadded inv1.59.0

func (UnimplementedHookServiceServer)Hookadded inv1.58.0

func (UnimplementedHookServiceServer)SetReturnStatusadded inv1.59.0

typeUnimplementedLoadBalancerStatsServiceServeradded inv1.28.0

type UnimplementedLoadBalancerStatsServiceServer struct{}

UnimplementedLoadBalancerStatsServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedLoadBalancerStatsServiceServer)GetClientAccumulatedStatsadded inv1.35.0

func (UnimplementedLoadBalancerStatsServiceServer)GetClientStatsadded inv1.28.0

typeUnimplementedReconnectServiceServeradded inv1.35.0

type UnimplementedReconnectServiceServer struct{}

UnimplementedReconnectServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedReconnectServiceServer)Startadded inv1.35.0

func (UnimplementedReconnectServiceServer)Stopadded inv1.35.0

typeUnimplementedReportQpsScenarioServiceServeradded inv1.35.0

type UnimplementedReportQpsScenarioServiceServer struct{}

UnimplementedReportQpsScenarioServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedReportQpsScenarioServiceServer)ReportScenarioadded inv1.35.0

typeUnimplementedServiceClientadded inv1.0.5

type UnimplementedServiceClient interface {// A call that no server should implementUnimplementedCall(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)}

UnimplementedServiceClient is the client API for UnimplementedService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A simple service NOT implemented at servers so clients can test forthat case.

funcNewUnimplementedServiceClientadded inv1.0.5

func NewUnimplementedServiceClient(ccgrpc.ClientConnInterface)UnimplementedServiceClient

typeUnimplementedServiceServeradded inv1.0.5

type UnimplementedServiceServer interface {// A call that no server should implementUnimplementedCall(context.Context, *Empty) (*Empty,error)// contains filtered or unexported methods}

UnimplementedServiceServer is the server API for UnimplementedService service.All implementations must embed UnimplementedUnimplementedServiceServerfor forward compatibility.

A simple service NOT implemented at servers so clients can test forthat case.

typeUnimplementedTestServiceServeradded inv1.24.0

type UnimplementedTestServiceServer struct{}

UnimplementedTestServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedTestServiceServer)CacheableUnaryCalladded inv1.35.0

func (UnimplementedTestServiceServer)EmptyCalladded inv1.24.0

func (UnimplementedTestServiceServer)UnaryCalladded inv1.24.0

func (UnimplementedTestServiceServer)UnimplementedCalladded inv1.35.0

typeUnimplementedUnimplementedServiceServeradded inv1.24.0

type UnimplementedUnimplementedServiceServer struct{}

UnimplementedUnimplementedServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedUnimplementedServiceServer)UnimplementedCalladded inv1.24.0

typeUnimplementedWorkerServiceServeradded inv1.35.0

type UnimplementedWorkerServiceServer struct{}

UnimplementedWorkerServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedWorkerServiceServer)CoreCountadded inv1.35.0

func (UnimplementedWorkerServiceServer)QuitWorkeradded inv1.35.0

func (UnimplementedWorkerServiceServer)RunClientadded inv1.35.0

func (UnimplementedWorkerServiceServer)RunServeradded inv1.35.0

typeUnimplementedXdsUpdateClientConfigureServiceServeradded inv1.35.0

type UnimplementedXdsUpdateClientConfigureServiceServer struct{}

UnimplementedXdsUpdateClientConfigureServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedXdsUpdateClientConfigureServiceServer)Configureadded inv1.35.0

typeUnimplementedXdsUpdateHealthServiceServeradded inv1.35.0

type UnimplementedXdsUpdateHealthServiceServer struct{}

UnimplementedXdsUpdateHealthServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedXdsUpdateHealthServiceServer)SendHookRequestadded inv1.58.0

func (UnimplementedXdsUpdateHealthServiceServer)SetNotServingadded inv1.35.0

func (UnimplementedXdsUpdateHealthServiceServer)SetServingadded inv1.35.0

typeUnsafeBenchmarkServiceServeradded inv1.35.0

type UnsafeBenchmarkServiceServer interface {// contains filtered or unexported methods}

UnsafeBenchmarkServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to BenchmarkServiceServer willresult in compilation errors.

typeUnsafeHookServiceServeradded inv1.58.0

type UnsafeHookServiceServer interface {// contains filtered or unexported methods}

UnsafeHookServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to HookServiceServer willresult in compilation errors.

typeUnsafeLoadBalancerStatsServiceServeradded inv1.33.0

type UnsafeLoadBalancerStatsServiceServer interface {// contains filtered or unexported methods}

UnsafeLoadBalancerStatsServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to LoadBalancerStatsServiceServer willresult in compilation errors.

typeUnsafeReconnectServiceServeradded inv1.35.0

type UnsafeReconnectServiceServer interface {// contains filtered or unexported methods}

UnsafeReconnectServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to ReconnectServiceServer willresult in compilation errors.

typeUnsafeReportQpsScenarioServiceServeradded inv1.35.0

type UnsafeReportQpsScenarioServiceServer interface {// contains filtered or unexported methods}

UnsafeReportQpsScenarioServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to ReportQpsScenarioServiceServer willresult in compilation errors.

typeUnsafeTestServiceServeradded inv1.33.0

type UnsafeTestServiceServer interface {// contains filtered or unexported methods}

UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to TestServiceServer willresult in compilation errors.

typeUnsafeUnimplementedServiceServeradded inv1.33.0

type UnsafeUnimplementedServiceServer interface {// contains filtered or unexported methods}

UnsafeUnimplementedServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to UnimplementedServiceServer willresult in compilation errors.

typeUnsafeWorkerServiceServeradded inv1.35.0

type UnsafeWorkerServiceServer interface {// contains filtered or unexported methods}

UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to WorkerServiceServer willresult in compilation errors.

typeUnsafeXdsUpdateClientConfigureServiceServeradded inv1.35.0

type UnsafeXdsUpdateClientConfigureServiceServer interface {// contains filtered or unexported methods}

UnsafeXdsUpdateClientConfigureServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to XdsUpdateClientConfigureServiceServer willresult in compilation errors.

typeUnsafeXdsUpdateHealthServiceServeradded inv1.35.0

type UnsafeXdsUpdateHealthServiceServer interface {// contains filtered or unexported methods}

UnsafeXdsUpdateHealthServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to XdsUpdateHealthServiceServer willresult in compilation errors.

typeVoidadded inv1.35.0

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

func (*Void)Descriptordeprecatedadded inv1.35.0

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void)ProtoMessageadded inv1.35.0

func (*Void) ProtoMessage()

func (*Void)ProtoReflectadded inv1.35.0

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

func (*Void)Resetadded inv1.35.0

func (x *Void) Reset()

func (*Void)Stringadded inv1.35.0

func (x *Void) String()string

typeWorkerServiceClientadded inv1.35.0

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

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

funcNewWorkerServiceClientadded inv1.35.0

func NewWorkerServiceClient(ccgrpc.ClientConnInterface)WorkerServiceClient

typeWorkerServiceServeradded inv1.35.0

type WorkerServiceServer interface {// Start server with specified workload.// First request sent specifies the ServerConfig followed by ServerStatus// response. After that, a "Mark" can be sent anytime to request the latest// stats. Closing the stream will initiate shutdown of the test server// and once the shutdown has finished, the OK status is sent to terminate// this RPC.RunServer(grpc.BidiStreamingServer[ServerArgs,ServerStatus])error// Start client with specified workload.// First request sent specifies the ClientConfig followed by ClientStatus// response. After that, a "Mark" can be sent anytime to request the latest// stats. Closing the stream will initiate shutdown of the test client// and once the shutdown has finished, the OK status is sent to terminate// this RPC.RunClient(grpc.BidiStreamingServer[ClientArgs,ClientStatus])error// Just return the core count - unary callCoreCount(context.Context, *CoreRequest) (*CoreResponse,error)// Quit this workerQuitWorker(context.Context, *Void) (*Void,error)// contains filtered or unexported methods}

WorkerServiceServer is the server API for WorkerService service.All implementations must embed UnimplementedWorkerServiceServerfor forward compatibility.

typeWorkerService_RunClientClientadded inv1.35.0

type WorkerService_RunClientClient =grpc.BidiStreamingClient[ClientArgs,ClientStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeWorkerService_RunClientServeradded inv1.35.0

type WorkerService_RunClientServer =grpc.BidiStreamingServer[ClientArgs,ClientStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeWorkerService_RunServerClientadded inv1.35.0

type WorkerService_RunServerClient =grpc.BidiStreamingClient[ServerArgs,ServerStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeWorkerService_RunServerServeradded inv1.35.0

type WorkerService_RunServerServer =grpc.BidiStreamingServer[ServerArgs,ServerStatus]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeXdsUpdateClientConfigureServiceClientadded inv1.35.0

type XdsUpdateClientConfigureServiceClient interface {// Update the tes client's configuration.Configure(ctxcontext.Context, in *ClientConfigureRequest, opts ...grpc.CallOption) (*ClientConfigureResponse,error)}

XdsUpdateClientConfigureServiceClient is the client API for XdsUpdateClientConfigureService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A service to dynamically update the configuration of an xDS test client.

funcNewXdsUpdateClientConfigureServiceClientadded inv1.35.0

func NewXdsUpdateClientConfigureServiceClient(ccgrpc.ClientConnInterface)XdsUpdateClientConfigureServiceClient

typeXdsUpdateClientConfigureServiceServeradded inv1.35.0

type XdsUpdateClientConfigureServiceServer interface {// Update the tes client's configuration.Configure(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse,error)// contains filtered or unexported methods}

XdsUpdateClientConfigureServiceServer is the server API for XdsUpdateClientConfigureService service.All implementations must embed UnimplementedXdsUpdateClientConfigureServiceServerfor forward compatibility.

A service to dynamically update the configuration of an xDS test client.

typeXdsUpdateHealthServiceClientadded inv1.35.0

type XdsUpdateHealthServiceClient interface {SetServing(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)SetNotServing(ctxcontext.Context, in *Empty, opts ...grpc.CallOption) (*Empty,error)SendHookRequest(ctxcontext.Context, in *HookRequest, opts ...grpc.CallOption) (*HookResponse,error)}

XdsUpdateHealthServiceClient is the client API for XdsUpdateHealthService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A service to remotely control health status of an xDS test server.

funcNewXdsUpdateHealthServiceClientadded inv1.35.0

func NewXdsUpdateHealthServiceClient(ccgrpc.ClientConnInterface)XdsUpdateHealthServiceClient

typeXdsUpdateHealthServiceServeradded inv1.35.0

type XdsUpdateHealthServiceServer interface {SetServing(context.Context, *Empty) (*Empty,error)SetNotServing(context.Context, *Empty) (*Empty,error)SendHookRequest(context.Context, *HookRequest) (*HookResponse,error)// contains filtered or unexported methods}

XdsUpdateHealthServiceServer is the server API for XdsUpdateHealthService service.All implementations must embed UnimplementedXdsUpdateHealthServiceServerfor forward compatibility.

A service to remotely control health status of an xDS test server.

Source Files

View all Source files

Directories

PathSynopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f orF : Jump to
y orY : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic.Learn more.
[8]ページ先頭
©2009-2025 Movatter.jp