Versions in this module Expand all Collapse all v0 v0.0.2 Oct 15, 2024 Changes in this version + const BenchmarkService_StreamingBothWays_FullMethodName + const BenchmarkService_StreamingCall_FullMethodName + const BenchmarkService_StreamingFromClient_FullMethodName + const BenchmarkService_StreamingFromServer_FullMethodName + const BenchmarkService_UnaryCall_FullMethodName + const HookService_ClearReturnStatus_FullMethodName + const HookService_Hook_FullMethodName + const HookService_SetReturnStatus_FullMethodName + const LoadBalancerStatsService_GetClientAccumulatedStats_FullMethodName + const LoadBalancerStatsService_GetClientStats_FullMethodName + const ReconnectService_Start_FullMethodName + const ReconnectService_Stop_FullMethodName + const ReportQpsScenarioService_ReportScenario_FullMethodName + const TestService_CacheableUnaryCall_FullMethodName + const TestService_EmptyCall_FullMethodName + const TestService_FullDuplexCall_FullMethodName + const TestService_HalfDuplexCall_FullMethodName + const TestService_StreamingInputCall_FullMethodName + const TestService_StreamingOutputCall_FullMethodName + const TestService_UnaryCall_FullMethodName + const TestService_UnimplementedCall_FullMethodName + const UnimplementedService_UnimplementedCall_FullMethodName + const WorkerService_CoreCount_FullMethodName + const WorkerService_QuitWorker_FullMethodName + const WorkerService_RunClient_FullMethodName + const WorkerService_RunServer_FullMethodName + const XdsUpdateClientConfigureService_Configure_FullMethodName + const XdsUpdateHealthService_SendHookRequest_FullMethodName + const XdsUpdateHealthService_SetNotServing_FullMethodName + const XdsUpdateHealthService_SetServing_FullMethodName + var BenchmarkService_ServiceDesc = grpc.ServiceDesc + var ClientConfigureRequest_RpcType_name = map[int32]string + var ClientConfigureRequest_RpcType_value = map[string]int32 + var ClientType_name = map[int32]string + var ClientType_value = map[string]int32 + var File_grpc_testing_benchmark_service_proto protoreflect.FileDescriptor + var File_grpc_testing_control_proto protoreflect.FileDescriptor + var File_grpc_testing_empty_proto protoreflect.FileDescriptor + var File_grpc_testing_messages_proto protoreflect.FileDescriptor + var File_grpc_testing_payloads_proto protoreflect.FileDescriptor + var File_grpc_testing_report_qps_scenario_service_proto protoreflect.FileDescriptor + var File_grpc_testing_stats_proto protoreflect.FileDescriptor + var File_grpc_testing_test_proto protoreflect.FileDescriptor + var File_grpc_testing_worker_service_proto protoreflect.FileDescriptor + var GrpclbRouteType_name = map[int32]string + var GrpclbRouteType_value = map[string]int32 + var HookRequest_HookRequestCommand_name = map[int32]string + var HookRequest_HookRequestCommand_value = map[string]int32 + var HookService_ServiceDesc = grpc.ServiceDesc + var LoadBalancerStatsResponse_MetadataType_name = map[int32]string + var LoadBalancerStatsResponse_MetadataType_value = map[string]int32 + var LoadBalancerStatsService_ServiceDesc = grpc.ServiceDesc + var PayloadType_name = map[int32]string + var PayloadType_value = map[string]int32 + var ReconnectService_ServiceDesc = grpc.ServiceDesc + var ReportQpsScenarioService_ServiceDesc = grpc.ServiceDesc + var RpcType_name = map[int32]string + var RpcType_value = map[string]int32 + var ServerType_name = map[int32]string + var ServerType_value = map[string]int32 + var TestService_ServiceDesc = grpc.ServiceDesc + var UnimplementedService_ServiceDesc = grpc.ServiceDesc + var WorkerService_ServiceDesc = grpc.ServiceDesc + var XdsUpdateClientConfigureService_ServiceDesc = grpc.ServiceDesc + var XdsUpdateHealthService_ServiceDesc = grpc.ServiceDesc + func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer) + func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer) + func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer) + func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer) + func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer) + func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer) + func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer) + func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer) + func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer) + func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer) + type BenchmarkServiceClient interface + StreamingBothWays func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest, SimpleResponse], error) + StreamingCall func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SimpleRequest, SimpleResponse], error) + StreamingFromClient func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SimpleRequest, SimpleResponse], error) + StreamingFromServer func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SimpleResponse], error) + UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient + type BenchmarkServiceServer interface + StreamingBothWays func(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error + StreamingCall func(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error + StreamingFromClient func(grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]) error + StreamingFromServer func(*SimpleRequest, grpc.ServerStreamingServer[SimpleResponse]) error + UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + type BenchmarkService_StreamingBothWaysClient = grpc.BidiStreamingClient[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingBothWaysServer = grpc.BidiStreamingServer[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingCallClient = grpc.BidiStreamingClient[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingCallServer = grpc.BidiStreamingServer[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingFromClientClient = grpc.ClientStreamingClient[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingFromClientServer = grpc.ClientStreamingServer[SimpleRequest, SimpleResponse] + type BenchmarkService_StreamingFromServerClient = grpc.ServerStreamingClient[SimpleResponse] + type BenchmarkService_StreamingFromServerServer = grpc.ServerStreamingServer[SimpleResponse] + type BoolValue struct + Value bool + func (*BoolValue) Descriptor() ([]byte, []int) + func (*BoolValue) ProtoMessage() + func (x *BoolValue) GetValue() bool + func (x *BoolValue) ProtoReflect() protoreflect.Message + func (x *BoolValue) Reset() + func (x *BoolValue) String() string + type ByteBufferParams struct + ReqSize int32 + RespSize int32 + func (*ByteBufferParams) Descriptor() ([]byte, []int) + func (*ByteBufferParams) ProtoMessage() + func (x *ByteBufferParams) GetReqSize() int32 + func (x *ByteBufferParams) GetRespSize() int32 + func (x *ByteBufferParams) ProtoReflect() protoreflect.Message + func (x *ByteBufferParams) Reset() + func (x *ByteBufferParams) String() string + type ChannelArg struct + Name string + Value isChannelArg_Value + func (*ChannelArg) Descriptor() ([]byte, []int) + func (*ChannelArg) ProtoMessage() + func (m *ChannelArg) GetValue() isChannelArg_Value + func (x *ChannelArg) GetIntValue() int32 + func (x *ChannelArg) GetName() string + func (x *ChannelArg) GetStrValue() string + func (x *ChannelArg) ProtoReflect() protoreflect.Message + func (x *ChannelArg) Reset() + func (x *ChannelArg) String() string + type ChannelArg_IntValue struct + IntValue int32 + type ChannelArg_StrValue struct + StrValue string + type ClientArgs struct + Argtype isClientArgs_Argtype + func (*ClientArgs) Descriptor() ([]byte, []int) + func (*ClientArgs) ProtoMessage() + func (m *ClientArgs) GetArgtype() isClientArgs_Argtype + func (x *ClientArgs) GetMark() *Mark + func (x *ClientArgs) GetSetup() *ClientConfig + func (x *ClientArgs) ProtoReflect() protoreflect.Message + func (x *ClientArgs) Reset() + func (x *ClientArgs) String() string + type ClientArgs_Mark struct + Mark *Mark + type ClientArgs_Setup struct + Setup *ClientConfig + type ClientConfig struct + AsyncClientThreads int32 + ChannelArgs []*ChannelArg + ClientChannels int32 + ClientProcesses int32 + ClientType ClientType + CoreLimit int32 + CoreList []int32 + HistogramParams *HistogramParams + LoadParams *LoadParams + MedianLatencyCollectionIntervalMillis int32 + MessagesPerStream int32 + OtherClientApi string + OutstandingRpcsPerChannel int32 + PayloadConfig *PayloadConfig + RpcType RpcType + SecurityParams *SecurityParams + ServerTargets []string + ThreadsPerCq int32 + UseCoalesceApi bool + func (*ClientConfig) Descriptor() ([]byte, []int) + func (*ClientConfig) ProtoMessage() + func (x *ClientConfig) GetAsyncClientThreads() int32 + func (x *ClientConfig) GetChannelArgs() []*ChannelArg + func (x *ClientConfig) GetClientChannels() int32 + func (x *ClientConfig) GetClientProcesses() int32 + func (x *ClientConfig) GetClientType() ClientType + func (x *ClientConfig) GetCoreLimit() int32 + func (x *ClientConfig) GetCoreList() []int32 + func (x *ClientConfig) GetHistogramParams() *HistogramParams + func (x *ClientConfig) GetLoadParams() *LoadParams + func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32 + func (x *ClientConfig) GetMessagesPerStream() int32 + func (x *ClientConfig) GetOtherClientApi() string + func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32 + func (x *ClientConfig) GetPayloadConfig() *PayloadConfig + func (x *ClientConfig) GetRpcType() RpcType + func (x *ClientConfig) GetSecurityParams() *SecurityParams + func (x *ClientConfig) GetServerTargets() []string + func (x *ClientConfig) GetThreadsPerCq() int32 + func (x *ClientConfig) GetUseCoalesceApi() bool + func (x *ClientConfig) ProtoReflect() protoreflect.Message + func (x *ClientConfig) Reset() + func (x *ClientConfig) String() string + type ClientConfigureRequest struct + Metadata []*ClientConfigureRequest_Metadata + TimeoutSec int32 + Types []ClientConfigureRequest_RpcType + func (*ClientConfigureRequest) Descriptor() ([]byte, []int) + func (*ClientConfigureRequest) ProtoMessage() + func (x *ClientConfigureRequest) GetMetadata() []*ClientConfigureRequest_Metadata + func (x *ClientConfigureRequest) GetTimeoutSec() int32 + func (x *ClientConfigureRequest) GetTypes() []ClientConfigureRequest_RpcType + func (x *ClientConfigureRequest) ProtoReflect() protoreflect.Message + func (x *ClientConfigureRequest) Reset() + func (x *ClientConfigureRequest) String() string + type ClientConfigureRequest_Metadata struct + Key string + Type ClientConfigureRequest_RpcType + Value string + func (*ClientConfigureRequest_Metadata) Descriptor() ([]byte, []int) + func (*ClientConfigureRequest_Metadata) ProtoMessage() + func (x *ClientConfigureRequest_Metadata) GetKey() string + func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType + func (x *ClientConfigureRequest_Metadata) GetValue() string + func (x *ClientConfigureRequest_Metadata) ProtoReflect() protoreflect.Message + func (x *ClientConfigureRequest_Metadata) Reset() + func (x *ClientConfigureRequest_Metadata) String() string + type ClientConfigureRequest_RpcType int32 + const ClientConfigureRequest_EMPTY_CALL + const ClientConfigureRequest_UNARY_CALL + func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor + func (ClientConfigureRequest_RpcType) EnumDescriptor() ([]byte, []int) + func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType + func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType + func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber + func (x ClientConfigureRequest_RpcType) String() string + type ClientConfigureResponse struct + func (*ClientConfigureResponse) Descriptor() ([]byte, []int) + func (*ClientConfigureResponse) ProtoMessage() + func (x *ClientConfigureResponse) ProtoReflect() protoreflect.Message + func (x *ClientConfigureResponse) Reset() + func (x *ClientConfigureResponse) String() string + type ClientStats struct + CoreStats *core.Stats + CqPollCount uint64 + Latencies *HistogramData + RequestResults []*RequestResultCount + TimeElapsed float64 + TimeSystem float64 + TimeUser float64 + func (*ClientStats) Descriptor() ([]byte, []int) + func (*ClientStats) ProtoMessage() + func (x *ClientStats) GetCoreStats() *core.Stats + func (x *ClientStats) GetCqPollCount() uint64 + func (x *ClientStats) GetLatencies() *HistogramData + func (x *ClientStats) GetRequestResults() []*RequestResultCount + func (x *ClientStats) GetTimeElapsed() float64 + func (x *ClientStats) GetTimeSystem() float64 + func (x *ClientStats) GetTimeUser() float64 + func (x *ClientStats) ProtoReflect() protoreflect.Message + func (x *ClientStats) Reset() + func (x *ClientStats) String() string + type ClientStatus struct + Stats *ClientStats + func (*ClientStatus) Descriptor() ([]byte, []int) + func (*ClientStatus) ProtoMessage() + func (x *ClientStatus) GetStats() *ClientStats + func (x *ClientStatus) ProtoReflect() protoreflect.Message + func (x *ClientStatus) Reset() + func (x *ClientStatus) String() string + type ClientType int32 + const ClientType_ASYNC_CLIENT + const ClientType_CALLBACK_CLIENT + const ClientType_OTHER_CLIENT + const ClientType_SYNC_CLIENT + func (ClientType) Descriptor() protoreflect.EnumDescriptor + func (ClientType) EnumDescriptor() ([]byte, []int) + func (ClientType) Type() protoreflect.EnumType + func (x ClientType) Enum() *ClientType + func (x ClientType) Number() protoreflect.EnumNumber + func (x ClientType) String() string + type ClosedLoopParams struct + func (*ClosedLoopParams) Descriptor() ([]byte, []int) + func (*ClosedLoopParams) ProtoMessage() + func (x *ClosedLoopParams) ProtoReflect() protoreflect.Message + func (x *ClosedLoopParams) Reset() + func (x *ClosedLoopParams) String() string + type ComplexProtoParams struct + func (*ComplexProtoParams) Descriptor() ([]byte, []int) + func (*ComplexProtoParams) ProtoMessage() + func (x *ComplexProtoParams) ProtoReflect() protoreflect.Message + func (x *ComplexProtoParams) Reset() + func (x *ComplexProtoParams) String() string + type CoreRequest struct + func (*CoreRequest) Descriptor() ([]byte, []int) + func (*CoreRequest) ProtoMessage() + func (x *CoreRequest) ProtoReflect() protoreflect.Message + func (x *CoreRequest) Reset() + func (x *CoreRequest) String() string + type CoreResponse struct + Cores int32 + func (*CoreResponse) Descriptor() ([]byte, []int) + func (*CoreResponse) ProtoMessage() + func (x *CoreResponse) GetCores() int32 + func (x *CoreResponse) ProtoReflect() protoreflect.Message + func (x *CoreResponse) Reset() + func (x *CoreResponse) String() string + type EchoStatus struct + Code int32 + Message string + func (*EchoStatus) Descriptor() ([]byte, []int) + func (*EchoStatus) ProtoMessage() + func (x *EchoStatus) GetCode() int32 + func (x *EchoStatus) GetMessage() string + func (x *EchoStatus) ProtoReflect() protoreflect.Message + func (x *EchoStatus) Reset() + func (x *EchoStatus) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type GrpclbRouteType int32 + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK + const GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN + func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor + func (GrpclbRouteType) EnumDescriptor() ([]byte, []int) + func (GrpclbRouteType) Type() protoreflect.EnumType + func (x GrpclbRouteType) Enum() *GrpclbRouteType + func (x GrpclbRouteType) Number() protoreflect.EnumNumber + func (x GrpclbRouteType) String() string + type HistogramData struct + Bucket []uint32 + Count float64 + MaxSeen float64 + MinSeen float64 + Sum float64 + SumOfSquares float64 + func (*HistogramData) Descriptor() ([]byte, []int) + func (*HistogramData) ProtoMessage() + func (x *HistogramData) GetBucket() []uint32 + func (x *HistogramData) GetCount() float64 + func (x *HistogramData) GetMaxSeen() float64 + func (x *HistogramData) GetMinSeen() float64 + func (x *HistogramData) GetSum() float64 + func (x *HistogramData) GetSumOfSquares() float64 + func (x *HistogramData) ProtoReflect() protoreflect.Message + func (x *HistogramData) Reset() + func (x *HistogramData) String() string + type HistogramParams struct + MaxPossible float64 + Resolution float64 + func (*HistogramParams) Descriptor() ([]byte, []int) + func (*HistogramParams) ProtoMessage() + func (x *HistogramParams) GetMaxPossible() float64 + func (x *HistogramParams) GetResolution() float64 + func (x *HistogramParams) ProtoReflect() protoreflect.Message + func (x *HistogramParams) Reset() + func (x *HistogramParams) String() string + type HookRequest struct + Command HookRequest_HookRequestCommand + GrpcCodeToReturn int32 + GrpcStatusDescription string + ServerPort int32 + func (*HookRequest) Descriptor() ([]byte, []int) + func (*HookRequest) ProtoMessage() + func (x *HookRequest) GetCommand() HookRequest_HookRequestCommand + func (x *HookRequest) GetGrpcCodeToReturn() int32 + func (x *HookRequest) GetGrpcStatusDescription() string + func (x *HookRequest) GetServerPort() int32 + func (x *HookRequest) ProtoReflect() protoreflect.Message + func (x *HookRequest) Reset() + func (x *HookRequest) String() string + type HookRequest_HookRequestCommand int32 + const HookRequest_RETURN + const HookRequest_START + const HookRequest_STOP + const HookRequest_UNSPECIFIED + func (HookRequest_HookRequestCommand) Descriptor() protoreflect.EnumDescriptor + func (HookRequest_HookRequestCommand) EnumDescriptor() ([]byte, []int) + func (HookRequest_HookRequestCommand) Type() protoreflect.EnumType + func (x HookRequest_HookRequestCommand) Enum() *HookRequest_HookRequestCommand + func (x HookRequest_HookRequestCommand) Number() protoreflect.EnumNumber + func (x HookRequest_HookRequestCommand) String() string + type HookResponse struct + func (*HookResponse) Descriptor() ([]byte, []int) + func (*HookResponse) ProtoMessage() + func (x *HookResponse) ProtoReflect() protoreflect.Message + func (x *HookResponse) Reset() + func (x *HookResponse) String() string + type HookServiceClient interface + ClearReturnStatus func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + Hook func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + SetReturnStatus func(ctx context.Context, in *SetReturnStatusRequest, opts ...grpc.CallOption) (*Empty, error) + func NewHookServiceClient(cc grpc.ClientConnInterface) HookServiceClient + type HookServiceServer interface + ClearReturnStatus func(context.Context, *Empty) (*Empty, error) + Hook func(context.Context, *Empty) (*Empty, error) + SetReturnStatus func(context.Context, *SetReturnStatusRequest) (*Empty, error) + type LoadBalancerAccumulatedStatsRequest struct + func (*LoadBalancerAccumulatedStatsRequest) Descriptor() ([]byte, []int) + func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage() + func (x *LoadBalancerAccumulatedStatsRequest) ProtoReflect() protoreflect.Message + func (x *LoadBalancerAccumulatedStatsRequest) Reset() + func (x *LoadBalancerAccumulatedStatsRequest) String() string + type LoadBalancerAccumulatedStatsResponse struct + NumRpcsFailedByMethod map[string]int32 + NumRpcsStartedByMethod map[string]int32 + NumRpcsSucceededByMethod map[string]int32 + StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats + func (*LoadBalancerAccumulatedStatsResponse) Descriptor() ([]byte, []int) + func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage() + func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod() map[string]int32 + func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod() map[string]int32 + func (x *LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod() map[string]int32 + func (x *LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod() map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats + func (x *LoadBalancerAccumulatedStatsResponse) ProtoReflect() protoreflect.Message + func (x *LoadBalancerAccumulatedStatsResponse) Reset() + func (x *LoadBalancerAccumulatedStatsResponse) String() string + type LoadBalancerAccumulatedStatsResponse_MethodStats struct + Result map[int32]int32 + RpcsStarted int32 + func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor() ([]byte, []int) + func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage() + func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult() map[int32]int32 + func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32 + func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect() protoreflect.Message + func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset() + func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string + type LoadBalancerStatsRequest struct + MetadataKeys []string + NumRpcs int32 + TimeoutSec int32 + func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsRequest) ProtoMessage() + func (x *LoadBalancerStatsRequest) GetMetadataKeys() []string + func (x *LoadBalancerStatsRequest) GetNumRpcs() int32 + func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32 + func (x *LoadBalancerStatsRequest) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsRequest) Reset() + func (x *LoadBalancerStatsRequest) String() string + type LoadBalancerStatsResponse struct + MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer + NumFailures int32 + RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer + RpcsByPeer map[string]int32 + func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse) ProtoMessage() + func (x *LoadBalancerStatsResponse) GetMetadatasByPeer() map[string]*LoadBalancerStatsResponse_MetadataByPeer + func (x *LoadBalancerStatsResponse) GetNumFailures() int32 + func (x *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer + func (x *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32 + func (x *LoadBalancerStatsResponse) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsResponse) Reset() + func (x *LoadBalancerStatsResponse) String() string + type LoadBalancerStatsResponse_MetadataByPeer struct + RpcMetadata []*LoadBalancerStatsResponse_RpcMetadata + func (*LoadBalancerStatsResponse_MetadataByPeer) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse_MetadataByPeer) ProtoMessage() + func (x *LoadBalancerStatsResponse_MetadataByPeer) GetRpcMetadata() []*LoadBalancerStatsResponse_RpcMetadata + func (x *LoadBalancerStatsResponse_MetadataByPeer) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsResponse_MetadataByPeer) Reset() + func (x *LoadBalancerStatsResponse_MetadataByPeer) String() string + type LoadBalancerStatsResponse_MetadataEntry struct + Key string + Type LoadBalancerStatsResponse_MetadataType + Value string + func (*LoadBalancerStatsResponse_MetadataEntry) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse_MetadataEntry) ProtoMessage() + func (x *LoadBalancerStatsResponse_MetadataEntry) GetKey() string + func (x *LoadBalancerStatsResponse_MetadataEntry) GetType() LoadBalancerStatsResponse_MetadataType + func (x *LoadBalancerStatsResponse_MetadataEntry) GetValue() string + func (x *LoadBalancerStatsResponse_MetadataEntry) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsResponse_MetadataEntry) Reset() + func (x *LoadBalancerStatsResponse_MetadataEntry) String() string + type LoadBalancerStatsResponse_MetadataType int32 + const LoadBalancerStatsResponse_INITIAL + const LoadBalancerStatsResponse_TRAILING + const LoadBalancerStatsResponse_UNKNOWN + func (LoadBalancerStatsResponse_MetadataType) Descriptor() protoreflect.EnumDescriptor + func (LoadBalancerStatsResponse_MetadataType) EnumDescriptor() ([]byte, []int) + func (LoadBalancerStatsResponse_MetadataType) Type() protoreflect.EnumType + func (x LoadBalancerStatsResponse_MetadataType) Enum() *LoadBalancerStatsResponse_MetadataType + func (x LoadBalancerStatsResponse_MetadataType) Number() protoreflect.EnumNumber + func (x LoadBalancerStatsResponse_MetadataType) String() string + type LoadBalancerStatsResponse_RpcMetadata struct + Metadata []*LoadBalancerStatsResponse_MetadataEntry + func (*LoadBalancerStatsResponse_RpcMetadata) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse_RpcMetadata) ProtoMessage() + func (x *LoadBalancerStatsResponse_RpcMetadata) GetMetadata() []*LoadBalancerStatsResponse_MetadataEntry + func (x *LoadBalancerStatsResponse_RpcMetadata) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsResponse_RpcMetadata) Reset() + func (x *LoadBalancerStatsResponse_RpcMetadata) String() string + type LoadBalancerStatsResponse_RpcsByPeer struct + RpcsByPeer map[string]int32 + func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int) + func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage() + func (x *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32 + func (x *LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect() protoreflect.Message + func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset() + func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string + type LoadBalancerStatsServiceClient interface + GetClientAccumulatedStats func(ctx context.Context, in *LoadBalancerAccumulatedStatsRequest, ...) (*LoadBalancerAccumulatedStatsResponse, error) + GetClientStats func(ctx context.Context, in *LoadBalancerStatsRequest, opts ...grpc.CallOption) (*LoadBalancerStatsResponse, error) + func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient + type LoadBalancerStatsServiceServer interface + GetClientAccumulatedStats func(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error) + GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) + type LoadParams struct + Load isLoadParams_Load + func (*LoadParams) Descriptor() ([]byte, []int) + func (*LoadParams) ProtoMessage() + func (m *LoadParams) GetLoad() isLoadParams_Load + func (x *LoadParams) GetClosedLoop() *ClosedLoopParams + func (x *LoadParams) GetPoisson() *PoissonParams + func (x *LoadParams) ProtoReflect() protoreflect.Message + func (x *LoadParams) Reset() + func (x *LoadParams) String() string + type LoadParams_ClosedLoop struct + ClosedLoop *ClosedLoopParams + type LoadParams_Poisson struct + Poisson *PoissonParams + type Mark struct + Reset_ bool + func (*Mark) Descriptor() ([]byte, []int) + func (*Mark) ProtoMessage() + func (x *Mark) GetReset_() bool + func (x *Mark) ProtoReflect() protoreflect.Message + func (x *Mark) Reset() + func (x *Mark) String() string + type MemorySize struct + Rss int64 + func (*MemorySize) Descriptor() ([]byte, []int) + func (*MemorySize) ProtoMessage() + func (x *MemorySize) GetRss() int64 + func (x *MemorySize) ProtoReflect() protoreflect.Message + func (x *MemorySize) Reset() + func (x *MemorySize) String() string + type Payload struct + Body []byte + Type PayloadType + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (x *Payload) GetBody() []byte + func (x *Payload) GetType() PayloadType + func (x *Payload) ProtoReflect() protoreflect.Message + func (x *Payload) Reset() + func (x *Payload) String() string + type PayloadConfig struct + Payload isPayloadConfig_Payload + func (*PayloadConfig) Descriptor() ([]byte, []int) + func (*PayloadConfig) ProtoMessage() + func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload + func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams + func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams + func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams + func (x *PayloadConfig) ProtoReflect() protoreflect.Message + func (x *PayloadConfig) Reset() + func (x *PayloadConfig) String() string + type PayloadConfig_BytebufParams struct + BytebufParams *ByteBufferParams + type PayloadConfig_ComplexParams struct + ComplexParams *ComplexProtoParams + type PayloadConfig_SimpleParams struct + SimpleParams *SimpleProtoParams + type PayloadType int32 + const PayloadType_COMPRESSABLE + func (PayloadType) Descriptor() protoreflect.EnumDescriptor + func (PayloadType) EnumDescriptor() ([]byte, []int) + func (PayloadType) Type() protoreflect.EnumType + func (x PayloadType) Enum() *PayloadType + func (x PayloadType) Number() protoreflect.EnumNumber + func (x PayloadType) String() string + type PoissonParams struct + OfferedLoad float64 + func (*PoissonParams) Descriptor() ([]byte, []int) + func (*PoissonParams) ProtoMessage() + func (x *PoissonParams) GetOfferedLoad() float64 + func (x *PoissonParams) ProtoReflect() protoreflect.Message + func (x *PoissonParams) Reset() + func (x *PoissonParams) String() string + type ReconnectInfo struct + BackoffMs []int32 + Passed bool + func (*ReconnectInfo) Descriptor() ([]byte, []int) + func (*ReconnectInfo) ProtoMessage() + func (x *ReconnectInfo) GetBackoffMs() []int32 + func (x *ReconnectInfo) GetPassed() bool + func (x *ReconnectInfo) ProtoReflect() protoreflect.Message + func (x *ReconnectInfo) Reset() + func (x *ReconnectInfo) String() string + type ReconnectParams struct + MaxReconnectBackoffMs int32 + func (*ReconnectParams) Descriptor() ([]byte, []int) + func (*ReconnectParams) ProtoMessage() + func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32 + func (x *ReconnectParams) ProtoReflect() protoreflect.Message + func (x *ReconnectParams) Reset() + func (x *ReconnectParams) String() string + type ReconnectServiceClient interface + Start func(ctx context.Context, in *ReconnectParams, opts ...grpc.CallOption) (*Empty, error) + Stop func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconnectInfo, error) + func NewReconnectServiceClient(cc grpc.ClientConnInterface) ReconnectServiceClient + type ReconnectServiceServer interface + Start func(context.Context, *ReconnectParams) (*Empty, error) + Stop func(context.Context, *Empty) (*ReconnectInfo, error) + type ReportQpsScenarioServiceClient interface + ReportScenario func(ctx context.Context, in *ScenarioResult, opts ...grpc.CallOption) (*Void, error) + func NewReportQpsScenarioServiceClient(cc grpc.ClientConnInterface) ReportQpsScenarioServiceClient + type ReportQpsScenarioServiceServer interface + ReportScenario func(context.Context, *ScenarioResult) (*Void, error) + type RequestResultCount struct + Count int64 + StatusCode int32 + func (*RequestResultCount) Descriptor() ([]byte, []int) + func (*RequestResultCount) ProtoMessage() + func (x *RequestResultCount) GetCount() int64 + func (x *RequestResultCount) GetStatusCode() int32 + func (x *RequestResultCount) ProtoReflect() protoreflect.Message + func (x *RequestResultCount) Reset() + func (x *RequestResultCount) String() string + type ResponseParameters struct + Compressed *BoolValue + IntervalUs int32 + Size int32 + func (*ResponseParameters) Descriptor() ([]byte, []int) + func (*ResponseParameters) ProtoMessage() + func (x *ResponseParameters) GetCompressed() *BoolValue + func (x *ResponseParameters) GetIntervalUs() int32 + func (x *ResponseParameters) GetSize() int32 + func (x *ResponseParameters) ProtoReflect() protoreflect.Message + func (x *ResponseParameters) Reset() + func (x *ResponseParameters) String() string + type RpcType int32 + const RpcType_STREAMING + const RpcType_STREAMING_BOTH_WAYS + const RpcType_STREAMING_FROM_CLIENT + const RpcType_STREAMING_FROM_SERVER + const RpcType_UNARY + func (RpcType) Descriptor() protoreflect.EnumDescriptor + func (RpcType) EnumDescriptor() ([]byte, []int) + func (RpcType) Type() protoreflect.EnumType + func (x RpcType) Enum() *RpcType + func (x RpcType) Number() protoreflect.EnumNumber + func (x RpcType) String() string + type Scenario struct + BenchmarkSeconds int32 + ClientConfig *ClientConfig + Name string + NumClients int32 + NumServers int32 + ServerConfig *ServerConfig + SpawnLocalWorkerCount int32 + WarmupSeconds int32 + func (*Scenario) Descriptor() ([]byte, []int) + func (*Scenario) ProtoMessage() + func (x *Scenario) GetBenchmarkSeconds() int32 + func (x *Scenario) GetClientConfig() *ClientConfig + func (x *Scenario) GetName() string + func (x *Scenario) GetNumClients() int32 + func (x *Scenario) GetNumServers() int32 + func (x *Scenario) GetServerConfig() *ServerConfig + func (x *Scenario) GetSpawnLocalWorkerCount() int32 + func (x *Scenario) GetWarmupSeconds() int32 + func (x *Scenario) ProtoReflect() protoreflect.Message + func (x *Scenario) Reset() + func (x *Scenario) String() string + type ScenarioResult struct + ClientStats []*ClientStats + ClientSuccess []bool + Latencies *HistogramData + RequestResults []*RequestResultCount + Scenario *Scenario + ServerCores []int32 + ServerStats []*ServerStats + ServerSuccess []bool + Summary *ScenarioResultSummary + func (*ScenarioResult) Descriptor() ([]byte, []int) + func (*ScenarioResult) ProtoMessage() + func (x *ScenarioResult) GetClientStats() []*ClientStats + func (x *ScenarioResult) GetClientSuccess() []bool + func (x *ScenarioResult) GetLatencies() *HistogramData + func (x *ScenarioResult) GetRequestResults() []*RequestResultCount + func (x *ScenarioResult) GetScenario() *Scenario + func (x *ScenarioResult) GetServerCores() []int32 + func (x *ScenarioResult) GetServerStats() []*ServerStats + func (x *ScenarioResult) GetServerSuccess() []bool + func (x *ScenarioResult) GetSummary() *ScenarioResultSummary + func (x *ScenarioResult) ProtoReflect() protoreflect.Message + func (x *ScenarioResult) Reset() + func (x *ScenarioResult) String() string + type ScenarioResultSummary struct + ClientPollsPerRequest float64 + ClientQueriesPerCpuSec float64 + ClientSystemTime float64 + ClientUserTime float64 + EndTime *timestamppb.Timestamp + FailedRequestsPerSecond float64 + Latency_50 float64 + Latency_90 float64 + Latency_95 float64 + Latency_99 float64 + Latency_999 float64 + Qps float64 + QpsPerServerCore float64 + ServerCpuUsage float64 + ServerPollsPerRequest float64 + ServerQueriesPerCpuSec float64 + ServerSystemTime float64 + ServerUserTime float64 + StartTime *timestamppb.Timestamp + SuccessfulRequestsPerSecond float64 + func (*ScenarioResultSummary) Descriptor() ([]byte, []int) + func (*ScenarioResultSummary) ProtoMessage() + func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64 + func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64 + func (x *ScenarioResultSummary) GetClientSystemTime() float64 + func (x *ScenarioResultSummary) GetClientUserTime() float64 + func (x *ScenarioResultSummary) GetEndTime() *timestamppb.Timestamp + func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64 + func (x *ScenarioResultSummary) GetLatency_50() float64 + func (x *ScenarioResultSummary) GetLatency_90() float64 + func (x *ScenarioResultSummary) GetLatency_95() float64 + func (x *ScenarioResultSummary) GetLatency_99() float64 + func (x *ScenarioResultSummary) GetLatency_999() float64 + func (x *ScenarioResultSummary) GetQps() float64 + func (x *ScenarioResultSummary) GetQpsPerServerCore() float64 + func (x *ScenarioResultSummary) GetServerCpuUsage() float64 + func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64 + func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64 + func (x *ScenarioResultSummary) GetServerSystemTime() float64 + func (x *ScenarioResultSummary) GetServerUserTime() float64 + func (x *ScenarioResultSummary) GetStartTime() *timestamppb.Timestamp + func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64 + func (x *ScenarioResultSummary) ProtoReflect() protoreflect.Message + func (x *ScenarioResultSummary) Reset() + func (x *ScenarioResultSummary) String() string + type Scenarios struct + Scenarios []*Scenario + func (*Scenarios) Descriptor() ([]byte, []int) + func (*Scenarios) ProtoMessage() + func (x *Scenarios) GetScenarios() []*Scenario + func (x *Scenarios) ProtoReflect() protoreflect.Message + func (x *Scenarios) Reset() + func (x *Scenarios) String() string + type SecurityParams struct + CredType string + ServerHostOverride string + UseTestCa bool + func (*SecurityParams) Descriptor() ([]byte, []int) + func (*SecurityParams) ProtoMessage() + func (x *SecurityParams) GetCredType() string + func (x *SecurityParams) GetServerHostOverride() string + func (x *SecurityParams) GetUseTestCa() bool + func (x *SecurityParams) ProtoReflect() protoreflect.Message + func (x *SecurityParams) Reset() + func (x *SecurityParams) String() string + type ServerArgs struct + Argtype isServerArgs_Argtype + func (*ServerArgs) Descriptor() ([]byte, []int) + func (*ServerArgs) ProtoMessage() + func (m *ServerArgs) GetArgtype() isServerArgs_Argtype + func (x *ServerArgs) GetMark() *Mark + func (x *ServerArgs) GetSetup() *ServerConfig + func (x *ServerArgs) ProtoReflect() protoreflect.Message + func (x *ServerArgs) Reset() + func (x *ServerArgs) String() string + type ServerArgs_Mark struct + Mark *Mark + type ServerArgs_Setup struct + Setup *ServerConfig + type ServerConfig struct + AsyncServerThreads int32 + ChannelArgs []*ChannelArg + CoreLimit int32 + CoreList []int32 + OtherServerApi string + PayloadConfig *PayloadConfig + Port int32 + ResourceQuotaSize int32 + SecurityParams *SecurityParams + ServerProcesses int32 + ServerType ServerType + ThreadsPerCq int32 + func (*ServerConfig) Descriptor() ([]byte, []int) + func (*ServerConfig) ProtoMessage() + func (x *ServerConfig) GetAsyncServerThreads() int32 + func (x *ServerConfig) GetChannelArgs() []*ChannelArg + func (x *ServerConfig) GetCoreLimit() int32 + func (x *ServerConfig) GetCoreList() []int32 + func (x *ServerConfig) GetOtherServerApi() string + func (x *ServerConfig) GetPayloadConfig() *PayloadConfig + func (x *ServerConfig) GetPort() int32 + func (x *ServerConfig) GetResourceQuotaSize() int32 + func (x *ServerConfig) GetSecurityParams() *SecurityParams + func (x *ServerConfig) GetServerProcesses() int32 + func (x *ServerConfig) GetServerType() ServerType + func (x *ServerConfig) GetThreadsPerCq() int32 + func (x *ServerConfig) ProtoReflect() protoreflect.Message + func (x *ServerConfig) Reset() + func (x *ServerConfig) String() string + type ServerStats struct + CoreStats *core.Stats + CqPollCount uint64 + IdleCpuTime uint64 + TimeElapsed float64 + TimeSystem float64 + TimeUser float64 + TotalCpuTime uint64 + func (*ServerStats) Descriptor() ([]byte, []int) + func (*ServerStats) ProtoMessage() + func (x *ServerStats) GetCoreStats() *core.Stats + func (x *ServerStats) GetCqPollCount() uint64 + func (x *ServerStats) GetIdleCpuTime() uint64 + func (x *ServerStats) GetTimeElapsed() float64 + func (x *ServerStats) GetTimeSystem() float64 + func (x *ServerStats) GetTimeUser() float64 + func (x *ServerStats) GetTotalCpuTime() uint64 + func (x *ServerStats) ProtoReflect() protoreflect.Message + func (x *ServerStats) Reset() + func (x *ServerStats) String() string + type ServerStatus struct + Cores int32 + Port int32 + Stats *ServerStats + func (*ServerStatus) Descriptor() ([]byte, []int) + func (*ServerStatus) ProtoMessage() + func (x *ServerStatus) GetCores() int32 + func (x *ServerStatus) GetPort() int32 + func (x *ServerStatus) GetStats() *ServerStats + func (x *ServerStatus) ProtoReflect() protoreflect.Message + func (x *ServerStatus) Reset() + func (x *ServerStatus) String() string + type ServerType int32 + const ServerType_ASYNC_GENERIC_SERVER + const ServerType_ASYNC_SERVER + const ServerType_CALLBACK_SERVER + const ServerType_OTHER_SERVER + const ServerType_SYNC_SERVER + func (ServerType) Descriptor() protoreflect.EnumDescriptor + func (ServerType) EnumDescriptor() ([]byte, []int) + func (ServerType) Type() protoreflect.EnumType + func (x ServerType) Enum() *ServerType + func (x ServerType) Number() protoreflect.EnumNumber + func (x ServerType) String() string + type SetReturnStatusRequest struct + GrpcCodeToReturn int32 + GrpcStatusDescription string + func (*SetReturnStatusRequest) Descriptor() ([]byte, []int) + func (*SetReturnStatusRequest) ProtoMessage() + func (x *SetReturnStatusRequest) GetGrpcCodeToReturn() int32 + func (x *SetReturnStatusRequest) GetGrpcStatusDescription() string + func (x *SetReturnStatusRequest) ProtoReflect() protoreflect.Message + func (x *SetReturnStatusRequest) Reset() + func (x *SetReturnStatusRequest) String() string + type SimpleProtoParams struct + ReqSize int32 + RespSize int32 + func (*SimpleProtoParams) Descriptor() ([]byte, []int) + func (*SimpleProtoParams) ProtoMessage() + func (x *SimpleProtoParams) GetReqSize() int32 + func (x *SimpleProtoParams) GetRespSize() int32 + func (x *SimpleProtoParams) ProtoReflect() protoreflect.Message + func (x *SimpleProtoParams) Reset() + func (x *SimpleProtoParams) String() string + type SimpleRequest struct + ExpectCompressed *BoolValue + FillGrpclbRouteType bool + FillOauthScope bool + FillServerId bool + FillUsername bool + OrcaPerQueryReport *TestOrcaReport + Payload *Payload + ResponseCompressed *BoolValue + ResponseSize int32 + ResponseStatus *EchoStatus + ResponseType PayloadType + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (x *SimpleRequest) GetExpectCompressed() *BoolValue + func (x *SimpleRequest) GetFillGrpclbRouteType() bool + func (x *SimpleRequest) GetFillOauthScope() bool + func (x *SimpleRequest) GetFillServerId() bool + func (x *SimpleRequest) GetFillUsername() bool + func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport + func (x *SimpleRequest) GetPayload() *Payload + func (x *SimpleRequest) GetResponseCompressed() *BoolValue + func (x *SimpleRequest) GetResponseSize() int32 + func (x *SimpleRequest) GetResponseStatus() *EchoStatus + func (x *SimpleRequest) GetResponseType() PayloadType + func (x *SimpleRequest) ProtoReflect() protoreflect.Message + func (x *SimpleRequest) Reset() + func (x *SimpleRequest) String() string + type SimpleResponse struct + GrpclbRouteType GrpclbRouteType + Hostname string + OauthScope string + Payload *Payload + ServerId string + Username string + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType + func (x *SimpleResponse) GetHostname() string + func (x *SimpleResponse) GetOauthScope() string + func (x *SimpleResponse) GetPayload() *Payload + func (x *SimpleResponse) GetServerId() string + func (x *SimpleResponse) GetUsername() string + func (x *SimpleResponse) ProtoReflect() protoreflect.Message + func (x *SimpleResponse) Reset() + func (x *SimpleResponse) String() string + type StreamingInputCallRequest struct + ExpectCompressed *BoolValue + Payload *Payload + func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingInputCallRequest) ProtoMessage() + func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue + func (x *StreamingInputCallRequest) GetPayload() *Payload + func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallRequest) Reset() + func (x *StreamingInputCallRequest) String() string + type StreamingInputCallResponse struct + AggregatedPayloadSize int32 + func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingInputCallResponse) ProtoMessage() + func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 + func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallResponse) Reset() + func (x *StreamingInputCallResponse) String() string + type StreamingOutputCallRequest struct + OrcaOobReport *TestOrcaReport + Payload *Payload + ResponseParameters []*ResponseParameters + ResponseStatus *EchoStatus + ResponseType PayloadType + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport + func (x *StreamingOutputCallRequest) GetPayload() *Payload + func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus + func (x *StreamingOutputCallRequest) GetResponseType() PayloadType + func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallRequest) Reset() + func (x *StreamingOutputCallRequest) String() string + type StreamingOutputCallResponse struct + Payload *Payload + func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingOutputCallResponse) ProtoMessage() + func (x *StreamingOutputCallResponse) GetPayload() *Payload + func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallResponse) Reset() + func (x *StreamingOutputCallResponse) String() string + type TestOrcaReport struct + CpuUtilization float64 + MemoryUtilization float64 + RequestCost map[string]float64 + Utilization map[string]float64 + func (*TestOrcaReport) Descriptor() ([]byte, []int) + func (*TestOrcaReport) ProtoMessage() + func (x *TestOrcaReport) GetCpuUtilization() float64 + func (x *TestOrcaReport) GetMemoryUtilization() float64 + func (x *TestOrcaReport) GetRequestCost() map[string]float64 + func (x *TestOrcaReport) GetUtilization() map[string]float64 + func (x *TestOrcaReport) ProtoReflect() protoreflect.Message + func (x *TestOrcaReport) Reset() + func (x *TestOrcaReport) String() string + type TestServiceClient interface + CacheableUnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + EmptyCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + FullDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (...) + HalfDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (...) + StreamingInputCall func(ctx context.Context, opts ...grpc.CallOption) (...) + StreamingOutputCall func(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamingOutputCallResponse], error) + UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + UnimplementedCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient + type TestServiceServer interface + CacheableUnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + EmptyCall func(context.Context, *Empty) (*Empty, error) + FullDuplexCall func(...) error + HalfDuplexCall func(...) error + StreamingInputCall func(...) error + StreamingOutputCall func(*StreamingOutputCallRequest, ...) error + UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + UnimplementedCall func(context.Context, *Empty) (*Empty, error) + type TestService_FullDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse] + type TestService_FullDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse] + type TestService_HalfDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse] + type TestService_HalfDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse] + type TestService_StreamingInputCallClient = grpc.ClientStreamingClient[StreamingInputCallRequest, StreamingInputCallResponse] + type TestService_StreamingInputCallServer = grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse] + type TestService_StreamingOutputCallClient = grpc.ServerStreamingClient[StreamingOutputCallResponse] + type TestService_StreamingOutputCallServer = grpc.ServerStreamingServer[StreamingOutputCallResponse] + type UnimplementedBenchmarkServiceServer struct + func (UnimplementedBenchmarkServiceServer) StreamingBothWays(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error + func (UnimplementedBenchmarkServiceServer) StreamingCall(grpc.BidiStreamingServer[SimpleRequest, SimpleResponse]) error + func (UnimplementedBenchmarkServiceServer) StreamingFromClient(grpc.ClientStreamingServer[SimpleRequest, SimpleResponse]) error + func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*SimpleRequest, grpc.ServerStreamingServer[SimpleResponse]) error + func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) + type UnimplementedHookServiceServer struct + func (UnimplementedHookServiceServer) ClearReturnStatus(context.Context, *Empty) (*Empty, error) + func (UnimplementedHookServiceServer) Hook(context.Context, *Empty) (*Empty, error) + func (UnimplementedHookServiceServer) SetReturnStatus(context.Context, *SetReturnStatusRequest) (*Empty, error) + type UnimplementedLoadBalancerStatsServiceServer struct + func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error) + func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) + type UnimplementedReconnectServiceServer struct + func (UnimplementedReconnectServiceServer) Start(context.Context, *ReconnectParams) (*Empty, error) + func (UnimplementedReconnectServiceServer) Stop(context.Context, *Empty) (*ReconnectInfo, error) + type UnimplementedReportQpsScenarioServiceServer struct + func (UnimplementedReportQpsScenarioServiceServer) ReportScenario(context.Context, *ScenarioResult) (*Void, error) + type UnimplementedServiceClient interface + UnimplementedCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient + type UnimplementedServiceServer interface + UnimplementedCall func(context.Context, *Empty) (*Empty, error) + type UnimplementedTestServiceServer struct + func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) + func (UnimplementedTestServiceServer) EmptyCall(context.Context, *Empty) (*Empty, error) + func (UnimplementedTestServiceServer) FullDuplexCall(...) error + func (UnimplementedTestServiceServer) HalfDuplexCall(...) error + func (UnimplementedTestServiceServer) StreamingInputCall(...) error + func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, ...) error + func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) + func (UnimplementedTestServiceServer) UnimplementedCall(context.Context, *Empty) (*Empty, error) + type UnimplementedUnimplementedServiceServer struct + func (UnimplementedUnimplementedServiceServer) UnimplementedCall(context.Context, *Empty) (*Empty, error) + type UnimplementedWorkerServiceServer struct + func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error) + func (UnimplementedWorkerServiceServer) QuitWorker(context.Context, *Void) (*Void, error) + func (UnimplementedWorkerServiceServer) RunClient(grpc.BidiStreamingServer[ClientArgs, ClientStatus]) error + func (UnimplementedWorkerServiceServer) RunServer(grpc.BidiStreamingServer[ServerArgs, ServerStatus]) error + type UnimplementedXdsUpdateClientConfigureServiceServer struct + func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse, error) + type UnimplementedXdsUpdateHealthServiceServer struct + func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *HookRequest) (*HookResponse, error) + func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing(context.Context, *Empty) (*Empty, error) + func (UnimplementedXdsUpdateHealthServiceServer) SetServing(context.Context, *Empty) (*Empty, error) + type UnsafeBenchmarkServiceServer interface + type UnsafeHookServiceServer interface + type UnsafeLoadBalancerStatsServiceServer interface + type UnsafeReconnectServiceServer interface + type UnsafeReportQpsScenarioServiceServer interface + type UnsafeTestServiceServer interface + type UnsafeUnimplementedServiceServer interface + type UnsafeWorkerServiceServer interface + type UnsafeXdsUpdateClientConfigureServiceServer interface + type UnsafeXdsUpdateHealthServiceServer interface + type Void struct + func (*Void) Descriptor() ([]byte, []int) + func (*Void) ProtoMessage() + func (x *Void) ProtoReflect() protoreflect.Message + func (x *Void) Reset() + func (x *Void) String() string + type WorkerServiceClient interface + CoreCount func(ctx context.Context, in *CoreRequest, opts ...grpc.CallOption) (*CoreResponse, error) + QuitWorker func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) + RunClient func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClientArgs, ClientStatus], error) + RunServer func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ServerArgs, ServerStatus], error) + func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient + type WorkerServiceServer interface + CoreCount func(context.Context, *CoreRequest) (*CoreResponse, error) + QuitWorker func(context.Context, *Void) (*Void, error) + RunClient func(grpc.BidiStreamingServer[ClientArgs, ClientStatus]) error + RunServer func(grpc.BidiStreamingServer[ServerArgs, ServerStatus]) error + type WorkerService_RunClientClient = grpc.BidiStreamingClient[ClientArgs, ClientStatus] + type WorkerService_RunClientServer = grpc.BidiStreamingServer[ClientArgs, ClientStatus] + type WorkerService_RunServerClient = grpc.BidiStreamingClient[ServerArgs, ServerStatus] + type WorkerService_RunServerServer = grpc.BidiStreamingServer[ServerArgs, ServerStatus] + type XdsUpdateClientConfigureServiceClient interface + Configure func(ctx context.Context, in *ClientConfigureRequest, opts ...grpc.CallOption) (*ClientConfigureResponse, error) + func NewXdsUpdateClientConfigureServiceClient(cc grpc.ClientConnInterface) XdsUpdateClientConfigureServiceClient + type XdsUpdateClientConfigureServiceServer interface + Configure func(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse, error) + type XdsUpdateHealthServiceClient interface + SendHookRequest func(ctx context.Context, in *HookRequest, opts ...grpc.CallOption) (*HookResponse, error) + SetNotServing func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + SetServing func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewXdsUpdateHealthServiceClient(cc grpc.ClientConnInterface) XdsUpdateHealthServiceClient + type XdsUpdateHealthServiceServer interface + SendHookRequest func(context.Context, *HookRequest) (*HookResponse, error) + SetNotServing func(context.Context, *Empty) (*Empty, error) + SetServing func(context.Context, *Empty) (*Empty, error)
Go to main page