grpc: google.golang.org/grpc/interop/grpc_testing Index | Files | Directories

package grpc_testing

import "google.golang.org/grpc/interop/grpc_testing"

Index

Package Files

benchmark_service.pb.go benchmark_service_grpc.pb.go control.pb.go empty.pb.go messages.pb.go payloads.pb.go report_qps_scenario_service.pb.go report_qps_scenario_service_grpc.pb.go stats.pb.go test.pb.go test_grpc.pb.go worker_service.pb.go worker_service_grpc.pb.go

Variables

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

Enum value maps for ClientType.

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

Enum value maps for ServerType.

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

Enum value maps for RpcType.

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

Enum value maps for PayloadType.

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

Enum value maps for GrpclbRouteType.

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

Enum value maps for ClientConfigureRequest_RpcType.

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

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

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{
    ServiceName: "grpc.testing.LoadBalancerStatsService",
    HandlerType: (*LoadBalancerStatsServiceServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "GetClientStats",
            Handler:    _LoadBalancerStatsService_GetClientStats_Handler,
        },
        {
            MethodName: "GetClientAccumulatedStats",
            Handler:    _LoadBalancerStatsService_GetClientAccumulatedStats_Handler,
        },
    },
    Streams:  []grpc.StreamDesc{},
    Metadata: "grpc/testing/test.proto",
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func RegisterBenchmarkServiceServer Uses

func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)

func RegisterLoadBalancerStatsServiceServer Uses

func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer)

func RegisterReconnectServiceServer Uses

func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)

func RegisterReportQpsScenarioServiceServer Uses

func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)

func RegisterTestServiceServer Uses

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

func RegisterUnimplementedServiceServer Uses

func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)

func RegisterWorkerServiceServer Uses

func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

func RegisterXdsUpdateClientConfigureServiceServer Uses

func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)

func RegisterXdsUpdateHealthServiceServer Uses

func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)

type BenchmarkServiceClient Uses

type BenchmarkServiceClient interface {
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
    // Repeated sequence of one request followed by one response.
    // Should be called streaming ping-pong
    // The server returns the client payload as-is on each response
    StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error)
    // Single-sided unbounded streaming from client to server
    // The server returns the client payload as-is once the client does WritesDone
    StreamingFromClient(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingFromClientClient, error)
    // Single-sided unbounded streaming from server to client
    // The server repeatedly returns the client payload as-is
    StreamingFromServer(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (BenchmarkService_StreamingFromServerClient, error)
    // Two-sided unbounded streaming between server to client
    // Both sides send the content of their own choice to the other
    StreamingBothWays(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingBothWaysClient, error)
}

BenchmarkServiceClient is the client API for BenchmarkService service.

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

func NewBenchmarkServiceClient Uses

func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient

type BenchmarkServiceServer Uses

type BenchmarkServiceServer interface {
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
    // Repeated sequence of one request followed by one response.
    // Should be called streaming ping-pong
    // The server returns the client payload as-is on each response
    StreamingCall(BenchmarkService_StreamingCallServer) error
    // Single-sided unbounded streaming from client to server
    // The server returns the client payload as-is once the client does WritesDone
    StreamingFromClient(BenchmarkService_StreamingFromClientServer) error
    // Single-sided unbounded streaming from server to client
    // The server repeatedly returns the client payload as-is
    StreamingFromServer(*SimpleRequest, BenchmarkService_StreamingFromServerServer) error
    // Two-sided unbounded streaming between server to client
    // Both sides send the content of their own choice to the other
    StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error
    // contains filtered or unexported methods
}

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

type BenchmarkService_StreamingBothWaysClient Uses

type BenchmarkService_StreamingBothWaysClient interface {
    Send(*SimpleRequest) error
    Recv() (*SimpleResponse, error)
    grpc.ClientStream
}

type BenchmarkService_StreamingBothWaysServer Uses

type BenchmarkService_StreamingBothWaysServer interface {
    Send(*SimpleResponse) error
    Recv() (*SimpleRequest, error)
    grpc.ServerStream
}

type BenchmarkService_StreamingCallClient Uses

type BenchmarkService_StreamingCallClient interface {
    Send(*SimpleRequest) error
    Recv() (*SimpleResponse, error)
    grpc.ClientStream
}

type BenchmarkService_StreamingCallServer Uses

type BenchmarkService_StreamingCallServer interface {
    Send(*SimpleResponse) error
    Recv() (*SimpleRequest, error)
    grpc.ServerStream
}

type BenchmarkService_StreamingFromClientClient Uses

type BenchmarkService_StreamingFromClientClient interface {
    Send(*SimpleRequest) error
    CloseAndRecv() (*SimpleResponse, error)
    grpc.ClientStream
}

type BenchmarkService_StreamingFromClientServer Uses

type BenchmarkService_StreamingFromClientServer interface {
    SendAndClose(*SimpleResponse) error
    Recv() (*SimpleRequest, error)
    grpc.ServerStream
}

type BenchmarkService_StreamingFromServerClient Uses

type BenchmarkService_StreamingFromServerClient interface {
    Recv() (*SimpleResponse, error)
    grpc.ClientStream
}

type BenchmarkService_StreamingFromServerServer Uses

type BenchmarkService_StreamingFromServerServer interface {
    Send(*SimpleResponse) error
    grpc.ServerStream
}

type BoolValue Uses

type BoolValue struct {

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

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

func (*BoolValue) Descriptor Uses

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

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue) GetValue Uses

func (x *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage Uses

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect Uses

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

func (*BoolValue) Reset Uses

func (x *BoolValue) Reset()

func (*BoolValue) String Uses

func (x *BoolValue) String() string

type ByteBufferParams Uses

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

func (*ByteBufferParams) Descriptor Uses

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

Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.

func (*ByteBufferParams) GetReqSize Uses

func (x *ByteBufferParams) GetReqSize() int32

func (*ByteBufferParams) GetRespSize Uses

func (x *ByteBufferParams) GetRespSize() int32

func (*ByteBufferParams) ProtoMessage Uses

func (*ByteBufferParams) ProtoMessage()

func (*ByteBufferParams) ProtoReflect Uses

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

func (*ByteBufferParams) Reset Uses

func (x *ByteBufferParams) Reset()

func (*ByteBufferParams) String Uses

func (x *ByteBufferParams) String() string

type ChannelArg Uses

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

func (*ChannelArg) Descriptor Uses

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

Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.

func (*ChannelArg) GetIntValue Uses

func (x *ChannelArg) GetIntValue() int32

func (*ChannelArg) GetName Uses

func (x *ChannelArg) GetName() string

func (*ChannelArg) GetStrValue Uses

func (x *ChannelArg) GetStrValue() string

func (*ChannelArg) GetValue Uses

func (m *ChannelArg) GetValue() isChannelArg_Value

func (*ChannelArg) ProtoMessage Uses

func (*ChannelArg) ProtoMessage()

func (*ChannelArg) ProtoReflect Uses

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

func (*ChannelArg) Reset Uses

func (x *ChannelArg) Reset()

func (*ChannelArg) String Uses

func (x *ChannelArg) String() string

type ChannelArg_IntValue Uses

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

type ChannelArg_StrValue Uses

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

type ClientArgs Uses

type ClientArgs struct {

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

func (*ClientArgs) Descriptor Uses

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

Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.

func (*ClientArgs) GetArgtype Uses

func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

func (*ClientArgs) GetMark Uses

func (x *ClientArgs) GetMark() *Mark

func (*ClientArgs) GetSetup Uses

func (x *ClientArgs) GetSetup() *ClientConfig

func (*ClientArgs) ProtoMessage Uses

func (*ClientArgs) ProtoMessage()

func (*ClientArgs) ProtoReflect Uses

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

func (*ClientArgs) Reset Uses

func (x *ClientArgs) Reset()

func (*ClientArgs) String Uses

func (x *ClientArgs) String() string

type ClientArgs_Mark Uses

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

type ClientArgs_Setup Uses

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

type ClientConfig Uses

type ClientConfig struct {

    // List of targets to connect to. At least one target needs to be specified.
    ServerTargets  []string        `protobuf:"bytes,1,rep,name=server_targets,json=serverTargets,proto3" json:"server_targets,omitempty"`
    ClientType     ClientType      `protobuf:"varint,2,opt,name=client_type,json=clientType,proto3,enum=grpc.testing.ClientType" json:"client_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,3,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
    // How many concurrent RPCs to start for each channel.
    // For synchronous client, use a separate thread for each outstanding RPC.
    OutstandingRpcsPerChannel int32 `protobuf:"varint,4,opt,name=outstanding_rpcs_per_channel,json=outstandingRpcsPerChannel,proto3" json:"outstanding_rpcs_per_channel,omitempty"`
    // Number of independent client channels to create.
    // i-th channel will connect to server_target[i % server_targets.size()]
    ClientChannels int32 `protobuf:"varint,5,opt,name=client_channels,json=clientChannels,proto3" json:"client_channels,omitempty"`
    // Only for async client. Number of threads to use to start/manage RPCs.
    AsyncClientThreads int32   `protobuf:"varint,7,opt,name=async_client_threads,json=asyncClientThreads,proto3" json:"async_client_threads,omitempty"`
    RpcType            RpcType `protobuf:"varint,8,opt,name=rpc_type,json=rpcType,proto3,enum=grpc.testing.RpcType" json:"rpc_type,omitempty"`
    // The requested load for the entire client (aggregated over all the threads).
    LoadParams      *LoadParams      `protobuf:"bytes,10,opt,name=load_params,json=loadParams,proto3" json:"load_params,omitempty"`
    PayloadConfig   *PayloadConfig   `protobuf:"bytes,11,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
    HistogramParams *HistogramParams `protobuf:"bytes,12,opt,name=histogram_params,json=histogramParams,proto3" json:"histogram_params,omitempty"`
    // Specify the cores we should run the client on, if desired
    CoreList  []int32 `protobuf:"varint,13,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
    CoreLimit int32   `protobuf:"varint,14,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
    // If we use an OTHER_CLIENT client_type, this string gives more detail
    OtherClientApi string        `protobuf:"bytes,15,opt,name=other_client_api,json=otherClientApi,proto3" json:"other_client_api,omitempty"`
    ChannelArgs    []*ChannelArg `protobuf:"bytes,16,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"`
    // Number of threads that share each completion queue
    ThreadsPerCq int32 `protobuf:"varint,17,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
    // Number of messages on a stream before it gets finished/restarted
    MessagesPerStream int32 `protobuf:"varint,18,opt,name=messages_per_stream,json=messagesPerStream,proto3" json:"messages_per_stream,omitempty"`
    // Use coalescing API when possible.
    UseCoalesceApi bool `protobuf:"varint,19,opt,name=use_coalesce_api,json=useCoalesceApi,proto3" json:"use_coalesce_api,omitempty"`
    // If 0, disabled. Else, specifies the period between gathering latency
    // medians in milliseconds.
    MedianLatencyCollectionIntervalMillis int32 `protobuf:"varint,20,opt,name=median_latency_collection_interval_millis,json=medianLatencyCollectionIntervalMillis,proto3" json:"median_latency_collection_interval_millis,omitempty"`
    // Number of client processes. 0 indicates no restriction.
    ClientProcesses int32 `protobuf:"varint,21,opt,name=client_processes,json=clientProcesses,proto3" json:"client_processes,omitempty"`
    // contains filtered or unexported fields
}

func (*ClientConfig) Descriptor Uses

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

Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

func (*ClientConfig) GetAsyncClientThreads Uses

func (x *ClientConfig) GetAsyncClientThreads() int32

func (*ClientConfig) GetChannelArgs Uses

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

func (*ClientConfig) GetClientChannels Uses

func (x *ClientConfig) GetClientChannels() int32

func (*ClientConfig) GetClientProcesses Uses

func (x *ClientConfig) GetClientProcesses() int32

func (*ClientConfig) GetClientType Uses

func (x *ClientConfig) GetClientType() ClientType

func (*ClientConfig) GetCoreLimit Uses

func (x *ClientConfig) GetCoreLimit() int32

func (*ClientConfig) GetCoreList Uses

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

func (*ClientConfig) GetHistogramParams Uses

func (x *ClientConfig) GetHistogramParams() *HistogramParams

func (*ClientConfig) GetLoadParams Uses

func (x *ClientConfig) GetLoadParams() *LoadParams

func (*ClientConfig) GetMedianLatencyCollectionIntervalMillis Uses

func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32

func (*ClientConfig) GetMessagesPerStream Uses

func (x *ClientConfig) GetMessagesPerStream() int32

func (*ClientConfig) GetOtherClientApi Uses

func (x *ClientConfig) GetOtherClientApi() string

func (*ClientConfig) GetOutstandingRpcsPerChannel Uses

func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32

func (*ClientConfig) GetPayloadConfig Uses

func (x *ClientConfig) GetPayloadConfig() *PayloadConfig

func (*ClientConfig) GetRpcType Uses

func (x *ClientConfig) GetRpcType() RpcType

func (*ClientConfig) GetSecurityParams Uses

func (x *ClientConfig) GetSecurityParams() *SecurityParams

func (*ClientConfig) GetServerTargets Uses

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

func (*ClientConfig) GetThreadsPerCq Uses

func (x *ClientConfig) GetThreadsPerCq() int32

func (*ClientConfig) GetUseCoalesceApi Uses

func (x *ClientConfig) GetUseCoalesceApi() bool

func (*ClientConfig) ProtoMessage Uses

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) ProtoReflect Uses

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

func (*ClientConfig) Reset Uses

func (x *ClientConfig) Reset()

func (*ClientConfig) String Uses

func (x *ClientConfig) String() string

type ClientConfigureRequest Uses

type ClientConfigureRequest struct {

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

Configurations for a test client.

func (*ClientConfigureRequest) Descriptor Uses

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

Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest) GetMetadata Uses

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

func (*ClientConfigureRequest) GetTimeoutSec Uses

func (x *ClientConfigureRequest) GetTimeoutSec() int32

func (*ClientConfigureRequest) GetTypes Uses

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

func (*ClientConfigureRequest) ProtoMessage Uses

func (*ClientConfigureRequest) ProtoMessage()

func (*ClientConfigureRequest) ProtoReflect Uses

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

func (*ClientConfigureRequest) Reset Uses

func (x *ClientConfigureRequest) Reset()

func (*ClientConfigureRequest) String Uses

func (x *ClientConfigureRequest) String() string

type ClientConfigureRequest_Metadata Uses

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

Metadata to be attached for the given type of RPCs.

func (*ClientConfigureRequest_Metadata) Descriptor Uses

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

Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.

func (*ClientConfigureRequest_Metadata) GetKey Uses

func (x *ClientConfigureRequest_Metadata) GetKey() string

func (*ClientConfigureRequest_Metadata) GetType Uses

func (x *ClientConfigureRequest_Metadata) GetType() ClientConfigureRequest_RpcType

func (*ClientConfigureRequest_Metadata) GetValue Uses

func (x *ClientConfigureRequest_Metadata) GetValue() string

func (*ClientConfigureRequest_Metadata) ProtoMessage Uses

func (*ClientConfigureRequest_Metadata) ProtoMessage()

func (*ClientConfigureRequest_Metadata) ProtoReflect Uses

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

func (*ClientConfigureRequest_Metadata) Reset Uses

func (x *ClientConfigureRequest_Metadata) Reset()

func (*ClientConfigureRequest_Metadata) String Uses

func (x *ClientConfigureRequest_Metadata) String() string

type ClientConfigureRequest_RpcType Uses

type ClientConfigureRequest_RpcType int32

Type of RPCs to send.

const (
    ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0
    ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1
)

func (ClientConfigureRequest_RpcType) Descriptor Uses

func (ClientConfigureRequest_RpcType) Descriptor() protoreflect.EnumDescriptor

func (ClientConfigureRequest_RpcType) Enum Uses

func (x ClientConfigureRequest_RpcType) Enum() *ClientConfigureRequest_RpcType

func (ClientConfigureRequest_RpcType) EnumDescriptor Uses

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

Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.

func (ClientConfigureRequest_RpcType) Number Uses

func (x ClientConfigureRequest_RpcType) Number() protoreflect.EnumNumber

func (ClientConfigureRequest_RpcType) String Uses

func (x ClientConfigureRequest_RpcType) String() string

func (ClientConfigureRequest_RpcType) Type Uses

func (ClientConfigureRequest_RpcType) Type() protoreflect.EnumType

type ClientConfigureResponse Uses

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

Response for updating a test client's configuration.

func (*ClientConfigureResponse) Descriptor Uses

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

Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.

func (*ClientConfigureResponse) ProtoMessage Uses

func (*ClientConfigureResponse) ProtoMessage()

func (*ClientConfigureResponse) ProtoReflect Uses

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

func (*ClientConfigureResponse) Reset Uses

func (x *ClientConfigureResponse) Reset()

func (*ClientConfigureResponse) String Uses

func (x *ClientConfigureResponse) String() string

type ClientStats Uses

type ClientStats struct {

    // Latency histogram. Data points are in nanoseconds.
    Latencies *HistogramData `protobuf:"bytes,1,opt,name=latencies,proto3" json:"latencies,omitempty"`
    // See ServerStats for details.
    TimeElapsed float64 `protobuf:"fixed64,2,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
    TimeUser    float64 `protobuf:"fixed64,3,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
    TimeSystem  float64 `protobuf:"fixed64,4,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
    // Number of failed requests (one row per status code seen)
    RequestResults []*RequestResultCount `protobuf:"bytes,5,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
    // Number of polls called inside completion queue
    CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
    // Core library stats
    CoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
    // contains filtered or unexported fields
}

func (*ClientStats) Descriptor Uses

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

Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.

func (*ClientStats) GetCoreStats Uses

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

func (*ClientStats) GetCqPollCount Uses

func (x *ClientStats) GetCqPollCount() uint64

func (*ClientStats) GetLatencies Uses

func (x *ClientStats) GetLatencies() *HistogramData

func (*ClientStats) GetRequestResults Uses

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

func (*ClientStats) GetTimeElapsed Uses

func (x *ClientStats) GetTimeElapsed() float64

func (*ClientStats) GetTimeSystem Uses

func (x *ClientStats) GetTimeSystem() float64

func (*ClientStats) GetTimeUser Uses

func (x *ClientStats) GetTimeUser() float64

func (*ClientStats) ProtoMessage Uses

func (*ClientStats) ProtoMessage()

func (*ClientStats) ProtoReflect Uses

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

func (*ClientStats) Reset Uses

func (x *ClientStats) Reset()

func (*ClientStats) String Uses

func (x *ClientStats) String() string

type ClientStatus Uses

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

func (*ClientStatus) Descriptor Uses

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

Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.

func (*ClientStatus) GetStats Uses

func (x *ClientStatus) GetStats() *ClientStats

func (*ClientStatus) ProtoMessage Uses

func (*ClientStatus) ProtoMessage()

func (*ClientStatus) ProtoReflect Uses

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

func (*ClientStatus) Reset Uses

func (x *ClientStatus) Reset()

func (*ClientStatus) String Uses

func (x *ClientStatus) String() string

type ClientType Uses

type ClientType int32
const (
    // Many languages support a basic distinction between using
    // sync or async client, and this allows the specification
    ClientType_SYNC_CLIENT     ClientType = 0
    ClientType_ASYNC_CLIENT    ClientType = 1
    ClientType_OTHER_CLIENT    ClientType = 2 // used for some language-specific variants
    ClientType_CALLBACK_CLIENT ClientType = 3
)

func (ClientType) Descriptor Uses

func (ClientType) Descriptor() protoreflect.EnumDescriptor

func (ClientType) Enum Uses

func (x ClientType) Enum() *ClientType

func (ClientType) EnumDescriptor Uses

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

Deprecated: Use ClientType.Descriptor instead.

func (ClientType) Number Uses

func (x ClientType) Number() protoreflect.EnumNumber

func (ClientType) String Uses

func (x ClientType) String() string

func (ClientType) Type Uses

func (ClientType) Type() protoreflect.EnumType

type ClosedLoopParams Uses

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

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

func (*ClosedLoopParams) Descriptor Uses

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

Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.

func (*ClosedLoopParams) ProtoMessage Uses

func (*ClosedLoopParams) ProtoMessage()

func (*ClosedLoopParams) ProtoReflect Uses

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

func (*ClosedLoopParams) Reset Uses

func (x *ClosedLoopParams) Reset()

func (*ClosedLoopParams) String Uses

func (x *ClosedLoopParams) String() string

type ComplexProtoParams Uses

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

func (*ComplexProtoParams) Descriptor Uses

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

Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.

func (*ComplexProtoParams) ProtoMessage Uses

func (*ComplexProtoParams) ProtoMessage()

func (*ComplexProtoParams) ProtoReflect Uses

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

func (*ComplexProtoParams) Reset Uses

func (x *ComplexProtoParams) Reset()

func (*ComplexProtoParams) String Uses

func (x *ComplexProtoParams) String() string

type CoreRequest Uses

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

func (*CoreRequest) Descriptor Uses

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

Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.

func (*CoreRequest) ProtoMessage Uses

func (*CoreRequest) ProtoMessage()

func (*CoreRequest) ProtoReflect Uses

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

func (*CoreRequest) Reset Uses

func (x *CoreRequest) Reset()

func (*CoreRequest) String Uses

func (x *CoreRequest) String() string

type CoreResponse Uses

type CoreResponse struct {

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

func (*CoreResponse) Descriptor Uses

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

Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.

func (*CoreResponse) GetCores Uses

func (x *CoreResponse) GetCores() int32

func (*CoreResponse) ProtoMessage Uses

func (*CoreResponse) ProtoMessage()

func (*CoreResponse) ProtoReflect Uses

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

func (*CoreResponse) Reset Uses

func (x *CoreResponse) Reset()

func (*CoreResponse) String Uses

func (x *CoreResponse) String() string

type EchoStatus Uses

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

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

func (*EchoStatus) Descriptor Uses

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

Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

func (*EchoStatus) GetCode Uses

func (x *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage Uses

func (x *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage Uses

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) ProtoReflect Uses

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

func (*EchoStatus) Reset Uses

func (x *EchoStatus) Reset()

func (*EchoStatus) String Uses

func (x *EchoStatus) String() string

type Empty Uses

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

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

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

func (*Empty) Descriptor Uses

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect Uses

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

func (*Empty) Reset Uses

func (x *Empty) Reset()

func (*Empty) String Uses

func (x *Empty) String() string

type GrpclbRouteType Uses

type GrpclbRouteType int32

The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependent.

const (
    // Server didn't detect the route that a client took to reach it.
    GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0
    // Indicates that a client reached a server via gRPCLB fallback.
    GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1
    // Indicates that a client reached a server as a gRPCLB-given backend.
    GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND GrpclbRouteType = 2
)

func (GrpclbRouteType) Descriptor Uses

func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor

func (GrpclbRouteType) Enum Uses

func (x GrpclbRouteType) Enum() *GrpclbRouteType

func (GrpclbRouteType) EnumDescriptor Uses

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

Deprecated: Use GrpclbRouteType.Descriptor instead.

func (GrpclbRouteType) Number Uses

func (x GrpclbRouteType) Number() protoreflect.EnumNumber

func (GrpclbRouteType) String Uses

func (x GrpclbRouteType) String() string

func (GrpclbRouteType) Type Uses

func (GrpclbRouteType) Type() protoreflect.EnumType

type HistogramData Uses

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

Histogram data based on grpc/support/histogram.c

func (*HistogramData) Descriptor Uses

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

Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.

func (*HistogramData) GetBucket Uses

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

func (*HistogramData) GetCount Uses

func (x *HistogramData) GetCount() float64

func (*HistogramData) GetMaxSeen Uses

func (x *HistogramData) GetMaxSeen() float64

func (*HistogramData) GetMinSeen Uses

func (x *HistogramData) GetMinSeen() float64

func (*HistogramData) GetSum Uses

func (x *HistogramData) GetSum() float64

func (*HistogramData) GetSumOfSquares Uses

func (x *HistogramData) GetSumOfSquares() float64

func (*HistogramData) ProtoMessage Uses

func (*HistogramData) ProtoMessage()

func (*HistogramData) ProtoReflect Uses

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

func (*HistogramData) Reset Uses

func (x *HistogramData) Reset()

func (*HistogramData) String Uses

func (x *HistogramData) String() string

type HistogramParams Uses

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

Histogram params based on grpc/support/histogram.c

func (*HistogramParams) Descriptor Uses

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

Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.

func (*HistogramParams) GetMaxPossible Uses

func (x *HistogramParams) GetMaxPossible() float64

func (*HistogramParams) GetResolution Uses

func (x *HistogramParams) GetResolution() float64

func (*HistogramParams) ProtoMessage Uses

func (*HistogramParams) ProtoMessage()

func (*HistogramParams) ProtoReflect Uses

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

func (*HistogramParams) Reset Uses

func (x *HistogramParams) Reset()

func (*HistogramParams) String Uses

func (x *HistogramParams) String() string

type LoadBalancerAccumulatedStatsRequest Uses

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

Request for retrieving a test client's accumulated stats.

func (*LoadBalancerAccumulatedStatsRequest) Descriptor Uses

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

Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage Uses

func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()

func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect Uses

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

func (*LoadBalancerAccumulatedStatsRequest) Reset Uses

func (x *LoadBalancerAccumulatedStatsRequest) Reset()

func (*LoadBalancerAccumulatedStatsRequest) String Uses

func (x *LoadBalancerAccumulatedStatsRequest) String() string

type LoadBalancerAccumulatedStatsResponse Uses

type LoadBalancerAccumulatedStatsResponse struct {

    // The total number of RPCs have ever issued for each type.
    // Deprecated: use stats_per_method.rpcs_started instead.
    //
    // Deprecated: Do not use.
    NumRpcsStartedByMethod map[string]int32 `protobuf:"bytes,1,rep,name=num_rpcs_started_by_method,json=numRpcsStartedByMethod,proto3" json:"num_rpcs_started_by_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // The total number of RPCs have ever completed successfully for each type.
    // Deprecated: use stats_per_method.result instead.
    //
    // Deprecated: Do not use.
    NumRpcsSucceededByMethod map[string]int32 `protobuf:"bytes,2,rep,name=num_rpcs_succeeded_by_method,json=numRpcsSucceededByMethod,proto3" json:"num_rpcs_succeeded_by_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // The total number of RPCs have ever failed for each type.
    // Deprecated: use stats_per_method.result instead.
    //
    // Deprecated: Do not use.
    NumRpcsFailedByMethod map[string]int32 `protobuf:"bytes,3,rep,name=num_rpcs_failed_by_method,json=numRpcsFailedByMethod,proto3" json:"num_rpcs_failed_by_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // Per-method RPC statistics.  The key is the full method path; i.e.
    // "/proto.package.ServiceName/MethodName".
    StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `protobuf:"bytes,4,rep,name=stats_per_method,json=statsPerMethod,proto3" json:"stats_per_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

Accumulated stats for RPCs sent by a test client.

func (*LoadBalancerAccumulatedStatsResponse) Descriptor Uses

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

Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod Uses

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

Deprecated: Do not use.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod Uses

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

Deprecated: Do not use.

func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod Uses

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

Deprecated: Do not use.

func (*LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod Uses

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

func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage Uses

func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()

func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect Uses

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

func (*LoadBalancerAccumulatedStatsResponse) Reset Uses

func (x *LoadBalancerAccumulatedStatsResponse) Reset()

func (*LoadBalancerAccumulatedStatsResponse) String Uses

func (x *LoadBalancerAccumulatedStatsResponse) String() string

type LoadBalancerAccumulatedStatsResponse_MethodStats Uses

type LoadBalancerAccumulatedStatsResponse_MethodStats struct {

    // The number of RPCs that were started for this method.
    RpcsStarted int32 `protobuf:"varint,1,opt,name=rpcs_started,json=rpcsStarted,proto3" json:"rpcs_started,omitempty"`
    // The number of RPCs that completed with each status for this method.  The
    // key is the integral value of a google.rpc.Code; the value is the count.
    Result map[int32]int32 `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor Uses

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

Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult Uses

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

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted Uses

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted() int32

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage Uses

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage()

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect Uses

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

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset Uses

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) Reset()

func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String Uses

func (x *LoadBalancerAccumulatedStatsResponse_MethodStats) String() string

type LoadBalancerStatsRequest Uses

type LoadBalancerStatsRequest struct {

    // Request stats for the next num_rpcs sent by client.
    NumRpcs int32 `protobuf:"varint,1,opt,name=num_rpcs,json=numRpcs,proto3" json:"num_rpcs,omitempty"`
    // If num_rpcs have not completed within timeout_sec, return partial results.
    TimeoutSec int32 `protobuf:"varint,2,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`
    // contains filtered or unexported fields
}

func (*LoadBalancerStatsRequest) Descriptor Uses

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

Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsRequest) GetNumRpcs Uses

func (x *LoadBalancerStatsRequest) GetNumRpcs() int32

func (*LoadBalancerStatsRequest) GetTimeoutSec Uses

func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32

func (*LoadBalancerStatsRequest) ProtoMessage Uses

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest) ProtoReflect Uses

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

func (*LoadBalancerStatsRequest) Reset Uses

func (x *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest) String Uses

func (x *LoadBalancerStatsRequest) String() string

type LoadBalancerStatsResponse Uses

type LoadBalancerStatsResponse struct {

    // The number of completed RPCs for each peer.
    RpcsByPeer map[string]int32 `protobuf:"bytes,1,rep,name=rpcs_by_peer,json=rpcsByPeer,proto3" json:"rpcs_by_peer,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // The number of RPCs that failed to record a remote peer.
    NumFailures  int32                                            `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
    RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `protobuf:"bytes,3,rep,name=rpcs_by_method,json=rpcsByMethod,proto3" json:"rpcs_by_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse) Descriptor Uses

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

Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse) GetNumFailures Uses

func (x *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod Uses

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

func (*LoadBalancerStatsResponse) GetRpcsByPeer Uses

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

func (*LoadBalancerStatsResponse) ProtoMessage Uses

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) ProtoReflect Uses

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

func (*LoadBalancerStatsResponse) Reset Uses

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) String Uses

func (x *LoadBalancerStatsResponse) String() string

type LoadBalancerStatsResponse_RpcsByPeer Uses

type LoadBalancerStatsResponse_RpcsByPeer struct {

    // The number of completed RPCs for each peer.
    RpcsByPeer map[string]int32 `protobuf:"bytes,1,rep,name=rpcs_by_peer,json=rpcsByPeer,proto3" json:"rpcs_by_peer,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor Uses

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

Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer Uses

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

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage Uses

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect Uses

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

func (*LoadBalancerStatsResponse_RpcsByPeer) Reset Uses

func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()

func (*LoadBalancerStatsResponse_RpcsByPeer) String Uses

func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string

type LoadBalancerStatsServiceClient Uses

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

LoadBalancerStatsServiceClient is the client API for LoadBalancerStatsService service.

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

func NewLoadBalancerStatsServiceClient Uses

func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient

type LoadBalancerStatsServiceServer Uses

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

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

type LoadParams Uses

type LoadParams struct {

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

func (*LoadParams) Descriptor Uses

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

Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.

func (*LoadParams) GetClosedLoop Uses

func (x *LoadParams) GetClosedLoop() *ClosedLoopParams

func (*LoadParams) GetLoad Uses

func (m *LoadParams) GetLoad() isLoadParams_Load

func (*LoadParams) GetPoisson Uses

func (x *LoadParams) GetPoisson() *PoissonParams

func (*LoadParams) ProtoMessage Uses

func (*LoadParams) ProtoMessage()

func (*LoadParams) ProtoReflect Uses

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

func (*LoadParams) Reset Uses

func (x *LoadParams) Reset()

func (*LoadParams) String Uses

func (x *LoadParams) String() string

type LoadParams_ClosedLoop Uses

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

type LoadParams_Poisson Uses

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

type Mark Uses

type Mark struct {

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

Request current stats

func (*Mark) Descriptor Uses

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

Deprecated: Use Mark.ProtoReflect.Descriptor instead.

func (*Mark) GetReset_ Uses

func (x *Mark) GetReset_() bool

func (*Mark) ProtoMessage Uses

func (*Mark) ProtoMessage()

func (*Mark) ProtoReflect Uses

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

func (*Mark) Reset Uses

func (x *Mark) Reset()

func (*Mark) String Uses

func (x *Mark) String() string

type Payload Uses

type Payload struct {

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

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

func (*Payload) Descriptor Uses

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetBody Uses

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

func (*Payload) GetType Uses

func (x *Payload) GetType() PayloadType

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect Uses

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

func (*Payload) Reset Uses

func (x *Payload) Reset()

func (*Payload) String Uses

func (x *Payload) String() string

type PayloadConfig Uses

type PayloadConfig struct {

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

func (*PayloadConfig) Descriptor Uses

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

Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.

func (*PayloadConfig) GetBytebufParams Uses

func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams

func (*PayloadConfig) GetComplexParams Uses

func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams

func (*PayloadConfig) GetPayload Uses

func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

func (*PayloadConfig) GetSimpleParams Uses

func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams

func (*PayloadConfig) ProtoMessage Uses

func (*PayloadConfig) ProtoMessage()

func (*PayloadConfig) ProtoReflect Uses

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

func (*PayloadConfig) Reset Uses

func (x *PayloadConfig) Reset()

func (*PayloadConfig) String Uses

func (x *PayloadConfig) String() string

type PayloadConfig_BytebufParams Uses

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

type PayloadConfig_ComplexParams Uses

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

type PayloadConfig_SimpleParams Uses

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

type PayloadType Uses

type PayloadType int32

The type of payload that should be returned.

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

func (PayloadType) Descriptor Uses

func (PayloadType) Descriptor() protoreflect.EnumDescriptor

func (PayloadType) Enum Uses

func (x PayloadType) Enum() *PayloadType

func (PayloadType) EnumDescriptor Uses

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

Deprecated: Use PayloadType.Descriptor instead.

func (PayloadType) Number Uses

func (x PayloadType) Number() protoreflect.EnumNumber

func (PayloadType) String Uses

func (x PayloadType) String() string

func (PayloadType) Type Uses

func (PayloadType) Type() protoreflect.EnumType

type PoissonParams Uses

type PoissonParams struct {

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

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

func (*PoissonParams) Descriptor Uses

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

Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.

func (*PoissonParams) GetOfferedLoad Uses

func (x *PoissonParams) GetOfferedLoad() float64

func (*PoissonParams) ProtoMessage Uses

func (*PoissonParams) ProtoMessage()

func (*PoissonParams) ProtoReflect Uses

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

func (*PoissonParams) Reset Uses

func (x *PoissonParams) Reset()

func (*PoissonParams) String Uses

func (x *PoissonParams) String() string

type ReconnectInfo Uses

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

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

func (*ReconnectInfo) Descriptor Uses

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

Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.

func (*ReconnectInfo) GetBackoffMs Uses

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

func (*ReconnectInfo) GetPassed Uses

func (x *ReconnectInfo) GetPassed() bool

func (*ReconnectInfo) ProtoMessage Uses

func (*ReconnectInfo) ProtoMessage()

func (*ReconnectInfo) ProtoReflect Uses

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

func (*ReconnectInfo) Reset Uses

func (x *ReconnectInfo) Reset()

func (*ReconnectInfo) String Uses

func (x *ReconnectInfo) String() string

type ReconnectParams Uses

type ReconnectParams struct {
    MaxReconnectBackoffMs int32 `protobuf:"varint,1,opt,name=max_reconnect_backoff_ms,json=maxReconnectBackoffMs,proto3" json:"max_reconnect_backoff_ms,omitempty"`
    // contains filtered or unexported fields
}

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

func (*ReconnectParams) Descriptor Uses

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

Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.

func (*ReconnectParams) GetMaxReconnectBackoffMs Uses

func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32

func (*ReconnectParams) ProtoMessage Uses

func (*ReconnectParams) ProtoMessage()

func (*ReconnectParams) ProtoReflect Uses

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

func (*ReconnectParams) Reset Uses

func (x *ReconnectParams) Reset()

func (*ReconnectParams) String Uses

func (x *ReconnectParams) String() string

type ReconnectServiceClient Uses

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

ReconnectServiceClient is the client API for ReconnectService service.

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

func NewReconnectServiceClient Uses

func NewReconnectServiceClient(cc grpc.ClientConnInterface) ReconnectServiceClient

type ReconnectServiceServer Uses

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

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

type ReportQpsScenarioServiceClient Uses

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

ReportQpsScenarioServiceClient is the client API for ReportQpsScenarioService service.

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

func NewReportQpsScenarioServiceClient Uses

func NewReportQpsScenarioServiceClient(cc grpc.ClientConnInterface) ReportQpsScenarioServiceClient

type ReportQpsScenarioServiceServer Uses

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

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

type RequestResultCount Uses

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

func (*RequestResultCount) Descriptor Uses

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

Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.

func (*RequestResultCount) GetCount Uses

func (x *RequestResultCount) GetCount() int64

func (*RequestResultCount) GetStatusCode Uses

func (x *RequestResultCount) GetStatusCode() int32

func (*RequestResultCount) ProtoMessage Uses

func (*RequestResultCount) ProtoMessage()

func (*RequestResultCount) ProtoReflect Uses

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

func (*RequestResultCount) Reset Uses

func (x *RequestResultCount) Reset()

func (*RequestResultCount) String Uses

func (x *RequestResultCount) String() string

type ResponseParameters Uses

type ResponseParameters struct {

    // Desired payload sizes in responses from the server.
    Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
    // Desired interval between consecutive responses in the response stream in
    // microseconds.
    IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
    // Whether to request the server to compress the response. This field is
    // "nullable" in order to interoperate seamlessly with clients not able to
    // implement the full compression tests by introspecting the call to verify
    // the response's compression status.
    Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,omitempty"`
    // contains filtered or unexported fields
}

Configuration for a particular response.

func (*ResponseParameters) Descriptor Uses

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

Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.

func (*ResponseParameters) GetCompressed Uses

func (x *ResponseParameters) GetCompressed() *BoolValue

func (*ResponseParameters) GetIntervalUs Uses

func (x *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize Uses

func (x *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage Uses

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) ProtoReflect Uses

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

func (*ResponseParameters) Reset Uses

func (x *ResponseParameters) Reset()

func (*ResponseParameters) String Uses

func (x *ResponseParameters) String() string

type RpcType Uses

type RpcType int32
const (
    RpcType_UNARY                 RpcType = 0
    RpcType_STREAMING             RpcType = 1
    RpcType_STREAMING_FROM_CLIENT RpcType = 2
    RpcType_STREAMING_FROM_SERVER RpcType = 3
    RpcType_STREAMING_BOTH_WAYS   RpcType = 4
)

func (RpcType) Descriptor Uses

func (RpcType) Descriptor() protoreflect.EnumDescriptor

func (RpcType) Enum Uses

func (x RpcType) Enum() *RpcType

func (RpcType) EnumDescriptor Uses

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

Deprecated: Use RpcType.Descriptor instead.

func (RpcType) Number Uses

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String Uses

func (x RpcType) String() string

func (RpcType) Type Uses

func (RpcType) Type() protoreflect.EnumType

type Scenario Uses

type Scenario struct {

    // Human readable name for this scenario
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Client configuration
    ClientConfig *ClientConfig `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
    // Number of clients to start for the test
    NumClients int32 `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
    // Server configuration
    ServerConfig *ServerConfig `protobuf:"bytes,4,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
    // Number of servers to start for the test
    NumServers int32 `protobuf:"varint,5,opt,name=num_servers,json=numServers,proto3" json:"num_servers,omitempty"`
    // Warmup period, in seconds
    WarmupSeconds int32 `protobuf:"varint,6,opt,name=warmup_seconds,json=warmupSeconds,proto3" json:"warmup_seconds,omitempty"`
    // Benchmark time, in seconds
    BenchmarkSeconds int32 `protobuf:"varint,7,opt,name=benchmark_seconds,json=benchmarkSeconds,proto3" json:"benchmark_seconds,omitempty"`
    // Number of workers to spawn locally (usually zero)
    SpawnLocalWorkerCount int32 `protobuf:"varint,8,opt,name=spawn_local_worker_count,json=spawnLocalWorkerCount,proto3" json:"spawn_local_worker_count,omitempty"`
    // contains filtered or unexported fields
}

A single performance scenario: input to qps_json_driver

func (*Scenario) Descriptor Uses

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

Deprecated: Use Scenario.ProtoReflect.Descriptor instead.

func (*Scenario) GetBenchmarkSeconds Uses

func (x *Scenario) GetBenchmarkSeconds() int32

func (*Scenario) GetClientConfig Uses

func (x *Scenario) GetClientConfig() *ClientConfig

func (*Scenario) GetName Uses

func (x *Scenario) GetName() string

func (*Scenario) GetNumClients Uses

func (x *Scenario) GetNumClients() int32

func (*Scenario) GetNumServers Uses

func (x *Scenario) GetNumServers() int32

func (*Scenario) GetServerConfig Uses

func (x *Scenario) GetServerConfig() *ServerConfig

func (*Scenario) GetSpawnLocalWorkerCount Uses

func (x *Scenario) GetSpawnLocalWorkerCount() int32

func (*Scenario) GetWarmupSeconds Uses

func (x *Scenario) GetWarmupSeconds() int32

func (*Scenario) ProtoMessage Uses

func (*Scenario) ProtoMessage()

func (*Scenario) ProtoReflect Uses

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

func (*Scenario) Reset Uses

func (x *Scenario) Reset()

func (*Scenario) String Uses

func (x *Scenario) String() string

type ScenarioResult Uses

type ScenarioResult struct {

    // Inputs used to run the scenario.
    Scenario *Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"`
    // Histograms from all clients merged into one histogram.
    Latencies *HistogramData `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"`
    // Client stats for each client
    ClientStats []*ClientStats `protobuf:"bytes,3,rep,name=client_stats,json=clientStats,proto3" json:"client_stats,omitempty"`
    // Server stats for each server
    ServerStats []*ServerStats `protobuf:"bytes,4,rep,name=server_stats,json=serverStats,proto3" json:"server_stats,omitempty"`
    // Number of cores available to each server
    ServerCores []int32 `protobuf:"varint,5,rep,packed,name=server_cores,json=serverCores,proto3" json:"server_cores,omitempty"`
    // An after-the-fact computed summary
    Summary *ScenarioResultSummary `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
    // Information on success or failure of each worker
    ClientSuccess []bool `protobuf:"varint,7,rep,packed,name=client_success,json=clientSuccess,proto3" json:"client_success,omitempty"`
    ServerSuccess []bool `protobuf:"varint,8,rep,packed,name=server_success,json=serverSuccess,proto3" json:"server_success,omitempty"`
    // Number of failed requests (one row per status code seen)
    RequestResults []*RequestResultCount `protobuf:"bytes,9,rep,name=request_results,json=requestResults,proto3" json:"request_results,omitempty"`
    // contains filtered or unexported fields
}

Results of a single benchmark scenario.

func (*ScenarioResult) Descriptor Uses

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

Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.

func (*ScenarioResult) GetClientStats Uses

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

func (*ScenarioResult) GetClientSuccess Uses

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

func (*ScenarioResult) GetLatencies Uses

func (x *ScenarioResult) GetLatencies() *HistogramData

func (*ScenarioResult) GetRequestResults Uses

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

func (*ScenarioResult) GetScenario Uses

func (x *ScenarioResult) GetScenario() *Scenario

func (*ScenarioResult) GetServerCores Uses

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

func (*ScenarioResult) GetServerStats Uses

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

func (*ScenarioResult) GetServerSuccess Uses

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

func (*ScenarioResult) GetSummary Uses

func (x *ScenarioResult) GetSummary() *ScenarioResultSummary

func (*ScenarioResult) ProtoMessage Uses

func (*ScenarioResult) ProtoMessage()

func (*ScenarioResult) ProtoReflect Uses

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

func (*ScenarioResult) Reset Uses

func (x *ScenarioResult) Reset()

func (*ScenarioResult) String Uses

func (x *ScenarioResult) String() string

type ScenarioResultSummary Uses

type ScenarioResultSummary struct {

    // Total number of operations per second over all clients. What is counted as 1 'operation' depends on the benchmark scenarios:
    // For unary benchmarks, an operation is processing of a single unary RPC.
    // For streaming benchmarks, an operation is processing of a single ping pong of request and response.
    Qps float64 `protobuf:"fixed64,1,opt,name=qps,proto3" json:"qps,omitempty"`
    // QPS per server core.
    QpsPerServerCore float64 `protobuf:"fixed64,2,opt,name=qps_per_server_core,json=qpsPerServerCore,proto3" json:"qps_per_server_core,omitempty"`
    // The total server cpu load based on system time across all server processes, expressed as percentage of a single cpu core.
    // For example, 85 implies 85% of a cpu core, 125 implies 125% of a cpu core. Since we are accumulating the cpu load across all the server
    // processes, the value could > 100 when there are multiple servers or a single server using multiple threads and cores.
    // Same explanation for the total client cpu load below.
    ServerSystemTime float64 `protobuf:"fixed64,3,opt,name=server_system_time,json=serverSystemTime,proto3" json:"server_system_time,omitempty"`
    // The total server cpu load based on user time across all server processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
    ServerUserTime float64 `protobuf:"fixed64,4,opt,name=server_user_time,json=serverUserTime,proto3" json:"server_user_time,omitempty"`
    // The total client cpu load based on system time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
    ClientSystemTime float64 `protobuf:"fixed64,5,opt,name=client_system_time,json=clientSystemTime,proto3" json:"client_system_time,omitempty"`
    // The total client cpu load based on user time across all client processes, expressed as percentage of a single cpu core. (85 => 85%, 125 => 125%)
    ClientUserTime float64 `protobuf:"fixed64,6,opt,name=client_user_time,json=clientUserTime,proto3" json:"client_user_time,omitempty"`
    // X% latency percentiles (in nanoseconds)
    Latency_50  float64 `protobuf:"fixed64,7,opt,name=latency_50,json=latency50,proto3" json:"latency_50,omitempty"`
    Latency_90  float64 `protobuf:"fixed64,8,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"`
    Latency_95  float64 `protobuf:"fixed64,9,opt,name=latency_95,json=latency95,proto3" json:"latency_95,omitempty"`
    Latency_99  float64 `protobuf:"fixed64,10,opt,name=latency_99,json=latency99,proto3" json:"latency_99,omitempty"`
    Latency_999 float64 `protobuf:"fixed64,11,opt,name=latency_999,json=latency999,proto3" json:"latency_999,omitempty"`
    // server cpu usage percentage
    ServerCpuUsage float64 `protobuf:"fixed64,12,opt,name=server_cpu_usage,json=serverCpuUsage,proto3" json:"server_cpu_usage,omitempty"`
    // Number of requests that succeeded/failed
    SuccessfulRequestsPerSecond float64 `protobuf:"fixed64,13,opt,name=successful_requests_per_second,json=successfulRequestsPerSecond,proto3" json:"successful_requests_per_second,omitempty"`
    FailedRequestsPerSecond     float64 `protobuf:"fixed64,14,opt,name=failed_requests_per_second,json=failedRequestsPerSecond,proto3" json:"failed_requests_per_second,omitempty"`
    // Number of polls called inside completion queue per request
    ClientPollsPerRequest float64 `protobuf:"fixed64,15,opt,name=client_polls_per_request,json=clientPollsPerRequest,proto3" json:"client_polls_per_request,omitempty"`
    ServerPollsPerRequest float64 `protobuf:"fixed64,16,opt,name=server_polls_per_request,json=serverPollsPerRequest,proto3" json:"server_polls_per_request,omitempty"`
    // Queries per CPU-sec over all servers or clients
    ServerQueriesPerCpuSec float64 `protobuf:"fixed64,17,opt,name=server_queries_per_cpu_sec,json=serverQueriesPerCpuSec,proto3" json:"server_queries_per_cpu_sec,omitempty"`
    ClientQueriesPerCpuSec float64 `protobuf:"fixed64,18,opt,name=client_queries_per_cpu_sec,json=clientQueriesPerCpuSec,proto3" json:"client_queries_per_cpu_sec,omitempty"`
    // contains filtered or unexported fields
}

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

func (*ScenarioResultSummary) Descriptor Uses

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

Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.

func (*ScenarioResultSummary) GetClientPollsPerRequest Uses

func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64

func (*ScenarioResultSummary) GetClientQueriesPerCpuSec Uses

func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetClientSystemTime Uses

func (x *ScenarioResultSummary) GetClientSystemTime() float64

func (*ScenarioResultSummary) GetClientUserTime Uses

func (x *ScenarioResultSummary) GetClientUserTime() float64

func (*ScenarioResultSummary) GetFailedRequestsPerSecond Uses

func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64

func (*ScenarioResultSummary) GetLatency_50 Uses

func (x *ScenarioResultSummary) GetLatency_50() float64

func (*ScenarioResultSummary) GetLatency_90 Uses

func (x *ScenarioResultSummary) GetLatency_90() float64

func (*ScenarioResultSummary) GetLatency_95 Uses

func (x *ScenarioResultSummary) GetLatency_95() float64

func (*ScenarioResultSummary) GetLatency_99 Uses

func (x *ScenarioResultSummary) GetLatency_99() float64

func (*ScenarioResultSummary) GetLatency_999 Uses

func (x *ScenarioResultSummary) GetLatency_999() float64

func (*ScenarioResultSummary) GetQps Uses

func (x *ScenarioResultSummary) GetQps() float64

func (*ScenarioResultSummary) GetQpsPerServerCore Uses

func (x *ScenarioResultSummary) GetQpsPerServerCore() float64

func (*ScenarioResultSummary) GetServerCpuUsage Uses

func (x *ScenarioResultSummary) GetServerCpuUsage() float64

func (*ScenarioResultSummary) GetServerPollsPerRequest Uses

func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64

func (*ScenarioResultSummary) GetServerQueriesPerCpuSec Uses

func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64

func (*ScenarioResultSummary) GetServerSystemTime Uses

func (x *ScenarioResultSummary) GetServerSystemTime() float64

func (*ScenarioResultSummary) GetServerUserTime Uses

func (x *ScenarioResultSummary) GetServerUserTime() float64

func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond Uses

func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64

func (*ScenarioResultSummary) ProtoMessage Uses

func (*ScenarioResultSummary) ProtoMessage()

func (*ScenarioResultSummary) ProtoReflect Uses

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

func (*ScenarioResultSummary) Reset Uses

func (x *ScenarioResultSummary) Reset()

func (*ScenarioResultSummary) String Uses

func (x *ScenarioResultSummary) String() string

type Scenarios Uses

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

A set of scenarios to be run with qps_json_driver

func (*Scenarios) Descriptor Uses

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

Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.

func (*Scenarios) GetScenarios Uses

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

func (*Scenarios) ProtoMessage Uses

func (*Scenarios) ProtoMessage()

func (*Scenarios) ProtoReflect Uses

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

func (*Scenarios) Reset Uses

func (x *Scenarios) Reset()

func (*Scenarios) String Uses

func (x *Scenarios) String() string

type SecurityParams Uses

type SecurityParams struct {
    UseTestCa          bool   `protobuf:"varint,1,opt,name=use_test_ca,json=useTestCa,proto3" json:"use_test_ca,omitempty"`
    ServerHostOverride string `protobuf:"bytes,2,opt,name=server_host_override,json=serverHostOverride,proto3" json:"server_host_override,omitempty"`
    CredType           string `protobuf:"bytes,3,opt,name=cred_type,json=credType,proto3" json:"cred_type,omitempty"`
    // contains filtered or unexported fields
}

presence of SecurityParams implies use of TLS

func (*SecurityParams) Descriptor Uses

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

Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.

func (*SecurityParams) GetCredType Uses

func (x *SecurityParams) GetCredType() string

func (*SecurityParams) GetServerHostOverride Uses

func (x *SecurityParams) GetServerHostOverride() string

func (*SecurityParams) GetUseTestCa Uses

func (x *SecurityParams) GetUseTestCa() bool

func (*SecurityParams) ProtoMessage Uses

func (*SecurityParams) ProtoMessage()

func (*SecurityParams) ProtoReflect Uses

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

func (*SecurityParams) Reset Uses

func (x *SecurityParams) Reset()

func (*SecurityParams) String Uses

func (x *SecurityParams) String() string

type ServerArgs Uses

type ServerArgs struct {

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

func (*ServerArgs) Descriptor Uses

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

Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.

func (*ServerArgs) GetArgtype Uses

func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

func (*ServerArgs) GetMark Uses

func (x *ServerArgs) GetMark() *Mark

func (*ServerArgs) GetSetup Uses

func (x *ServerArgs) GetSetup() *ServerConfig

func (*ServerArgs) ProtoMessage Uses

func (*ServerArgs) ProtoMessage()

func (*ServerArgs) ProtoReflect Uses

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

func (*ServerArgs) Reset Uses

func (x *ServerArgs) Reset()

func (*ServerArgs) String Uses

func (x *ServerArgs) String() string

type ServerArgs_Mark Uses

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

type ServerArgs_Setup Uses

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

type ServerConfig Uses

type ServerConfig struct {
    ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
    SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
    // Port on which to listen. Zero means pick unused port.
    Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
    // Only for async server. Number of threads used to serve the requests.
    AsyncServerThreads int32 `protobuf:"varint,7,opt,name=async_server_threads,json=asyncServerThreads,proto3" json:"async_server_threads,omitempty"`
    // Specify the number of cores to limit server to, if desired
    CoreLimit int32 `protobuf:"varint,8,opt,name=core_limit,json=coreLimit,proto3" json:"core_limit,omitempty"`
    // payload config, used in generic server.
    // Note this must NOT be used in proto (non-generic) servers. For proto servers,
    // 'response sizes' must be configured from the 'response_size' field of the
    // 'SimpleRequest' objects in RPC requests.
    PayloadConfig *PayloadConfig `protobuf:"bytes,9,opt,name=payload_config,json=payloadConfig,proto3" json:"payload_config,omitempty"`
    // Specify the cores we should run the server on, if desired
    CoreList []int32 `protobuf:"varint,10,rep,packed,name=core_list,json=coreList,proto3" json:"core_list,omitempty"`
    // If we use an OTHER_SERVER client_type, this string gives more detail
    OtherServerApi string `protobuf:"bytes,11,opt,name=other_server_api,json=otherServerApi,proto3" json:"other_server_api,omitempty"`
    // Number of threads that share each completion queue
    ThreadsPerCq int32 `protobuf:"varint,12,opt,name=threads_per_cq,json=threadsPerCq,proto3" json:"threads_per_cq,omitempty"`
    // Buffer pool size (no buffer pool specified if unset)
    ResourceQuotaSize int32         `protobuf:"varint,1001,opt,name=resource_quota_size,json=resourceQuotaSize,proto3" json:"resource_quota_size,omitempty"`
    ChannelArgs       []*ChannelArg `protobuf:"bytes,1002,rep,name=channel_args,json=channelArgs,proto3" json:"channel_args,omitempty"`
    // Number of server processes. 0 indicates no restriction.
    ServerProcesses int32 `protobuf:"varint,21,opt,name=server_processes,json=serverProcesses,proto3" json:"server_processes,omitempty"`
    // contains filtered or unexported fields
}

func (*ServerConfig) Descriptor Uses

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

Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

func (*ServerConfig) GetAsyncServerThreads Uses

func (x *ServerConfig) GetAsyncServerThreads() int32

func (*ServerConfig) GetChannelArgs Uses

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

func (*ServerConfig) GetCoreLimit Uses

func (x *ServerConfig) GetCoreLimit() int32

func (*ServerConfig) GetCoreList Uses

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

func (*ServerConfig) GetOtherServerApi Uses

func (x *ServerConfig) GetOtherServerApi() string

func (*ServerConfig) GetPayloadConfig Uses

func (x *ServerConfig) GetPayloadConfig() *PayloadConfig

func (*ServerConfig) GetPort Uses

func (x *ServerConfig) GetPort() int32

func (*ServerConfig) GetResourceQuotaSize Uses

func (x *ServerConfig) GetResourceQuotaSize() int32

func (*ServerConfig) GetSecurityParams Uses

func (x *ServerConfig) GetSecurityParams() *SecurityParams

func (*ServerConfig) GetServerProcesses Uses

func (x *ServerConfig) GetServerProcesses() int32

func (*ServerConfig) GetServerType Uses

func (x *ServerConfig) GetServerType() ServerType

func (*ServerConfig) GetThreadsPerCq Uses

func (x *ServerConfig) GetThreadsPerCq() int32

func (*ServerConfig) ProtoMessage Uses

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) ProtoReflect Uses

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

func (*ServerConfig) Reset Uses

func (x *ServerConfig) Reset()

func (*ServerConfig) String Uses

func (x *ServerConfig) String() string

type ServerStats Uses

type ServerStats struct {

    // wall clock time change in seconds since last reset
    TimeElapsed float64 `protobuf:"fixed64,1,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
    // change in user time (in seconds) used by the server since last reset
    TimeUser float64 `protobuf:"fixed64,2,opt,name=time_user,json=timeUser,proto3" json:"time_user,omitempty"`
    // change in server time (in seconds) used by the server process and all
    // threads since last reset
    TimeSystem float64 `protobuf:"fixed64,3,opt,name=time_system,json=timeSystem,proto3" json:"time_system,omitempty"`
    // change in total cpu time of the server (data from proc/stat)
    TotalCpuTime uint64 `protobuf:"varint,4,opt,name=total_cpu_time,json=totalCpuTime,proto3" json:"total_cpu_time,omitempty"`
    // change in idle time of the server (data from proc/stat)
    IdleCpuTime uint64 `protobuf:"varint,5,opt,name=idle_cpu_time,json=idleCpuTime,proto3" json:"idle_cpu_time,omitempty"`
    // Number of polls called inside completion queue
    CqPollCount uint64 `protobuf:"varint,6,opt,name=cq_poll_count,json=cqPollCount,proto3" json:"cq_poll_count,omitempty"`
    // Core library stats
    CoreStats *core.Stats `protobuf:"bytes,7,opt,name=core_stats,json=coreStats,proto3" json:"core_stats,omitempty"`
    // contains filtered or unexported fields
}

func (*ServerStats) Descriptor Uses

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

Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.

func (*ServerStats) GetCoreStats Uses

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

func (*ServerStats) GetCqPollCount Uses

func (x *ServerStats) GetCqPollCount() uint64

func (*ServerStats) GetIdleCpuTime Uses

func (x *ServerStats) GetIdleCpuTime() uint64

func (*ServerStats) GetTimeElapsed Uses

func (x *ServerStats) GetTimeElapsed() float64

func (*ServerStats) GetTimeSystem Uses

func (x *ServerStats) GetTimeSystem() float64

func (*ServerStats) GetTimeUser Uses

func (x *ServerStats) GetTimeUser() float64

func (*ServerStats) GetTotalCpuTime Uses

func (x *ServerStats) GetTotalCpuTime() uint64

func (*ServerStats) ProtoMessage Uses

func (*ServerStats) ProtoMessage()

func (*ServerStats) ProtoReflect Uses

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

func (*ServerStats) Reset Uses

func (x *ServerStats) Reset()

func (*ServerStats) String Uses

func (x *ServerStats) String() string

type ServerStatus Uses

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

func (*ServerStatus) Descriptor Uses

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

Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.

func (*ServerStatus) GetCores Uses

func (x *ServerStatus) GetCores() int32

func (*ServerStatus) GetPort Uses

func (x *ServerStatus) GetPort() int32

func (*ServerStatus) GetStats Uses

func (x *ServerStatus) GetStats() *ServerStats

func (*ServerStatus) ProtoMessage Uses

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) ProtoReflect Uses

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

func (*ServerStatus) Reset Uses

func (x *ServerStatus) Reset()

func (*ServerStatus) String Uses

func (x *ServerStatus) String() string

type ServerType Uses

type ServerType int32
const (
    ServerType_SYNC_SERVER          ServerType = 0
    ServerType_ASYNC_SERVER         ServerType = 1
    ServerType_ASYNC_GENERIC_SERVER ServerType = 2
    ServerType_OTHER_SERVER         ServerType = 3 // used for some language-specific variants
    ServerType_CALLBACK_SERVER      ServerType = 4
)

func (ServerType) Descriptor Uses

func (ServerType) Descriptor() protoreflect.EnumDescriptor

func (ServerType) Enum Uses

func (x ServerType) Enum() *ServerType

func (ServerType) EnumDescriptor Uses

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

Deprecated: Use ServerType.Descriptor instead.

func (ServerType) Number Uses

func (x ServerType) Number() protoreflect.EnumNumber

func (ServerType) String Uses

func (x ServerType) String() string

func (ServerType) Type Uses

func (ServerType) Type() protoreflect.EnumType

type SimpleProtoParams Uses

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

func (*SimpleProtoParams) Descriptor Uses

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

Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.

func (*SimpleProtoParams) GetReqSize Uses

func (x *SimpleProtoParams) GetReqSize() int32

func (*SimpleProtoParams) GetRespSize Uses

func (x *SimpleProtoParams) GetRespSize() int32

func (*SimpleProtoParams) ProtoMessage Uses

func (*SimpleProtoParams) ProtoMessage()

func (*SimpleProtoParams) ProtoReflect Uses

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

func (*SimpleProtoParams) Reset Uses

func (x *SimpleProtoParams) Reset()

func (*SimpleProtoParams) String Uses

func (x *SimpleProtoParams) String() string

type SimpleRequest Uses

type SimpleRequest struct {

    // Desired payload type in the response from the server.
    // If response_type is RANDOM, server randomly chooses one from other formats.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Desired payload size in the response from the server.
    ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether SimpleResponse should include username.
    FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
    // Whether SimpleResponse should include OAuth scope.
    FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
    // Whether to request the server to compress the response. This field is
    // "nullable" in order to interoperate seamlessly with clients not able to
    // implement the full compression tests by introspecting the call to verify
    // the response's compression status.
    ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,omitempty"`
    // Whether server should return a given status
    ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
    // Whether the server should expect this request to be compressed.
    ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
    // Whether SimpleResponse should include server_id.
    FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`
    // Whether SimpleResponse should include grpclb_route_type.
    FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"`
    // contains filtered or unexported fields
}

Unary request.

func (*SimpleRequest) Descriptor Uses

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

func (*SimpleRequest) GetExpectCompressed Uses

func (x *SimpleRequest) GetExpectCompressed() *BoolValue

func (*SimpleRequest) GetFillGrpclbRouteType Uses

func (x *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope Uses

func (x *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId Uses

func (x *SimpleRequest) GetFillServerId() bool

func (*SimpleRequest) GetFillUsername Uses

func (x *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload Uses

func (x *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseCompressed Uses

func (x *SimpleRequest) GetResponseCompressed() *BoolValue

func (*SimpleRequest) GetResponseSize Uses

func (x *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus Uses

func (x *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType Uses

func (x *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage Uses

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect Uses

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

func (*SimpleRequest) Reset Uses

func (x *SimpleRequest) Reset()

func (*SimpleRequest) String Uses

func (x *SimpleRequest) String() string

type SimpleResponse Uses

type SimpleResponse struct {

    // Payload to increase message size.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    // The user the request came from, for verifying authentication was
    // successful when the client expected it.
    Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
    // OAuth scope.
    OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
    // Server ID. This must be unique among different server instances,
    // but the same across all RPC's made to a particular server instance.
    ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
    // gRPCLB Path.
    GrpclbRouteType GrpclbRouteType `protobuf:"varint,5,opt,name=grpclb_route_type,json=grpclbRouteType,proto3,enum=grpc.testing.GrpclbRouteType" json:"grpclb_route_type,omitempty"`
    // Server hostname.
    Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
    // contains filtered or unexported fields
}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor Uses

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse) GetGrpclbRouteType Uses

func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetHostname Uses

func (x *SimpleResponse) GetHostname() string

func (*SimpleResponse) GetOauthScope Uses

func (x *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload Uses

func (x *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId Uses

func (x *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername Uses

func (x *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage Uses

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect Uses

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

func (*SimpleResponse) Reset Uses

func (x *SimpleResponse) Reset()

func (*SimpleResponse) String Uses

func (x *SimpleResponse) String() string

type StreamingInputCallRequest Uses

type StreamingInputCallRequest struct {

    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether the server should expect this request to be compressed. This field
    // is "nullable" in order to interoperate seamlessly with servers not able to
    // implement the full compression tests by introspecting the call to verify
    // the request's compression status.
    ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,omitempty"`
    // contains filtered or unexported fields
}

Client-streaming request.

func (*StreamingInputCallRequest) Descriptor Uses

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

Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingInputCallRequest) GetExpectCompressed Uses

func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

func (*StreamingInputCallRequest) GetPayload Uses

func (x *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage Uses

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) ProtoReflect Uses

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

func (*StreamingInputCallRequest) Reset Uses

func (x *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String Uses

func (x *StreamingInputCallRequest) String() string

type StreamingInputCallResponse Uses

type StreamingInputCallResponse struct {

    // Aggregated size of payloads received from the client.
    AggregatedPayloadSize int32 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize,proto3" json:"aggregated_payload_size,omitempty"`
    // contains filtered or unexported fields
}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor Uses

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

Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingInputCallResponse) GetAggregatedPayloadSize Uses

func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage Uses

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) ProtoReflect Uses

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

func (*StreamingInputCallResponse) Reset Uses

func (x *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String Uses

func (x *StreamingInputCallResponse) String() string

type StreamingOutputCallRequest Uses

type StreamingOutputCallRequest struct {

    // Desired payload type in the response from the server.
    // If response_type is RANDOM, the payload from each response in the stream
    // might be of different types. This is to simulate a mixed type of payload
    // stream.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Configuration for each expected response message.
    ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether server should return a given status
    ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
    // contains filtered or unexported fields
}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor Uses

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

Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallRequest) GetPayload Uses

func (x *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseParameters Uses

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

func (*StreamingOutputCallRequest) GetResponseStatus Uses

func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType Uses

func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage Uses

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) ProtoReflect Uses

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

func (*StreamingOutputCallRequest) Reset Uses

func (x *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String Uses

func (x *StreamingOutputCallRequest) String() string

type StreamingOutputCallResponse Uses

type StreamingOutputCallResponse struct {

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

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

func (*StreamingOutputCallResponse) Descriptor Uses

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

Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallResponse) GetPayload Uses

func (x *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage Uses

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) ProtoReflect Uses

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

func (*StreamingOutputCallResponse) Reset Uses

func (x *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String Uses

func (x *StreamingOutputCallResponse) String() string

type TestServiceClient Uses

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

TestServiceClient is the client API for TestService service.

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

func NewTestServiceClient Uses

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer Uses

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

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

type TestService_FullDuplexCallClient Uses

type TestService_FullDuplexCallClient interface {
    Send(*StreamingOutputCallRequest) error
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_FullDuplexCallServer Uses

type TestService_FullDuplexCallServer interface {
    Send(*StreamingOutputCallResponse) error
    Recv() (*StreamingOutputCallRequest, error)
    grpc.ServerStream
}

type TestService_HalfDuplexCallClient Uses

type TestService_HalfDuplexCallClient interface {
    Send(*StreamingOutputCallRequest) error
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_HalfDuplexCallServer Uses

type TestService_HalfDuplexCallServer interface {
    Send(*StreamingOutputCallResponse) error
    Recv() (*StreamingOutputCallRequest, error)
    grpc.ServerStream
}

type TestService_StreamingInputCallClient Uses

type TestService_StreamingInputCallClient interface {
    Send(*StreamingInputCallRequest) error
    CloseAndRecv() (*StreamingInputCallResponse, error)
    grpc.ClientStream
}

type TestService_StreamingInputCallServer Uses

type TestService_StreamingInputCallServer interface {
    SendAndClose(*StreamingInputCallResponse) error
    Recv() (*StreamingInputCallRequest, error)
    grpc.ServerStream
}

type TestService_StreamingOutputCallClient Uses

type TestService_StreamingOutputCallClient interface {
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_StreamingOutputCallServer Uses

type TestService_StreamingOutputCallServer interface {
    Send(*StreamingOutputCallResponse) error
    grpc.ServerStream
}

type UnimplementedBenchmarkServiceServer Uses

type UnimplementedBenchmarkServiceServer struct {
}

UnimplementedBenchmarkServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBenchmarkServiceServer) StreamingBothWays Uses

func (UnimplementedBenchmarkServiceServer) StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error

func (UnimplementedBenchmarkServiceServer) StreamingCall Uses

func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error

func (UnimplementedBenchmarkServiceServer) StreamingFromClient Uses

func (UnimplementedBenchmarkServiceServer) StreamingFromClient(BenchmarkService_StreamingFromClientServer) error

func (UnimplementedBenchmarkServiceServer) StreamingFromServer Uses

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

func (UnimplementedBenchmarkServiceServer) UnaryCall Uses

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

type UnimplementedLoadBalancerStatsServiceServer Uses

type UnimplementedLoadBalancerStatsServiceServer struct {
}

UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats Uses

func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *LoadBalancerAccumulatedStatsRequest) (*LoadBalancerAccumulatedStatsResponse, error)

func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats Uses

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

type UnimplementedReconnectServiceServer Uses

type UnimplementedReconnectServiceServer struct {
}

UnimplementedReconnectServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReconnectServiceServer) Start Uses

func (UnimplementedReconnectServiceServer) Start(context.Context, *ReconnectParams) (*Empty, error)

func (UnimplementedReconnectServiceServer) Stop Uses

func (UnimplementedReconnectServiceServer) Stop(context.Context, *Empty) (*ReconnectInfo, error)

type UnimplementedReportQpsScenarioServiceServer Uses

type UnimplementedReportQpsScenarioServiceServer struct {
}

UnimplementedReportQpsScenarioServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReportQpsScenarioServiceServer) ReportScenario Uses

func (UnimplementedReportQpsScenarioServiceServer) ReportScenario(context.Context, *ScenarioResult) (*Void, error)

type UnimplementedServiceClient Uses

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

UnimplementedServiceClient is the client API for UnimplementedService service.

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

func NewUnimplementedServiceClient Uses

func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient

type UnimplementedServiceServer Uses

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

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

type UnimplementedTestServiceServer Uses

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) CacheableUnaryCall Uses

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

func (UnimplementedTestServiceServer) EmptyCall Uses

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

func (UnimplementedTestServiceServer) FullDuplexCall Uses

func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error

func (UnimplementedTestServiceServer) HalfDuplexCall Uses

func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error

func (UnimplementedTestServiceServer) StreamingInputCall Uses

func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error

func (UnimplementedTestServiceServer) StreamingOutputCall Uses

func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error

func (UnimplementedTestServiceServer) UnaryCall Uses

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

func (UnimplementedTestServiceServer) UnimplementedCall Uses

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

type UnimplementedUnimplementedServiceServer Uses

type UnimplementedUnimplementedServiceServer struct {
}

UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUnimplementedServiceServer) UnimplementedCall Uses

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

type UnimplementedWorkerServiceServer Uses

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServiceServer) CoreCount Uses

func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *CoreRequest) (*CoreResponse, error)

func (UnimplementedWorkerServiceServer) QuitWorker Uses

func (UnimplementedWorkerServiceServer) QuitWorker(context.Context, *Void) (*Void, error)

func (UnimplementedWorkerServiceServer) RunClient Uses

func (UnimplementedWorkerServiceServer) RunClient(WorkerService_RunClientServer) error

func (UnimplementedWorkerServiceServer) RunServer Uses

func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error

type UnimplementedXdsUpdateClientConfigureServiceServer Uses

type UnimplementedXdsUpdateClientConfigureServiceServer struct {
}

UnimplementedXdsUpdateClientConfigureServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure Uses

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

type UnimplementedXdsUpdateHealthServiceServer Uses

type UnimplementedXdsUpdateHealthServiceServer struct {
}

UnimplementedXdsUpdateHealthServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing Uses

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

func (UnimplementedXdsUpdateHealthServiceServer) SetServing Uses

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

type UnsafeBenchmarkServiceServer Uses

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

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

type UnsafeLoadBalancerStatsServiceServer Uses

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

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

type UnsafeReconnectServiceServer Uses

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

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

type UnsafeReportQpsScenarioServiceServer Uses

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

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

type UnsafeTestServiceServer Uses

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

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

type UnsafeUnimplementedServiceServer Uses

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

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

type UnsafeWorkerServiceServer Uses

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

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

type UnsafeXdsUpdateClientConfigureServiceServer Uses

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

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

type UnsafeXdsUpdateHealthServiceServer Uses

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

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

type Void Uses

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

func (*Void) Descriptor Uses

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage Uses

func (*Void) ProtoMessage()

func (*Void) ProtoReflect Uses

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

func (*Void) Reset Uses

func (x *Void) Reset()

func (*Void) String Uses

func (x *Void) String() string

type WorkerServiceClient Uses

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

WorkerServiceClient is the client API for WorkerService service.

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

func NewWorkerServiceClient Uses

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceServer Uses

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

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

type WorkerService_RunClientClient Uses

type WorkerService_RunClientClient interface {
    Send(*ClientArgs) error
    Recv() (*ClientStatus, error)
    grpc.ClientStream
}

type WorkerService_RunClientServer Uses

type WorkerService_RunClientServer interface {
    Send(*ClientStatus) error
    Recv() (*ClientArgs, error)
    grpc.ServerStream
}

type WorkerService_RunServerClient Uses

type WorkerService_RunServerClient interface {
    Send(*ServerArgs) error
    Recv() (*ServerStatus, error)
    grpc.ClientStream
}

type WorkerService_RunServerServer Uses

type WorkerService_RunServerServer interface {
    Send(*ServerStatus) error
    Recv() (*ServerArgs, error)
    grpc.ServerStream
}

type XdsUpdateClientConfigureServiceClient Uses

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

XdsUpdateClientConfigureServiceClient is the client API for XdsUpdateClientConfigureService service.

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

func NewXdsUpdateClientConfigureServiceClient Uses

func NewXdsUpdateClientConfigureServiceClient(cc grpc.ClientConnInterface) XdsUpdateClientConfigureServiceClient

type XdsUpdateClientConfigureServiceServer Uses

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

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

type XdsUpdateHealthServiceClient Uses

type XdsUpdateHealthServiceClient interface {
    SetServing(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
    SetNotServing(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

XdsUpdateHealthServiceClient is the client API for XdsUpdateHealthService service.

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

func NewXdsUpdateHealthServiceClient Uses

func NewXdsUpdateHealthServiceClient(cc grpc.ClientConnInterface) XdsUpdateHealthServiceClient

type XdsUpdateHealthServiceServer Uses

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

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

Directories

PathSynopsis
core

Package grpc_testing imports 10 packages (graph) and is imported by 206 packages. Updated 2021-01-15. Refresh now. Tools for package owners.