grpc_testing

Oct 17, 2023

Changes in this version

+ const HookService_ClearReturnStatus_FullMethodName

+ const HookService_SetReturnStatus_FullMethodName

+ var HookRequest_HookRequestCommand_name = map[int32]string

+ var HookRequest_HookRequestCommand_value = map[string]int32

+ 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 HookServiceClient

+ ClearReturnStatus func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ SetReturnStatus func(ctx context.Context, in *SetReturnStatusRequest, opts ...grpc.CallOption) (*Empty, error)

type HookServiceServer

+ ClearReturnStatus func(context.Context, *Empty) (*Empty, error)

+ SetReturnStatus func(context.Context, *SetReturnStatusRequest) (*Empty, error)

type LoadBalancerStatsResponse_MetadataType

+ const LoadBalancerStatsResponse_INITIAL

+ const LoadBalancerStatsResponse_TRAILING

+ const LoadBalancerStatsResponse_UNKNOWN

+ 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 UnimplementedHookServiceServer

+ func (UnimplementedHookServiceServer) ClearReturnStatus(context.Context, *Empty) (*Empty, error)

+ func (UnimplementedHookServiceServer) SetReturnStatus(context.Context, *SetReturnStatusRequest) (*Empty, error)

Sep 21, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 13, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 6, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ const HookService_Hook_FullMethodName

+ const XdsUpdateHealthService_SendHookRequest_FullMethodName

+ var HookRequestCommand_name = map[int32]string

+ var HookRequestCommand_value = map[string]int32

+ var HookService_ServiceDesc = grpc.ServiceDesc

+ var LoadBalancerStatsResponse_MetadataType_name = map[int32]string

+ var LoadBalancerStatsResponse_MetadataType_value = map[string]int32

+ func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer)

+ type HookRequest struct

+ Command HookRequestCommand

+ GrpcCodeToReturn int32

+ GrpcStatusDescription string

+ ServerPort int32

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

+ func (*HookRequest) ProtoMessage()

+ func (x *HookRequest) GetCommand() 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 HookRequestCommand int32

+ const HookRequestCommand_RETURN

+ const HookRequestCommand_START

+ const HookRequestCommand_STOP

+ func (HookRequestCommand) Descriptor() protoreflect.EnumDescriptor

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

+ func (HookRequestCommand) Type() protoreflect.EnumType

+ func (x HookRequestCommand) Enum() *HookRequestCommand

+ func (x HookRequestCommand) Number() protoreflect.EnumNumber

+ func (x 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

+ Hook func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ func NewHookServiceClient(cc grpc.ClientConnInterface) HookServiceClient

+ type HookServiceServer interface

+ Hook func(context.Context, *Empty) (*Empty, error)

type LoadBalancerStatsRequest

+ MetadataKeys []string

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

type LoadBalancerStatsResponse

+ MetadatasByPeer map[string]*LoadBalancerStatsResponse_MetadataByPeer

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

+ 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

+ 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 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 UnimplementedHookServiceServer struct

+ func (UnimplementedHookServiceServer) Hook(context.Context, *Empty) (*Empty, error)

type UnimplementedXdsUpdateHealthServiceServer

+ func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *HookRequest) (*HookResponse, error)

+ type UnsafeHookServiceServer interface

type XdsUpdateHealthServiceClient

+ SendHookRequest func(ctx context.Context, in *HookRequest, opts ...grpc.CallOption) (*HookResponse, error)

type XdsUpdateHealthServiceServer

+ SendHookRequest func(context.Context, *HookRequest) (*HookResponse, error)

Jul 26, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 6, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 21, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 15, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 18, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 6, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 4, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 17, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 5, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 21, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

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 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_SetNotServing_FullMethodName

+ const XdsUpdateHealthService_SetServing_FullMethodName

Feb 7, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 16, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 25, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 24, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 10, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 8, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 18, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 4, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 14, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 6, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 15, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 23, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 1, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 12, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type ScenarioResultSummary

+ EndTime *timestamppb.Timestamp

+ StartTime *timestamppb.Timestamp

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

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

type SimpleRequest

+ OrcaOobReport *TestOrcaReport

+ OrcaPerQueryReport *TestOrcaReport

+ func (x *SimpleRequest) GetOrcaOobReport() *TestOrcaReport

+ func (x *SimpleRequest) GetOrcaPerQueryReport() *TestOrcaReport

type StreamingOutputCallRequest

+ OrcaOobReport *TestOrcaReport

+ func (x *StreamingOutputCallRequest) GetOrcaOobReport() *TestOrcaReport

+ 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

May 23, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 31, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 6, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 13, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 9, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 25, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 6, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 14, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 29, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 2, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 21, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 1, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 23, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 27, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 1, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 12, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 15, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 5, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 29, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 29, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 19, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 31, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 7, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 10, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 25, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 24, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type ClientConfigureRequest

+ TimeoutSec int32

+ func (x *ClientConfigureRequest) GetTimeoutSec() int32

type LoadBalancerAccumulatedStatsResponse

+ StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats

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

+ 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

Jan 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 12, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 13, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ 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 LoadBalancerStatsService_ServiceDesc = grpc.ServiceDesc

+ 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 RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)

+ func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)

+ 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) (BenchmarkService_StreamingBothWaysClient, error)

+ StreamingCall func(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)

+ StreamingFromClient func(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingFromClientClient, error)

+ StreamingFromServer func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (BenchmarkService_StreamingFromServerClient, error)

+ UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)

+ func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient

+ type BenchmarkServiceServer interface

+ StreamingBothWays func(BenchmarkService_StreamingBothWaysServer) error

+ StreamingCall func(BenchmarkService_StreamingCallServer) error

+ StreamingFromClient func(BenchmarkService_StreamingFromClientServer) error

+ StreamingFromServer func(*SimpleRequest, BenchmarkService_StreamingFromServerServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ type BenchmarkService_StreamingBothWaysClient interface

+ Recv func() (*SimpleResponse, error)

+ Send func(*SimpleRequest) error

+ type BenchmarkService_StreamingBothWaysServer interface

+ Recv func() (*SimpleRequest, error)

+ Send func(*SimpleResponse) error

+ type BenchmarkService_StreamingCallClient interface

+ Recv func() (*SimpleResponse, error)

+ Send func(*SimpleRequest) error

+ type BenchmarkService_StreamingCallServer interface

+ Recv func() (*SimpleRequest, error)

+ Send func(*SimpleResponse) error

+ type BenchmarkService_StreamingFromClientClient interface

+ CloseAndRecv func() (*SimpleResponse, error)

+ Send func(*SimpleRequest) error

+ type BenchmarkService_StreamingFromClientServer interface

+ Recv func() (*SimpleRequest, error)

+ SendAndClose func(*SimpleResponse) error

+ type BenchmarkService_StreamingFromServerClient interface

+ Recv func() (*SimpleResponse, error)

+ type BenchmarkService_StreamingFromServerServer interface

+ Send func(*SimpleResponse) error

+ 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

+ Types []ClientConfigureRequest_RpcType

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

+ func (*ClientConfigureRequest) ProtoMessage()

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

+ 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 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 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

+ 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) ProtoReflect() protoreflect.Message

+ func (x *LoadBalancerAccumulatedStatsResponse) Reset()

+ func (x *LoadBalancerAccumulatedStatsResponse) String() string

type LoadBalancerStatsServiceClient

+ GetClientAccumulatedStats func(ctx context.Context, in *LoadBalancerAccumulatedStatsRequest, ...) (*LoadBalancerAccumulatedStatsResponse, error)

type LoadBalancerStatsServiceServer

+ GetClientAccumulatedStats func(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, 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 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 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

+ Compressed *BoolValue

+ func (x *ResponseParameters) GetCompressed() *BoolValue

+ 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

+ 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

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

+ ExpectCompressed *BoolValue

+ ResponseCompressed *BoolValue

+ func (x *SimpleRequest) GetExpectCompressed() *BoolValue

+ func (x *SimpleRequest) GetResponseCompressed() *BoolValue

type StreamingInputCallRequest

+ ExpectCompressed *BoolValue

+ func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

type TestServiceClient

+ CacheableUnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)

+ UnimplementedCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

type TestServiceServer

+ CacheableUnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ UnimplementedCall func(context.Context, *Empty) (*Empty, error)

+ type UnimplementedBenchmarkServiceServer struct

+ func (UnimplementedBenchmarkServiceServer) StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error

+ func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error

+ func (UnimplementedBenchmarkServiceServer) StreamingFromClient(BenchmarkService_StreamingFromClientServer) error

+ func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*SimpleRequest, BenchmarkService_StreamingFromServerServer) error

+ func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)

type UnimplementedLoadBalancerStatsServiceServer

+ func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, 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 UnimplementedTestServiceServer

+ func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ func (UnimplementedTestServiceServer) 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(WorkerService_RunClientServer) error

+ func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error

+ type UnimplementedXdsUpdateClientConfigureServiceServer struct

+ func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure(context.Context, *ClientConfigureRequest) (*ClientConfigureResponse, error)

+ type UnimplementedXdsUpdateHealthServiceServer struct

+ func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing(context.Context, *Empty) (*Empty, error)

+ func (UnimplementedXdsUpdateHealthServiceServer) SetServing(context.Context, *Empty) (*Empty, error)

+ type UnsafeBenchmarkServiceServer interface

+ type UnsafeReconnectServiceServer interface

+ type UnsafeReportQpsScenarioServiceServer 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) (WorkerService_RunClientClient, error)

+ RunServer func(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunServerClient, 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(WorkerService_RunClientServer) error

+ RunServer func(WorkerService_RunServerServer) error

+ type WorkerService_RunClientClient interface

+ Recv func() (*ClientStatus, error)

+ Send func(*ClientArgs) error

+ type WorkerService_RunClientServer interface

+ Recv func() (*ClientArgs, error)

+ Send func(*ClientStatus) error

+ type WorkerService_RunServerClient interface

+ Recv func() (*ServerStatus, error)

+ Send func(*ServerArgs) error

+ type WorkerService_RunServerServer interface

+ Recv func() (*ServerArgs, error)

+ Send func(*ServerStatus) error

+ 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

+ 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

+ SetNotServing func(context.Context, *Empty) (*Empty, error)

+ SetServing func(context.Context, *Empty) (*Empty, error)

Nov 17, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 12, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 2, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 6, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ var File_interop_grpc_testing_test_proto protoreflect.FileDescriptor

type EchoStatus

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

type Empty

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

type GrpclbRouteType

+ func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor

+ func (GrpclbRouteType) Type() protoreflect.EnumType

+ func (x GrpclbRouteType) Enum() *GrpclbRouteType

+ func (x GrpclbRouteType) Number() protoreflect.EnumNumber

type LoadBalancerStatsRequest

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

type LoadBalancerStatsResponse

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

type LoadBalancerStatsResponse_RpcsByPeer

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

type Payload

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

type PayloadType

+ func (PayloadType) Descriptor() protoreflect.EnumDescriptor

+ func (PayloadType) Type() protoreflect.EnumType

+ func (x PayloadType) Number() protoreflect.EnumNumber

type ResponseParameters

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

type SimpleRequest

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

type SimpleResponse

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

type StreamingInputCallRequest

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

type StreamingInputCallResponse

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

type StreamingOutputCallRequest

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

type StreamingOutputCallResponse

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

Oct 20, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ type UnsafeLoadBalancerStatsServiceServer interface

+ type UnsafeTestServiceServer interface

+ type UnsafeUnimplementedServiceServer interface

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ func RegisterLoadBalancerStatsServiceService(s grpc.ServiceRegistrar, srv *LoadBalancerStatsServiceService)

+ func RegisterTestServiceService(s grpc.ServiceRegistrar, srv *TestServiceService)

+ func RegisterUnimplementedServiceService(s grpc.ServiceRegistrar, srv *UnimplementedServiceService)

+ type LoadBalancerStatsServiceService struct

+ GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)

+ func NewLoadBalancerStatsServiceService(s interface{}) *LoadBalancerStatsServiceService

+ type TestServiceService struct

+ EmptyCall func(context.Context, *Empty) (*Empty, error)

+ FullDuplexCall func(TestService_FullDuplexCallServer) error

+ HalfDuplexCall func(TestService_HalfDuplexCallServer) error

+ StreamingInputCall func(TestService_StreamingInputCallServer) error

+ StreamingOutputCall func(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ func NewTestServiceService(s interface{}) *TestServiceService

+ type UnimplementedServiceService struct

+ UnimplementedCall func(context.Context, *Empty) (*Empty, error)

+ func NewUnimplementedServiceService(s interface{}) *UnimplementedServiceService

+ type UnstableLoadBalancerStatsServiceService interface

+ GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)

+ type UnstableTestServiceService interface

+ EmptyCall func(context.Context, *Empty) (*Empty, error)

+ FullDuplexCall func(TestService_FullDuplexCallServer) error

+ HalfDuplexCall func(TestService_HalfDuplexCallServer) error

+ StreamingInputCall func(TestService_StreamingInputCallServer) error

+ StreamingOutputCall func(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ type UnstableUnimplementedServiceService interface

+ UnimplementedCall func(context.Context, *Empty) (*Empty, error)

Jul 23, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 30, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type LoadBalancerStatsResponse

+ RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer

+ func (m *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer

+ type LoadBalancerStatsResponse_RpcsByPeer struct

+ RpcsByPeer map[string]int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) Reset()

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) String() string

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown()

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

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge(src proto.Message)

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Size() int

+ func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal(b []byte) error

Jun 11, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 25, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 22, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 21, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 8, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 23, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 21, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 5, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 6, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 10, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ func RegisterLoadBalancerStatsServiceServer(s *grpc.Server, srv LoadBalancerStatsServiceServer)

+ type LoadBalancerStatsRequest struct

+ NumRpcs int32

+ TimeoutSec int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadBalancerStatsRequest) ProtoMessage()

+ func (m *LoadBalancerStatsRequest) GetNumRpcs() int32

+ func (m *LoadBalancerStatsRequest) GetTimeoutSec() int32

+ func (m *LoadBalancerStatsRequest) Reset()

+ func (m *LoadBalancerStatsRequest) String() string

+ func (m *LoadBalancerStatsRequest) XXX_DiscardUnknown()

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

+ func (m *LoadBalancerStatsRequest) XXX_Merge(src proto.Message)

+ func (m *LoadBalancerStatsRequest) XXX_Size() int

+ func (m *LoadBalancerStatsRequest) XXX_Unmarshal(b []byte) error

+ type LoadBalancerStatsResponse struct

+ NumFailures int32

+ RpcsByPeer map[string]int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadBalancerStatsResponse) ProtoMessage()

+ func (m *LoadBalancerStatsResponse) GetNumFailures() int32

+ func (m *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32

+ func (m *LoadBalancerStatsResponse) Reset()

+ func (m *LoadBalancerStatsResponse) String() string

+ func (m *LoadBalancerStatsResponse) XXX_DiscardUnknown()

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

+ func (m *LoadBalancerStatsResponse) XXX_Merge(src proto.Message)

+ func (m *LoadBalancerStatsResponse) XXX_Size() int

+ func (m *LoadBalancerStatsResponse) XXX_Unmarshal(b []byte) error

+ type LoadBalancerStatsServiceClient interface

+ GetClientStats func(ctx context.Context, in *LoadBalancerStatsRequest, opts ...grpc.CallOption) (*LoadBalancerStatsResponse, error)

+ func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient

+ type LoadBalancerStatsServiceServer interface

+ GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)

type SimpleResponse

+ Hostname string

+ func (m *SimpleResponse) GetHostname() string

+ type UnimplementedLoadBalancerStatsServiceServer struct

+ func (*UnimplementedLoadBalancerStatsServiceServer) GetClientStats(ctx context.Context, req *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error)

Jan 28, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 5, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 28, 2020 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ var GrpclbRouteType_name = map[int32]string

+ var GrpclbRouteType_value = map[string]int32

+ type GrpclbRouteType int32

+ const GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND

+ const GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK

+ const GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN

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

+ func (x GrpclbRouteType) String() string

type SimpleRequest

+ FillGrpclbRouteType bool

+ func (m *SimpleRequest) GetFillGrpclbRouteType() bool

type SimpleResponse

+ GrpclbRouteType GrpclbRouteType

+ func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

Nov 8, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 5, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ type UnimplementedTestServiceServer struct

+ func (*UnimplementedTestServiceServer) EmptyCall(ctx context.Context, req *Empty) (*Empty, error)

+ func (*UnimplementedTestServiceServer) FullDuplexCall(srv TestService_FullDuplexCallServer) error

+ func (*UnimplementedTestServiceServer) HalfDuplexCall(srv TestService_HalfDuplexCallServer) error

+ func (*UnimplementedTestServiceServer) StreamingInputCall(srv TestService_StreamingInputCallServer) error

+ func (*UnimplementedTestServiceServer) StreamingOutputCall(req *StreamingOutputCallRequest, srv TestService_StreamingOutputCallServer) error

+ func (*UnimplementedTestServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)

+ type UnimplementedUnimplementedServiceServer struct

+ func (*UnimplementedUnimplementedServiceServer) UnimplementedCall(ctx context.Context, req *Empty) (*Empty, error)

Sep 11, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 11, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 2, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 17, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 13, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 25, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 4, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 22, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type SimpleRequest

+ FillServerId bool

+ func (m *SimpleRequest) GetFillServerId() bool

type SimpleResponse

+ ServerId string

+ func (m *SimpleResponse) GetServerId() string

Apr 18, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 9, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 20, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 26, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 20, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 15, 2019 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 4, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 23, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Sep 11, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 31, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 19, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 7, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 6, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 8, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

type EchoStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *EchoStatus) XXX_Merge(src proto.Message)

+ func (m *EchoStatus) XXX_DiscardUnknown()

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

+ func (m *EchoStatus) XXX_Size() int

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

type Empty

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_DiscardUnknown()

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

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

type Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *Payload) XXX_Merge(src proto.Message)

+ func (m *Payload) XXX_DiscardUnknown()

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

+ func (m *Payload) XXX_Size() int

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

type ResponseParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *ResponseParameters) XXX_Merge(src proto.Message)

+ func (m *ResponseParameters) XXX_DiscardUnknown()

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

+ func (m *ResponseParameters) XXX_Size() int

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

type SimpleRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *SimpleRequest) XXX_Merge(src proto.Message)

+ func (m *SimpleRequest) XXX_DiscardUnknown()

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

+ func (m *SimpleRequest) XXX_Size() int

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

type SimpleResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *SimpleResponse) XXX_Merge(src proto.Message)

+ func (m *SimpleResponse) XXX_DiscardUnknown()

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

+ func (m *SimpleResponse) XXX_Size() int

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

type StreamingInputCallRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *StreamingInputCallRequest) XXX_Merge(src proto.Message)

+ func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

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

+ func (m *StreamingInputCallRequest) XXX_Size() int

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

type StreamingInputCallResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *StreamingInputCallResponse) XXX_Merge(src proto.Message)

+ func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

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

+ func (m *StreamingInputCallResponse) XXX_Size() int

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

type StreamingOutputCallRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

+ func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

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

+ func (m *StreamingOutputCallRequest) XXX_Size() int

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

type StreamingOutputCallResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

+ func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

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

+ func (m *StreamingOutputCallResponse) XXX_Size() int

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

Apr 9, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 4, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 29, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 27, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 28, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 14, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 19, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 8, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 2, 2018 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 13, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 21, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 18, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 4, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 3, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 25, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 11, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 30, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 27, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 19, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 22, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jun 7, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 28, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 7, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 14, 2017 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 2, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer)

+ type UnimplementedServiceClient interface

+ UnimplementedCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ func NewUnimplementedServiceClient(cc *grpc.ClientConn) UnimplementedServiceClient

+ type UnimplementedServiceServer interface

+ UnimplementedCall func(context.Context, *Empty) (*Empty, error)

Nov 3, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 17, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ type EchoStatus struct

+ Code *int32

+ Message *string

+ XXX_unrecognized []byte

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

+ func (*EchoStatus) ProtoMessage()

+ func (m *EchoStatus) GetCode() int32

+ func (m *EchoStatus) GetMessage() string

+ func (m *EchoStatus) Reset()

+ func (m *EchoStatus) String() string

type SimpleRequest

+ ResponseStatus *EchoStatus

+ func (m *SimpleRequest) GetResponseStatus() *EchoStatus

type StreamingOutputCallRequest

+ ResponseStatus *EchoStatus

+ func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

Oct 3, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 19, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 11, 2016 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ var PayloadType_name = map[int32]string

+ var PayloadType_value = map[string]int32

+ func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

+ type Empty struct

+ XXX_unrecognized []byte

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ type Payload struct

+ Body []byte

+ Type *PayloadType

+ XXX_unrecognized []byte

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

+ func (*Payload) ProtoMessage()

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

+ func (m *Payload) GetType() PayloadType

+ func (m *Payload) Reset()

+ func (m *Payload) String() string

+ type PayloadType int32

+ const PayloadType_COMPRESSABLE

+ const PayloadType_RANDOM

+ const PayloadType_UNCOMPRESSABLE

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

+ func (x *PayloadType) UnmarshalJSON(data []byte) error

+ func (x PayloadType) Enum() *PayloadType

+ func (x PayloadType) String() string

+ type ResponseParameters struct

+ IntervalUs *int32

+ Size *int32

+ XXX_unrecognized []byte

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

+ func (*ResponseParameters) ProtoMessage()

+ func (m *ResponseParameters) GetIntervalUs() int32

+ func (m *ResponseParameters) GetSize() int32

+ func (m *ResponseParameters) Reset()

+ func (m *ResponseParameters) String() string

+ type SimpleRequest struct

+ FillOauthScope *bool

+ FillUsername *bool

+ Payload *Payload

+ ResponseSize *int32

+ ResponseType *PayloadType

+ XXX_unrecognized []byte

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

+ func (*SimpleRequest) ProtoMessage()

+ func (m *SimpleRequest) GetFillOauthScope() bool

+ func (m *SimpleRequest) GetFillUsername() bool

+ func (m *SimpleRequest) GetPayload() *Payload

+ func (m *SimpleRequest) GetResponseSize() int32

+ func (m *SimpleRequest) GetResponseType() PayloadType

+ func (m *SimpleRequest) Reset()

+ func (m *SimpleRequest) String() string

+ type SimpleResponse struct

+ OauthScope *string

+ Payload *Payload

+ Username *string

+ XXX_unrecognized []byte

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

+ func (*SimpleResponse) ProtoMessage()

+ func (m *SimpleResponse) GetOauthScope() string

+ func (m *SimpleResponse) GetPayload() *Payload

+ func (m *SimpleResponse) GetUsername() string

+ func (m *SimpleResponse) Reset()

+ func (m *SimpleResponse) String() string

+ type StreamingInputCallRequest struct

+ Payload *Payload

+ XXX_unrecognized []byte

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

+ func (*StreamingInputCallRequest) ProtoMessage()

+ func (m *StreamingInputCallRequest) GetPayload() *Payload

+ func (m *StreamingInputCallRequest) Reset()

+ func (m *StreamingInputCallRequest) String() string

+ type StreamingInputCallResponse struct

+ AggregatedPayloadSize *int32

+ XXX_unrecognized []byte

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

+ func (*StreamingInputCallResponse) ProtoMessage()

+ func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

+ func (m *StreamingInputCallResponse) Reset()

+ func (m *StreamingInputCallResponse) String() string

+ type StreamingOutputCallRequest struct

+ Payload *Payload

+ ResponseParameters []*ResponseParameters

+ ResponseType *PayloadType

+ XXX_unrecognized []byte

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

+ func (*StreamingOutputCallRequest) ProtoMessage()

+ func (m *StreamingOutputCallRequest) GetPayload() *Payload

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

+ func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

+ func (m *StreamingOutputCallRequest) Reset()

+ func (m *StreamingOutputCallRequest) String() string

+ type StreamingOutputCallResponse struct

+ Payload *Payload

+ XXX_unrecognized []byte

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

+ func (*StreamingOutputCallResponse) ProtoMessage()

+ func (m *StreamingOutputCallResponse) GetPayload() *Payload

+ func (m *StreamingOutputCallResponse) Reset()

+ func (m *StreamingOutputCallResponse) String() string

+ type TestServiceClient interface

+ EmptyCall func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ FullDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error)

+ HalfDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error)

+ StreamingInputCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error)

+ StreamingOutputCall func(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error)

+ UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)

+ func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

+ type TestServiceServer interface

+ EmptyCall func(context.Context, *Empty) (*Empty, error)

+ FullDuplexCall func(TestService_FullDuplexCallServer) error

+ HalfDuplexCall func(TestService_HalfDuplexCallServer) error

+ StreamingInputCall func(TestService_StreamingInputCallServer) error

+ StreamingOutputCall func(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error

+ UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error)

+ type TestService_FullDuplexCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ Send func(*StreamingOutputCallRequest) error

+ type TestService_FullDuplexCallServer interface

+ Recv func() (*StreamingOutputCallRequest, error)

+ Send func(*StreamingOutputCallResponse) error

+ type TestService_HalfDuplexCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ Send func(*StreamingOutputCallRequest) error

+ type TestService_HalfDuplexCallServer interface

+ Recv func() (*StreamingOutputCallRequest, error)

+ Send func(*StreamingOutputCallResponse) error

+ type TestService_StreamingInputCallClient interface

+ CloseAndRecv func() (*StreamingInputCallResponse, error)

+ Send func(*StreamingInputCallRequest) error

+ type TestService_StreamingInputCallServer interface

+ Recv func() (*StreamingInputCallRequest, error)

+ SendAndClose func(*StreamingInputCallResponse) error

+ type TestService_StreamingOutputCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ type TestService_StreamingOutputCallServer interface

+ Send func(*StreamingOutputCallResponse) error