Documentation

Index

Constants

This section is empty.

Variables

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

    Enum value maps for ClientType.

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

      Enum value maps for ServerType.

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

        Enum value maps for RpcType.

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

          Enum value maps for PayloadType.

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

            Enum value maps for GrpclbRouteType.

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

              Enum value maps for ClientConfigureRequest_RpcType.

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

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

                View Source
                var File_grpc_testing_benchmark_service_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_control_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_empty_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_messages_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_payloads_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_report_qps_scenario_service_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_stats_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_test_proto protoreflect.FileDescriptor
                View Source
                var File_grpc_testing_worker_service_proto protoreflect.FileDescriptor
                View Source
                var LoadBalancerStatsService_ServiceDesc = grpc.ServiceDesc{
                	ServiceName: "grpc.testing.LoadBalancerStatsService",
                	HandlerType: (*LoadBalancerStatsServiceServer)(nil),
                	Methods: []grpc.MethodDesc{
                		{
                			MethodName: "GetClientStats",
                			Handler:    _LoadBalancerStatsService_GetClientStats_Handler,
                		},
                		{
                			MethodName: "GetClientAccumulatedStats",
                			Handler:    _LoadBalancerStatsService_GetClientAccumulatedStats_Handler,
                		},
                	},
                	Streams:  []grpc.StreamDesc{},
                	Metadata: "grpc/testing/test.proto",
                }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

                                Functions

                                func RegisterBenchmarkServiceServer

                                func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)

                                func RegisterLoadBalancerStatsServiceServer

                                func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer)

                                func RegisterReconnectServiceServer

                                func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)

                                func RegisterReportQpsScenarioServiceServer

                                func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)

                                func RegisterTestServiceServer

                                func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

                                func RegisterUnimplementedServiceServer

                                func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)

                                func RegisterWorkerServiceServer

                                func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

                                func RegisterXdsUpdateClientConfigureServiceServer

                                func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)

                                func RegisterXdsUpdateHealthServiceServer

                                func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)

                                Types

                                type BenchmarkServiceClient

                                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.

                                  type BenchmarkServiceServer

                                  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

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

                                    type BenchmarkService_StreamingBothWaysServer

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

                                    type BenchmarkService_StreamingCallClient

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

                                    type BenchmarkService_StreamingCallServer

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

                                    type BenchmarkService_StreamingFromClientClient

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

                                    type BenchmarkService_StreamingFromClientServer

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

                                    type BenchmarkService_StreamingFromServerClient

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

                                    type BenchmarkService_StreamingFromServerServer

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

                                    type BoolValue

                                    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

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

                                        Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

                                        func (*BoolValue) GetValue

                                        func (x *BoolValue) GetValue() bool

                                        func (*BoolValue) ProtoMessage

                                        func (*BoolValue) ProtoMessage()

                                        func (*BoolValue) ProtoReflect

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

                                        func (*BoolValue) Reset

                                        func (x *BoolValue) Reset()

                                        func (*BoolValue) String

                                        func (x *BoolValue) String() string

                                        type ByteBufferParams

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

                                        func (*ByteBufferParams) Descriptor

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

                                          Deprecated: Use ByteBufferParams.ProtoReflect.Descriptor instead.

                                          func (*ByteBufferParams) GetReqSize

                                          func (x *ByteBufferParams) GetReqSize() int32

                                          func (*ByteBufferParams) GetRespSize

                                          func (x *ByteBufferParams) GetRespSize() int32

                                          func (*ByteBufferParams) ProtoMessage

                                          func (*ByteBufferParams) ProtoMessage()

                                          func (*ByteBufferParams) ProtoReflect

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

                                          func (*ByteBufferParams) Reset

                                          func (x *ByteBufferParams) Reset()

                                          func (*ByteBufferParams) String

                                          func (x *ByteBufferParams) String() string

                                          type ChannelArg

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

                                          func (*ChannelArg) Descriptor

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

                                            Deprecated: Use ChannelArg.ProtoReflect.Descriptor instead.

                                            func (*ChannelArg) GetIntValue

                                            func (x *ChannelArg) GetIntValue() int32

                                            func (*ChannelArg) GetName

                                            func (x *ChannelArg) GetName() string

                                            func (*ChannelArg) GetStrValue

                                            func (x *ChannelArg) GetStrValue() string

                                            func (*ChannelArg) GetValue

                                            func (m *ChannelArg) GetValue() isChannelArg_Value

                                            func (*ChannelArg) ProtoMessage

                                            func (*ChannelArg) ProtoMessage()

                                            func (*ChannelArg) ProtoReflect

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

                                            func (*ChannelArg) Reset

                                            func (x *ChannelArg) Reset()

                                            func (*ChannelArg) String

                                            func (x *ChannelArg) String() string

                                            type ChannelArg_IntValue

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

                                            type ChannelArg_StrValue

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

                                            type ClientArgs

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

                                            func (*ClientArgs) Descriptor

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

                                              Deprecated: Use ClientArgs.ProtoReflect.Descriptor instead.

                                              func (*ClientArgs) GetArgtype

                                              func (m *ClientArgs) GetArgtype() isClientArgs_Argtype

                                              func (*ClientArgs) GetMark

                                              func (x *ClientArgs) GetMark() *Mark

                                              func (*ClientArgs) GetSetup

                                              func (x *ClientArgs) GetSetup() *ClientConfig

                                              func (*ClientArgs) ProtoMessage

                                              func (*ClientArgs) ProtoMessage()

                                              func (*ClientArgs) ProtoReflect

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

                                              func (*ClientArgs) Reset

                                              func (x *ClientArgs) Reset()

                                              func (*ClientArgs) String

                                              func (x *ClientArgs) String() string

                                              type ClientArgs_Mark

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

                                              type ClientArgs_Setup

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

                                              type ClientConfig

                                              type ClientConfig struct {
                                              
                                              	// 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 `` /* 141-byte string literal not displayed */
                                              	// Number of independent client channels to create.
                                              	// i-th channel will connect to server_target[i % server_targets.size()]
                                              	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 `` /* 180-byte string literal not displayed */
                                              	// 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

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

                                                Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

                                                func (*ClientConfig) GetAsyncClientThreads

                                                func (x *ClientConfig) GetAsyncClientThreads() int32

                                                func (*ClientConfig) GetChannelArgs

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

                                                func (*ClientConfig) GetClientChannels

                                                func (x *ClientConfig) GetClientChannels() int32

                                                func (*ClientConfig) GetClientProcesses

                                                func (x *ClientConfig) GetClientProcesses() int32

                                                func (*ClientConfig) GetClientType

                                                func (x *ClientConfig) GetClientType() ClientType

                                                func (*ClientConfig) GetCoreLimit

                                                func (x *ClientConfig) GetCoreLimit() int32

                                                func (*ClientConfig) GetCoreList

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

                                                func (*ClientConfig) GetHistogramParams

                                                func (x *ClientConfig) GetHistogramParams() *HistogramParams

                                                func (*ClientConfig) GetLoadParams

                                                func (x *ClientConfig) GetLoadParams() *LoadParams

                                                func (*ClientConfig) GetMedianLatencyCollectionIntervalMillis

                                                func (x *ClientConfig) GetMedianLatencyCollectionIntervalMillis() int32

                                                func (*ClientConfig) GetMessagesPerStream

                                                func (x *ClientConfig) GetMessagesPerStream() int32

                                                func (*ClientConfig) GetOtherClientApi

                                                func (x *ClientConfig) GetOtherClientApi() string

                                                func (*ClientConfig) GetOutstandingRpcsPerChannel

                                                func (x *ClientConfig) GetOutstandingRpcsPerChannel() int32

                                                func (*ClientConfig) GetPayloadConfig

                                                func (x *ClientConfig) GetPayloadConfig() *PayloadConfig

                                                func (*ClientConfig) GetRpcType

                                                func (x *ClientConfig) GetRpcType() RpcType

                                                func (*ClientConfig) GetSecurityParams

                                                func (x *ClientConfig) GetSecurityParams() *SecurityParams

                                                func (*ClientConfig) GetServerTargets

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

                                                func (*ClientConfig) GetThreadsPerCq

                                                func (x *ClientConfig) GetThreadsPerCq() int32

                                                func (*ClientConfig) GetUseCoalesceApi

                                                func (x *ClientConfig) GetUseCoalesceApi() bool

                                                func (*ClientConfig) ProtoMessage

                                                func (*ClientConfig) ProtoMessage()

                                                func (*ClientConfig) ProtoReflect

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

                                                func (*ClientConfig) Reset

                                                func (x *ClientConfig) Reset()

                                                func (*ClientConfig) String

                                                func (x *ClientConfig) String() string

                                                type ClientConfigureRequest

                                                type ClientConfigureRequest struct {
                                                
                                                	// 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

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

                                                    Deprecated: Use ClientConfigureRequest.ProtoReflect.Descriptor instead.

                                                    func (*ClientConfigureRequest) GetMetadata

                                                    func (*ClientConfigureRequest) GetTimeoutSec

                                                    func (x *ClientConfigureRequest) GetTimeoutSec() int32

                                                    func (*ClientConfigureRequest) GetTypes

                                                    func (*ClientConfigureRequest) ProtoMessage

                                                    func (*ClientConfigureRequest) ProtoMessage()

                                                    func (*ClientConfigureRequest) ProtoReflect

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

                                                    func (*ClientConfigureRequest) Reset

                                                    func (x *ClientConfigureRequest) Reset()

                                                    func (*ClientConfigureRequest) String

                                                    func (x *ClientConfigureRequest) String() string

                                                    type ClientConfigureRequest_Metadata

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

                                                      Metadata to be attached for the given type of RPCs.

                                                      func (*ClientConfigureRequest_Metadata) Descriptor

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

                                                        Deprecated: Use ClientConfigureRequest_Metadata.ProtoReflect.Descriptor instead.

                                                        func (*ClientConfigureRequest_Metadata) GetKey

                                                        func (*ClientConfigureRequest_Metadata) GetType

                                                        func (*ClientConfigureRequest_Metadata) GetValue

                                                        func (*ClientConfigureRequest_Metadata) ProtoMessage

                                                        func (*ClientConfigureRequest_Metadata) ProtoMessage()

                                                        func (*ClientConfigureRequest_Metadata) ProtoReflect

                                                        func (*ClientConfigureRequest_Metadata) Reset

                                                        func (*ClientConfigureRequest_Metadata) String

                                                        type ClientConfigureRequest_RpcType

                                                        type ClientConfigureRequest_RpcType int32

                                                          Type of RPCs to send.

                                                          const (
                                                          	ClientConfigureRequest_EMPTY_CALL ClientConfigureRequest_RpcType = 0
                                                          	ClientConfigureRequest_UNARY_CALL ClientConfigureRequest_RpcType = 1
                                                          )

                                                          func (ClientConfigureRequest_RpcType) Descriptor

                                                          func (ClientConfigureRequest_RpcType) Enum

                                                          func (ClientConfigureRequest_RpcType) EnumDescriptor

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

                                                            Deprecated: Use ClientConfigureRequest_RpcType.Descriptor instead.

                                                            func (ClientConfigureRequest_RpcType) Number

                                                            func (ClientConfigureRequest_RpcType) String

                                                            func (ClientConfigureRequest_RpcType) Type

                                                            type ClientConfigureResponse

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

                                                              Response for updating a test client's configuration.

                                                              func (*ClientConfigureResponse) Descriptor

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

                                                                Deprecated: Use ClientConfigureResponse.ProtoReflect.Descriptor instead.

                                                                func (*ClientConfigureResponse) ProtoMessage

                                                                func (*ClientConfigureResponse) ProtoMessage()

                                                                func (*ClientConfigureResponse) ProtoReflect

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

                                                                func (*ClientConfigureResponse) Reset

                                                                func (x *ClientConfigureResponse) Reset()

                                                                func (*ClientConfigureResponse) String

                                                                func (x *ClientConfigureResponse) String() string

                                                                type ClientStats

                                                                type ClientStats struct {
                                                                
                                                                	// 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

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

                                                                  Deprecated: Use ClientStats.ProtoReflect.Descriptor instead.

                                                                  func (*ClientStats) GetCoreStats

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

                                                                  func (*ClientStats) GetCqPollCount

                                                                  func (x *ClientStats) GetCqPollCount() uint64

                                                                  func (*ClientStats) GetLatencies

                                                                  func (x *ClientStats) GetLatencies() *HistogramData

                                                                  func (*ClientStats) GetRequestResults

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

                                                                  func (*ClientStats) GetTimeElapsed

                                                                  func (x *ClientStats) GetTimeElapsed() float64

                                                                  func (*ClientStats) GetTimeSystem

                                                                  func (x *ClientStats) GetTimeSystem() float64

                                                                  func (*ClientStats) GetTimeUser

                                                                  func (x *ClientStats) GetTimeUser() float64

                                                                  func (*ClientStats) ProtoMessage

                                                                  func (*ClientStats) ProtoMessage()

                                                                  func (*ClientStats) ProtoReflect

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

                                                                  func (*ClientStats) Reset

                                                                  func (x *ClientStats) Reset()

                                                                  func (*ClientStats) String

                                                                  func (x *ClientStats) String() string

                                                                  type ClientStatus

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

                                                                  func (*ClientStatus) Descriptor

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

                                                                    Deprecated: Use ClientStatus.ProtoReflect.Descriptor instead.

                                                                    func (*ClientStatus) GetStats

                                                                    func (x *ClientStatus) GetStats() *ClientStats

                                                                    func (*ClientStatus) ProtoMessage

                                                                    func (*ClientStatus) ProtoMessage()

                                                                    func (*ClientStatus) ProtoReflect

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

                                                                    func (*ClientStatus) Reset

                                                                    func (x *ClientStatus) Reset()

                                                                    func (*ClientStatus) String

                                                                    func (x *ClientStatus) String() string

                                                                    type ClientType

                                                                    type ClientType int32
                                                                    const (
                                                                    	// 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

                                                                    func (ClientType) Descriptor() protoreflect.EnumDescriptor

                                                                    func (ClientType) Enum

                                                                    func (x ClientType) Enum() *ClientType

                                                                    func (ClientType) EnumDescriptor

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

                                                                      Deprecated: Use ClientType.Descriptor instead.

                                                                      func (ClientType) Number

                                                                      func (x ClientType) Number() protoreflect.EnumNumber

                                                                      func (ClientType) String

                                                                      func (x ClientType) String() string

                                                                      func (ClientType) Type

                                                                      type ClosedLoopParams

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

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

                                                                        func (*ClosedLoopParams) Descriptor

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

                                                                          Deprecated: Use ClosedLoopParams.ProtoReflect.Descriptor instead.

                                                                          func (*ClosedLoopParams) ProtoMessage

                                                                          func (*ClosedLoopParams) ProtoMessage()

                                                                          func (*ClosedLoopParams) ProtoReflect

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

                                                                          func (*ClosedLoopParams) Reset

                                                                          func (x *ClosedLoopParams) Reset()

                                                                          func (*ClosedLoopParams) String

                                                                          func (x *ClosedLoopParams) String() string

                                                                          type ComplexProtoParams

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

                                                                          func (*ComplexProtoParams) Descriptor

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

                                                                            Deprecated: Use ComplexProtoParams.ProtoReflect.Descriptor instead.

                                                                            func (*ComplexProtoParams) ProtoMessage

                                                                            func (*ComplexProtoParams) ProtoMessage()

                                                                            func (*ComplexProtoParams) ProtoReflect

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

                                                                            func (*ComplexProtoParams) Reset

                                                                            func (x *ComplexProtoParams) Reset()

                                                                            func (*ComplexProtoParams) String

                                                                            func (x *ComplexProtoParams) String() string

                                                                            type CoreRequest

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

                                                                            func (*CoreRequest) Descriptor

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

                                                                              Deprecated: Use CoreRequest.ProtoReflect.Descriptor instead.

                                                                              func (*CoreRequest) ProtoMessage

                                                                              func (*CoreRequest) ProtoMessage()

                                                                              func (*CoreRequest) ProtoReflect

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

                                                                              func (*CoreRequest) Reset

                                                                              func (x *CoreRequest) Reset()

                                                                              func (*CoreRequest) String

                                                                              func (x *CoreRequest) String() string

                                                                              type CoreResponse

                                                                              type CoreResponse struct {
                                                                              
                                                                              	// 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

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

                                                                                Deprecated: Use CoreResponse.ProtoReflect.Descriptor instead.

                                                                                func (*CoreResponse) GetCores

                                                                                func (x *CoreResponse) GetCores() int32

                                                                                func (*CoreResponse) ProtoMessage

                                                                                func (*CoreResponse) ProtoMessage()

                                                                                func (*CoreResponse) ProtoReflect

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

                                                                                func (*CoreResponse) Reset

                                                                                func (x *CoreResponse) Reset()

                                                                                func (*CoreResponse) String

                                                                                func (x *CoreResponse) String() string

                                                                                type EchoStatus

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

                                                                                  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

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

                                                                                    Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

                                                                                    func (*EchoStatus) GetCode

                                                                                    func (x *EchoStatus) GetCode() int32

                                                                                    func (*EchoStatus) GetMessage

                                                                                    func (x *EchoStatus) GetMessage() string

                                                                                    func (*EchoStatus) ProtoMessage

                                                                                    func (*EchoStatus) ProtoMessage()

                                                                                    func (*EchoStatus) ProtoReflect

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

                                                                                    func (*EchoStatus) Reset

                                                                                    func (x *EchoStatus) Reset()

                                                                                    func (*EchoStatus) String

                                                                                    func (x *EchoStatus) String() string

                                                                                    type Empty

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

                                                                                      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

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

                                                                                        Deprecated: Use Empty.ProtoReflect.Descriptor instead.

                                                                                        func (*Empty) ProtoMessage

                                                                                        func (*Empty) ProtoMessage()

                                                                                        func (*Empty) ProtoReflect

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

                                                                                        func (*Empty) Reset

                                                                                        func (x *Empty) Reset()

                                                                                        func (*Empty) String

                                                                                        func (x *Empty) String() string

                                                                                        type GrpclbRouteType

                                                                                        type GrpclbRouteType int32

                                                                                          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

                                                                                          func (GrpclbRouteType) Enum

                                                                                          func (x GrpclbRouteType) Enum() *GrpclbRouteType

                                                                                          func (GrpclbRouteType) EnumDescriptor

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

                                                                                            Deprecated: Use GrpclbRouteType.Descriptor instead.

                                                                                            func (GrpclbRouteType) Number

                                                                                            func (GrpclbRouteType) String

                                                                                            func (x GrpclbRouteType) String() string

                                                                                            func (GrpclbRouteType) Type

                                                                                            type HistogramData

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

                                                                                              Histogram data based on grpc/support/histogram.c

                                                                                              func (*HistogramData) Descriptor

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

                                                                                                Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.

                                                                                                func (*HistogramData) GetBucket

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

                                                                                                func (*HistogramData) GetCount

                                                                                                func (x *HistogramData) GetCount() float64

                                                                                                func (*HistogramData) GetMaxSeen

                                                                                                func (x *HistogramData) GetMaxSeen() float64

                                                                                                func (*HistogramData) GetMinSeen

                                                                                                func (x *HistogramData) GetMinSeen() float64

                                                                                                func (*HistogramData) GetSum

                                                                                                func (x *HistogramData) GetSum() float64

                                                                                                func (*HistogramData) GetSumOfSquares

                                                                                                func (x *HistogramData) GetSumOfSquares() float64

                                                                                                func (*HistogramData) ProtoMessage

                                                                                                func (*HistogramData) ProtoMessage()

                                                                                                func (*HistogramData) ProtoReflect

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

                                                                                                func (*HistogramData) Reset

                                                                                                func (x *HistogramData) Reset()

                                                                                                func (*HistogramData) String

                                                                                                func (x *HistogramData) String() string

                                                                                                type HistogramParams

                                                                                                type HistogramParams struct {
                                                                                                	Resolution  float64 `protobuf:"fixed64,1,opt,name=resolution,proto3" json:"resolution,omitempty"`                      // 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

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

                                                                                                    Deprecated: Use HistogramParams.ProtoReflect.Descriptor instead.

                                                                                                    func (*HistogramParams) GetMaxPossible

                                                                                                    func (x *HistogramParams) GetMaxPossible() float64

                                                                                                    func (*HistogramParams) GetResolution

                                                                                                    func (x *HistogramParams) GetResolution() float64

                                                                                                    func (*HistogramParams) ProtoMessage

                                                                                                    func (*HistogramParams) ProtoMessage()

                                                                                                    func (*HistogramParams) ProtoReflect

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

                                                                                                    func (*HistogramParams) Reset

                                                                                                    func (x *HistogramParams) Reset()

                                                                                                    func (*HistogramParams) String

                                                                                                    func (x *HistogramParams) String() string

                                                                                                    type LoadBalancerAccumulatedStatsRequest

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

                                                                                                      Request for retrieving a test client's accumulated stats.

                                                                                                      func (*LoadBalancerAccumulatedStatsRequest) Descriptor

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

                                                                                                        Deprecated: Use LoadBalancerAccumulatedStatsRequest.ProtoReflect.Descriptor instead.

                                                                                                        func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage

                                                                                                        func (*LoadBalancerAccumulatedStatsRequest) ProtoMessage()

                                                                                                        func (*LoadBalancerAccumulatedStatsRequest) ProtoReflect

                                                                                                        func (*LoadBalancerAccumulatedStatsRequest) Reset

                                                                                                        func (*LoadBalancerAccumulatedStatsRequest) String

                                                                                                        type LoadBalancerAccumulatedStatsResponse

                                                                                                        type LoadBalancerAccumulatedStatsResponse struct {
                                                                                                        
                                                                                                        	// 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 `` /* 222-byte string literal not displayed */
                                                                                                        	// The total number of RPCs have ever completed successfully for each type.
                                                                                                        	// Deprecated: use stats_per_method.result instead.
                                                                                                        	//
                                                                                                        	// Deprecated: Do not use.
                                                                                                        	NumRpcsSucceededByMethod map[string]int32 `` /* 228-byte string literal not displayed */
                                                                                                        	// 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 `` /* 219-byte string literal not displayed */
                                                                                                        	// Per-method RPC statistics.  The key is the RpcType in string form; e.g.
                                                                                                        	// 'EMPTY_CALL' or 'UNARY_CALL'
                                                                                                        	StatsPerMethod map[string]*LoadBalancerAccumulatedStatsResponse_MethodStats `` /* 193-byte string literal not displayed */
                                                                                                        	// contains filtered or unexported fields
                                                                                                        }

                                                                                                          Accumulated stats for RPCs sent by a test client.

                                                                                                          func (*LoadBalancerAccumulatedStatsResponse) Descriptor

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

                                                                                                            Deprecated: Use LoadBalancerAccumulatedStatsResponse.ProtoReflect.Descriptor instead.

                                                                                                            func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsFailedByMethod

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

                                                                                                              Deprecated: Do not use.

                                                                                                              func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsStartedByMethod

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

                                                                                                                Deprecated: Do not use.

                                                                                                                func (*LoadBalancerAccumulatedStatsResponse) GetNumRpcsSucceededByMethod

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

                                                                                                                  Deprecated: Do not use.

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) GetStatsPerMethod

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) ProtoMessage()

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) ProtoReflect

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) Reset

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse) String

                                                                                                                  type LoadBalancerAccumulatedStatsResponse_MethodStats

                                                                                                                  type LoadBalancerAccumulatedStatsResponse_MethodStats struct {
                                                                                                                  
                                                                                                                  	// 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 `` /* 155-byte string literal not displayed */
                                                                                                                  	// contains filtered or unexported fields
                                                                                                                  }

                                                                                                                  func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Descriptor

                                                                                                                    Deprecated: Use LoadBalancerAccumulatedStatsResponse_MethodStats.ProtoReflect.Descriptor instead.

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetResult

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) GetRpcsStarted

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoMessage

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) ProtoReflect

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) Reset

                                                                                                                    func (*LoadBalancerAccumulatedStatsResponse_MethodStats) String

                                                                                                                    type LoadBalancerStatsRequest

                                                                                                                    type LoadBalancerStatsRequest struct {
                                                                                                                    
                                                                                                                    	// 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

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

                                                                                                                      Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

                                                                                                                      func (*LoadBalancerStatsRequest) GetNumRpcs

                                                                                                                      func (x *LoadBalancerStatsRequest) GetNumRpcs() int32

                                                                                                                      func (*LoadBalancerStatsRequest) GetTimeoutSec

                                                                                                                      func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32

                                                                                                                      func (*LoadBalancerStatsRequest) ProtoMessage

                                                                                                                      func (*LoadBalancerStatsRequest) ProtoMessage()

                                                                                                                      func (*LoadBalancerStatsRequest) ProtoReflect

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

                                                                                                                      func (*LoadBalancerStatsRequest) Reset

                                                                                                                      func (x *LoadBalancerStatsRequest) Reset()

                                                                                                                      func (*LoadBalancerStatsRequest) String

                                                                                                                      func (x *LoadBalancerStatsRequest) String() string

                                                                                                                      type LoadBalancerStatsResponse

                                                                                                                      type LoadBalancerStatsResponse struct {
                                                                                                                      
                                                                                                                      	// The number of completed RPCs for each peer.
                                                                                                                      	RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */
                                                                                                                      	// 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 `` /* 187-byte string literal not displayed */
                                                                                                                      	// contains filtered or unexported fields
                                                                                                                      }

                                                                                                                      func (*LoadBalancerStatsResponse) Descriptor

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

                                                                                                                        Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

                                                                                                                        func (*LoadBalancerStatsResponse) GetNumFailures

                                                                                                                        func (x *LoadBalancerStatsResponse) GetNumFailures() int32

                                                                                                                        func (*LoadBalancerStatsResponse) GetRpcsByMethod

                                                                                                                        func (*LoadBalancerStatsResponse) GetRpcsByPeer

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

                                                                                                                        func (*LoadBalancerStatsResponse) ProtoMessage

                                                                                                                        func (*LoadBalancerStatsResponse) ProtoMessage()

                                                                                                                        func (*LoadBalancerStatsResponse) ProtoReflect

                                                                                                                        func (*LoadBalancerStatsResponse) Reset

                                                                                                                        func (x *LoadBalancerStatsResponse) Reset()

                                                                                                                        func (*LoadBalancerStatsResponse) String

                                                                                                                        func (x *LoadBalancerStatsResponse) String() string

                                                                                                                        type LoadBalancerStatsResponse_RpcsByPeer

                                                                                                                        type LoadBalancerStatsResponse_RpcsByPeer struct {
                                                                                                                        
                                                                                                                        	// The number of completed RPCs for each peer.
                                                                                                                        	RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */
                                                                                                                        	// contains filtered or unexported fields
                                                                                                                        }

                                                                                                                        func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor

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

                                                                                                                          Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer

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

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) Reset

                                                                                                                          func (*LoadBalancerStatsResponse_RpcsByPeer) String

                                                                                                                          type LoadBalancerStatsServiceClient

                                                                                                                          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.

                                                                                                                            type LoadBalancerStatsServiceServer

                                                                                                                            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

                                                                                                                              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

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

                                                                                                                                Deprecated: Use LoadParams.ProtoReflect.Descriptor instead.

                                                                                                                                func (*LoadParams) GetClosedLoop

                                                                                                                                func (x *LoadParams) GetClosedLoop() *ClosedLoopParams

                                                                                                                                func (*LoadParams) GetLoad

                                                                                                                                func (m *LoadParams) GetLoad() isLoadParams_Load

                                                                                                                                func (*LoadParams) GetPoisson

                                                                                                                                func (x *LoadParams) GetPoisson() *PoissonParams

                                                                                                                                func (*LoadParams) ProtoMessage

                                                                                                                                func (*LoadParams) ProtoMessage()

                                                                                                                                func (*LoadParams) ProtoReflect

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

                                                                                                                                func (*LoadParams) Reset

                                                                                                                                func (x *LoadParams) Reset()

                                                                                                                                func (*LoadParams) String

                                                                                                                                func (x *LoadParams) String() string

                                                                                                                                type LoadParams_ClosedLoop

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

                                                                                                                                type LoadParams_Poisson

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

                                                                                                                                type Mark

                                                                                                                                type Mark struct {
                                                                                                                                
                                                                                                                                	// 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

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

                                                                                                                                    Deprecated: Use Mark.ProtoReflect.Descriptor instead.

                                                                                                                                    func (*Mark) GetReset_

                                                                                                                                    func (x *Mark) GetReset_() bool

                                                                                                                                    func (*Mark) ProtoMessage

                                                                                                                                    func (*Mark) ProtoMessage()

                                                                                                                                    func (*Mark) ProtoReflect

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

                                                                                                                                    func (*Mark) Reset

                                                                                                                                    func (x *Mark) Reset()

                                                                                                                                    func (*Mark) String

                                                                                                                                    func (x *Mark) String() string

                                                                                                                                    type Payload

                                                                                                                                    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

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

                                                                                                                                        Deprecated: Use Payload.ProtoReflect.Descriptor instead.

                                                                                                                                        func (*Payload) GetBody

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

                                                                                                                                        func (*Payload) GetType

                                                                                                                                        func (x *Payload) GetType() PayloadType

                                                                                                                                        func (*Payload) ProtoMessage

                                                                                                                                        func (*Payload) ProtoMessage()

                                                                                                                                        func (*Payload) ProtoReflect

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

                                                                                                                                        func (*Payload) Reset

                                                                                                                                        func (x *Payload) Reset()

                                                                                                                                        func (*Payload) String

                                                                                                                                        func (x *Payload) String() string

                                                                                                                                        type PayloadConfig

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

                                                                                                                                        func (*PayloadConfig) Descriptor

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

                                                                                                                                          Deprecated: Use PayloadConfig.ProtoReflect.Descriptor instead.

                                                                                                                                          func (*PayloadConfig) GetBytebufParams

                                                                                                                                          func (x *PayloadConfig) GetBytebufParams() *ByteBufferParams

                                                                                                                                          func (*PayloadConfig) GetComplexParams

                                                                                                                                          func (x *PayloadConfig) GetComplexParams() *ComplexProtoParams

                                                                                                                                          func (*PayloadConfig) GetPayload

                                                                                                                                          func (m *PayloadConfig) GetPayload() isPayloadConfig_Payload

                                                                                                                                          func (*PayloadConfig) GetSimpleParams

                                                                                                                                          func (x *PayloadConfig) GetSimpleParams() *SimpleProtoParams

                                                                                                                                          func (*PayloadConfig) ProtoMessage

                                                                                                                                          func (*PayloadConfig) ProtoMessage()

                                                                                                                                          func (*PayloadConfig) ProtoReflect

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

                                                                                                                                          func (*PayloadConfig) Reset

                                                                                                                                          func (x *PayloadConfig) Reset()

                                                                                                                                          func (*PayloadConfig) String

                                                                                                                                          func (x *PayloadConfig) String() string

                                                                                                                                          type PayloadConfig_BytebufParams

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

                                                                                                                                          type PayloadConfig_ComplexParams

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

                                                                                                                                          type PayloadConfig_SimpleParams

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

                                                                                                                                          type PayloadType

                                                                                                                                          type PayloadType int32

                                                                                                                                            The type of payload that should be returned.

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

                                                                                                                                            func (PayloadType) Descriptor

                                                                                                                                            func (PayloadType) Enum

                                                                                                                                            func (x PayloadType) Enum() *PayloadType

                                                                                                                                            func (PayloadType) EnumDescriptor

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

                                                                                                                                              Deprecated: Use PayloadType.Descriptor instead.

                                                                                                                                              func (PayloadType) Number

                                                                                                                                              func (x PayloadType) Number() protoreflect.EnumNumber

                                                                                                                                              func (PayloadType) String

                                                                                                                                              func (x PayloadType) String() string

                                                                                                                                              func (PayloadType) Type

                                                                                                                                              type PoissonParams

                                                                                                                                              type PoissonParams struct {
                                                                                                                                              
                                                                                                                                              	// 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

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

                                                                                                                                                  Deprecated: Use PoissonParams.ProtoReflect.Descriptor instead.

                                                                                                                                                  func (*PoissonParams) GetOfferedLoad

                                                                                                                                                  func (x *PoissonParams) GetOfferedLoad() float64

                                                                                                                                                  func (*PoissonParams) ProtoMessage

                                                                                                                                                  func (*PoissonParams) ProtoMessage()

                                                                                                                                                  func (*PoissonParams) ProtoReflect

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

                                                                                                                                                  func (*PoissonParams) Reset

                                                                                                                                                  func (x *PoissonParams) Reset()

                                                                                                                                                  func (*PoissonParams) String

                                                                                                                                                  func (x *PoissonParams) String() string

                                                                                                                                                  type ReconnectInfo

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

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

                                                                                                                                                    func (*ReconnectInfo) Descriptor

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

                                                                                                                                                      Deprecated: Use ReconnectInfo.ProtoReflect.Descriptor instead.

                                                                                                                                                      func (*ReconnectInfo) GetBackoffMs

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

                                                                                                                                                      func (*ReconnectInfo) GetPassed

                                                                                                                                                      func (x *ReconnectInfo) GetPassed() bool

                                                                                                                                                      func (*ReconnectInfo) ProtoMessage

                                                                                                                                                      func (*ReconnectInfo) ProtoMessage()

                                                                                                                                                      func (*ReconnectInfo) ProtoReflect

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

                                                                                                                                                      func (*ReconnectInfo) Reset

                                                                                                                                                      func (x *ReconnectInfo) Reset()

                                                                                                                                                      func (*ReconnectInfo) String

                                                                                                                                                      func (x *ReconnectInfo) String() string

                                                                                                                                                      type ReconnectParams

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

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

                                                                                                                                                        func (*ReconnectParams) Descriptor

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

                                                                                                                                                          Deprecated: Use ReconnectParams.ProtoReflect.Descriptor instead.

                                                                                                                                                          func (*ReconnectParams) GetMaxReconnectBackoffMs

                                                                                                                                                          func (x *ReconnectParams) GetMaxReconnectBackoffMs() int32

                                                                                                                                                          func (*ReconnectParams) ProtoMessage

                                                                                                                                                          func (*ReconnectParams) ProtoMessage()

                                                                                                                                                          func (*ReconnectParams) ProtoReflect

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

                                                                                                                                                          func (*ReconnectParams) Reset

                                                                                                                                                          func (x *ReconnectParams) Reset()

                                                                                                                                                          func (*ReconnectParams) String

                                                                                                                                                          func (x *ReconnectParams) String() string

                                                                                                                                                          type ReconnectServiceClient

                                                                                                                                                          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.

                                                                                                                                                            type ReconnectServiceServer

                                                                                                                                                            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

                                                                                                                                                              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.

                                                                                                                                                                type ReportQpsScenarioServiceServer

                                                                                                                                                                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

                                                                                                                                                                  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

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

                                                                                                                                                                    Deprecated: Use RequestResultCount.ProtoReflect.Descriptor instead.

                                                                                                                                                                    func (*RequestResultCount) GetCount

                                                                                                                                                                    func (x *RequestResultCount) GetCount() int64

                                                                                                                                                                    func (*RequestResultCount) GetStatusCode

                                                                                                                                                                    func (x *RequestResultCount) GetStatusCode() int32

                                                                                                                                                                    func (*RequestResultCount) ProtoMessage

                                                                                                                                                                    func (*RequestResultCount) ProtoMessage()

                                                                                                                                                                    func (*RequestResultCount) ProtoReflect

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

                                                                                                                                                                    func (*RequestResultCount) Reset

                                                                                                                                                                    func (x *RequestResultCount) Reset()

                                                                                                                                                                    func (*RequestResultCount) String

                                                                                                                                                                    func (x *RequestResultCount) String() string

                                                                                                                                                                    type ResponseParameters

                                                                                                                                                                    type ResponseParameters struct {
                                                                                                                                                                    
                                                                                                                                                                    	// 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

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

                                                                                                                                                                        Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.

                                                                                                                                                                        func (*ResponseParameters) GetCompressed

                                                                                                                                                                        func (x *ResponseParameters) GetCompressed() *BoolValue

                                                                                                                                                                        func (*ResponseParameters) GetIntervalUs

                                                                                                                                                                        func (x *ResponseParameters) GetIntervalUs() int32

                                                                                                                                                                        func (*ResponseParameters) GetSize

                                                                                                                                                                        func (x *ResponseParameters) GetSize() int32

                                                                                                                                                                        func (*ResponseParameters) ProtoMessage

                                                                                                                                                                        func (*ResponseParameters) ProtoMessage()

                                                                                                                                                                        func (*ResponseParameters) ProtoReflect

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

                                                                                                                                                                        func (*ResponseParameters) Reset

                                                                                                                                                                        func (x *ResponseParameters) Reset()

                                                                                                                                                                        func (*ResponseParameters) String

                                                                                                                                                                        func (x *ResponseParameters) String() string

                                                                                                                                                                        type RpcType

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

                                                                                                                                                                        func (RpcType) Descriptor

                                                                                                                                                                        func (RpcType) Descriptor() protoreflect.EnumDescriptor

                                                                                                                                                                        func (RpcType) Enum

                                                                                                                                                                        func (x RpcType) Enum() *RpcType

                                                                                                                                                                        func (RpcType) EnumDescriptor

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

                                                                                                                                                                          Deprecated: Use RpcType.Descriptor instead.

                                                                                                                                                                          func (RpcType) Number

                                                                                                                                                                          func (x RpcType) Number() protoreflect.EnumNumber

                                                                                                                                                                          func (RpcType) String

                                                                                                                                                                          func (x RpcType) String() string

                                                                                                                                                                          func (RpcType) Type

                                                                                                                                                                          func (RpcType) Type() protoreflect.EnumType

                                                                                                                                                                          type Scenario

                                                                                                                                                                          type Scenario struct {
                                                                                                                                                                          
                                                                                                                                                                          	// 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 `` /* 129-byte string literal not displayed */
                                                                                                                                                                          	// contains filtered or unexported fields
                                                                                                                                                                          }

                                                                                                                                                                            A single performance scenario: input to qps_json_driver

                                                                                                                                                                            func (*Scenario) Descriptor

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

                                                                                                                                                                              Deprecated: Use Scenario.ProtoReflect.Descriptor instead.

                                                                                                                                                                              func (*Scenario) GetBenchmarkSeconds

                                                                                                                                                                              func (x *Scenario) GetBenchmarkSeconds() int32

                                                                                                                                                                              func (*Scenario) GetClientConfig

                                                                                                                                                                              func (x *Scenario) GetClientConfig() *ClientConfig

                                                                                                                                                                              func (*Scenario) GetName

                                                                                                                                                                              func (x *Scenario) GetName() string

                                                                                                                                                                              func (*Scenario) GetNumClients

                                                                                                                                                                              func (x *Scenario) GetNumClients() int32

                                                                                                                                                                              func (*Scenario) GetNumServers

                                                                                                                                                                              func (x *Scenario) GetNumServers() int32

                                                                                                                                                                              func (*Scenario) GetServerConfig

                                                                                                                                                                              func (x *Scenario) GetServerConfig() *ServerConfig

                                                                                                                                                                              func (*Scenario) GetSpawnLocalWorkerCount

                                                                                                                                                                              func (x *Scenario) GetSpawnLocalWorkerCount() int32

                                                                                                                                                                              func (*Scenario) GetWarmupSeconds

                                                                                                                                                                              func (x *Scenario) GetWarmupSeconds() int32

                                                                                                                                                                              func (*Scenario) ProtoMessage

                                                                                                                                                                              func (*Scenario) ProtoMessage()

                                                                                                                                                                              func (*Scenario) ProtoReflect

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

                                                                                                                                                                              func (*Scenario) Reset

                                                                                                                                                                              func (x *Scenario) Reset()

                                                                                                                                                                              func (*Scenario) String

                                                                                                                                                                              func (x *Scenario) String() string

                                                                                                                                                                              type ScenarioResult

                                                                                                                                                                              type ScenarioResult struct {
                                                                                                                                                                              
                                                                                                                                                                              	// 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

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

                                                                                                                                                                                  Deprecated: Use ScenarioResult.ProtoReflect.Descriptor instead.

                                                                                                                                                                                  func (*ScenarioResult) GetClientStats

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

                                                                                                                                                                                  func (*ScenarioResult) GetClientSuccess

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

                                                                                                                                                                                  func (*ScenarioResult) GetLatencies

                                                                                                                                                                                  func (x *ScenarioResult) GetLatencies() *HistogramData

                                                                                                                                                                                  func (*ScenarioResult) GetRequestResults

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

                                                                                                                                                                                  func (*ScenarioResult) GetScenario

                                                                                                                                                                                  func (x *ScenarioResult) GetScenario() *Scenario

                                                                                                                                                                                  func (*ScenarioResult) GetServerCores

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

                                                                                                                                                                                  func (*ScenarioResult) GetServerStats

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

                                                                                                                                                                                  func (*ScenarioResult) GetServerSuccess

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

                                                                                                                                                                                  func (*ScenarioResult) GetSummary

                                                                                                                                                                                  func (x *ScenarioResult) GetSummary() *ScenarioResultSummary

                                                                                                                                                                                  func (*ScenarioResult) ProtoMessage

                                                                                                                                                                                  func (*ScenarioResult) ProtoMessage()

                                                                                                                                                                                  func (*ScenarioResult) ProtoReflect

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

                                                                                                                                                                                  func (*ScenarioResult) Reset

                                                                                                                                                                                  func (x *ScenarioResult) Reset()

                                                                                                                                                                                  func (*ScenarioResult) String

                                                                                                                                                                                  func (x *ScenarioResult) String() string

                                                                                                                                                                                  type ScenarioResultSummary

                                                                                                                                                                                  type ScenarioResultSummary struct {
                                                                                                                                                                                  
                                                                                                                                                                                  	// 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 `` /* 149-byte string literal not displayed */
                                                                                                                                                                                  	FailedRequestsPerSecond     float64 `` /* 137-byte string literal not displayed */
                                                                                                                                                                                  	// Number of polls called inside completion queue per request
                                                                                                                                                                                  	ClientPollsPerRequest float64 `` /* 131-byte string literal not displayed */
                                                                                                                                                                                  	ServerPollsPerRequest float64 `` /* 131-byte string literal not displayed */
                                                                                                                                                                                  	// Queries per CPU-sec over all servers or clients
                                                                                                                                                                                  	ServerQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */
                                                                                                                                                                                  	ClientQueriesPerCpuSec float64 `` /* 136-byte string literal not displayed */
                                                                                                                                                                                  	// contains filtered or unexported fields
                                                                                                                                                                                  }

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

                                                                                                                                                                                    func (*ScenarioResultSummary) Descriptor

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

                                                                                                                                                                                      Deprecated: Use ScenarioResultSummary.ProtoReflect.Descriptor instead.

                                                                                                                                                                                      func (*ScenarioResultSummary) GetClientPollsPerRequest

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetClientPollsPerRequest() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetClientQueriesPerCpuSec

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetClientQueriesPerCpuSec() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetClientSystemTime

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetClientSystemTime() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetClientUserTime

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetClientUserTime() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetFailedRequestsPerSecond

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetFailedRequestsPerSecond() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetLatency_50

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetLatency_50() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetLatency_90

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetLatency_90() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetLatency_95

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetLatency_95() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetLatency_99

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetLatency_99() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetLatency_999

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetLatency_999() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetQps

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetQps() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetQpsPerServerCore

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetQpsPerServerCore() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetServerCpuUsage

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetServerCpuUsage() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetServerPollsPerRequest

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetServerPollsPerRequest() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetServerQueriesPerCpuSec

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetServerQueriesPerCpuSec() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetServerSystemTime

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetServerSystemTime() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetServerUserTime

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetServerUserTime() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) GetSuccessfulRequestsPerSecond

                                                                                                                                                                                      func (x *ScenarioResultSummary) GetSuccessfulRequestsPerSecond() float64

                                                                                                                                                                                      func (*ScenarioResultSummary) ProtoMessage

                                                                                                                                                                                      func (*ScenarioResultSummary) ProtoMessage()

                                                                                                                                                                                      func (*ScenarioResultSummary) ProtoReflect

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

                                                                                                                                                                                      func (*ScenarioResultSummary) Reset

                                                                                                                                                                                      func (x *ScenarioResultSummary) Reset()

                                                                                                                                                                                      func (*ScenarioResultSummary) String

                                                                                                                                                                                      func (x *ScenarioResultSummary) String() string

                                                                                                                                                                                      type Scenarios

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

                                                                                                                                                                                        A set of scenarios to be run with qps_json_driver

                                                                                                                                                                                        func (*Scenarios) Descriptor

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

                                                                                                                                                                                          Deprecated: Use Scenarios.ProtoReflect.Descriptor instead.

                                                                                                                                                                                          func (*Scenarios) GetScenarios

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

                                                                                                                                                                                          func (*Scenarios) ProtoMessage

                                                                                                                                                                                          func (*Scenarios) ProtoMessage()

                                                                                                                                                                                          func (*Scenarios) ProtoReflect

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

                                                                                                                                                                                          func (*Scenarios) Reset

                                                                                                                                                                                          func (x *Scenarios) Reset()

                                                                                                                                                                                          func (*Scenarios) String

                                                                                                                                                                                          func (x *Scenarios) String() string

                                                                                                                                                                                          type SecurityParams

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

                                                                                                                                                                                            presence of SecurityParams implies use of TLS

                                                                                                                                                                                            func (*SecurityParams) Descriptor

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

                                                                                                                                                                                              Deprecated: Use SecurityParams.ProtoReflect.Descriptor instead.

                                                                                                                                                                                              func (*SecurityParams) GetCredType

                                                                                                                                                                                              func (x *SecurityParams) GetCredType() string

                                                                                                                                                                                              func (*SecurityParams) GetServerHostOverride

                                                                                                                                                                                              func (x *SecurityParams) GetServerHostOverride() string

                                                                                                                                                                                              func (*SecurityParams) GetUseTestCa

                                                                                                                                                                                              func (x *SecurityParams) GetUseTestCa() bool

                                                                                                                                                                                              func (*SecurityParams) ProtoMessage

                                                                                                                                                                                              func (*SecurityParams) ProtoMessage()

                                                                                                                                                                                              func (*SecurityParams) ProtoReflect

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

                                                                                                                                                                                              func (*SecurityParams) Reset

                                                                                                                                                                                              func (x *SecurityParams) Reset()

                                                                                                                                                                                              func (*SecurityParams) String

                                                                                                                                                                                              func (x *SecurityParams) String() string

                                                                                                                                                                                              type ServerArgs

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

                                                                                                                                                                                              func (*ServerArgs) Descriptor

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

                                                                                                                                                                                                Deprecated: Use ServerArgs.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                func (*ServerArgs) GetArgtype

                                                                                                                                                                                                func (m *ServerArgs) GetArgtype() isServerArgs_Argtype

                                                                                                                                                                                                func (*ServerArgs) GetMark

                                                                                                                                                                                                func (x *ServerArgs) GetMark() *Mark

                                                                                                                                                                                                func (*ServerArgs) GetSetup

                                                                                                                                                                                                func (x *ServerArgs) GetSetup() *ServerConfig

                                                                                                                                                                                                func (*ServerArgs) ProtoMessage

                                                                                                                                                                                                func (*ServerArgs) ProtoMessage()

                                                                                                                                                                                                func (*ServerArgs) ProtoReflect

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

                                                                                                                                                                                                func (*ServerArgs) Reset

                                                                                                                                                                                                func (x *ServerArgs) Reset()

                                                                                                                                                                                                func (*ServerArgs) String

                                                                                                                                                                                                func (x *ServerArgs) String() string

                                                                                                                                                                                                type ServerArgs_Mark

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

                                                                                                                                                                                                type ServerArgs_Setup

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

                                                                                                                                                                                                type ServerConfig

                                                                                                                                                                                                type ServerConfig struct {
                                                                                                                                                                                                	ServerType     ServerType      `protobuf:"varint,1,opt,name=server_type,json=serverType,proto3,enum=grpc.testing.ServerType" json:"server_type,omitempty"`
                                                                                                                                                                                                	SecurityParams *SecurityParams `protobuf:"bytes,2,opt,name=security_params,json=securityParams,proto3" json:"security_params,omitempty"`
                                                                                                                                                                                                	// Port 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

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

                                                                                                                                                                                                  Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                  func (*ServerConfig) GetAsyncServerThreads

                                                                                                                                                                                                  func (x *ServerConfig) GetAsyncServerThreads() int32

                                                                                                                                                                                                  func (*ServerConfig) GetChannelArgs

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

                                                                                                                                                                                                  func (*ServerConfig) GetCoreLimit

                                                                                                                                                                                                  func (x *ServerConfig) GetCoreLimit() int32

                                                                                                                                                                                                  func (*ServerConfig) GetCoreList

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

                                                                                                                                                                                                  func (*ServerConfig) GetOtherServerApi

                                                                                                                                                                                                  func (x *ServerConfig) GetOtherServerApi() string

                                                                                                                                                                                                  func (*ServerConfig) GetPayloadConfig

                                                                                                                                                                                                  func (x *ServerConfig) GetPayloadConfig() *PayloadConfig

                                                                                                                                                                                                  func (*ServerConfig) GetPort

                                                                                                                                                                                                  func (x *ServerConfig) GetPort() int32

                                                                                                                                                                                                  func (*ServerConfig) GetResourceQuotaSize

                                                                                                                                                                                                  func (x *ServerConfig) GetResourceQuotaSize() int32

                                                                                                                                                                                                  func (*ServerConfig) GetSecurityParams

                                                                                                                                                                                                  func (x *ServerConfig) GetSecurityParams() *SecurityParams

                                                                                                                                                                                                  func (*ServerConfig) GetServerProcesses

                                                                                                                                                                                                  func (x *ServerConfig) GetServerProcesses() int32

                                                                                                                                                                                                  func (*ServerConfig) GetServerType

                                                                                                                                                                                                  func (x *ServerConfig) GetServerType() ServerType

                                                                                                                                                                                                  func (*ServerConfig) GetThreadsPerCq

                                                                                                                                                                                                  func (x *ServerConfig) GetThreadsPerCq() int32

                                                                                                                                                                                                  func (*ServerConfig) ProtoMessage

                                                                                                                                                                                                  func (*ServerConfig) ProtoMessage()

                                                                                                                                                                                                  func (*ServerConfig) ProtoReflect

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

                                                                                                                                                                                                  func (*ServerConfig) Reset

                                                                                                                                                                                                  func (x *ServerConfig) Reset()

                                                                                                                                                                                                  func (*ServerConfig) String

                                                                                                                                                                                                  func (x *ServerConfig) String() string

                                                                                                                                                                                                  type ServerStats

                                                                                                                                                                                                  type ServerStats struct {
                                                                                                                                                                                                  
                                                                                                                                                                                                  	// 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

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

                                                                                                                                                                                                    Deprecated: Use ServerStats.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                    func (*ServerStats) GetCoreStats

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

                                                                                                                                                                                                    func (*ServerStats) GetCqPollCount

                                                                                                                                                                                                    func (x *ServerStats) GetCqPollCount() uint64

                                                                                                                                                                                                    func (*ServerStats) GetIdleCpuTime

                                                                                                                                                                                                    func (x *ServerStats) GetIdleCpuTime() uint64

                                                                                                                                                                                                    func (*ServerStats) GetTimeElapsed

                                                                                                                                                                                                    func (x *ServerStats) GetTimeElapsed() float64

                                                                                                                                                                                                    func (*ServerStats) GetTimeSystem

                                                                                                                                                                                                    func (x *ServerStats) GetTimeSystem() float64

                                                                                                                                                                                                    func (*ServerStats) GetTimeUser

                                                                                                                                                                                                    func (x *ServerStats) GetTimeUser() float64

                                                                                                                                                                                                    func (*ServerStats) GetTotalCpuTime

                                                                                                                                                                                                    func (x *ServerStats) GetTotalCpuTime() uint64

                                                                                                                                                                                                    func (*ServerStats) ProtoMessage

                                                                                                                                                                                                    func (*ServerStats) ProtoMessage()

                                                                                                                                                                                                    func (*ServerStats) ProtoReflect

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

                                                                                                                                                                                                    func (*ServerStats) Reset

                                                                                                                                                                                                    func (x *ServerStats) Reset()

                                                                                                                                                                                                    func (*ServerStats) String

                                                                                                                                                                                                    func (x *ServerStats) String() string

                                                                                                                                                                                                    type ServerStatus

                                                                                                                                                                                                    type ServerStatus struct {
                                                                                                                                                                                                    	Stats *ServerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
                                                                                                                                                                                                    	// 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

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

                                                                                                                                                                                                      Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                      func (*ServerStatus) GetCores

                                                                                                                                                                                                      func (x *ServerStatus) GetCores() int32

                                                                                                                                                                                                      func (*ServerStatus) GetPort

                                                                                                                                                                                                      func (x *ServerStatus) GetPort() int32

                                                                                                                                                                                                      func (*ServerStatus) GetStats

                                                                                                                                                                                                      func (x *ServerStatus) GetStats() *ServerStats

                                                                                                                                                                                                      func (*ServerStatus) ProtoMessage

                                                                                                                                                                                                      func (*ServerStatus) ProtoMessage()

                                                                                                                                                                                                      func (*ServerStatus) ProtoReflect

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

                                                                                                                                                                                                      func (*ServerStatus) Reset

                                                                                                                                                                                                      func (x *ServerStatus) Reset()

                                                                                                                                                                                                      func (*ServerStatus) String

                                                                                                                                                                                                      func (x *ServerStatus) String() string

                                                                                                                                                                                                      type ServerType

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

                                                                                                                                                                                                      func (ServerType) Descriptor

                                                                                                                                                                                                      func (ServerType) Descriptor() protoreflect.EnumDescriptor

                                                                                                                                                                                                      func (ServerType) Enum

                                                                                                                                                                                                      func (x ServerType) Enum() *ServerType

                                                                                                                                                                                                      func (ServerType) EnumDescriptor

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

                                                                                                                                                                                                        Deprecated: Use ServerType.Descriptor instead.

                                                                                                                                                                                                        func (ServerType) Number

                                                                                                                                                                                                        func (x ServerType) Number() protoreflect.EnumNumber

                                                                                                                                                                                                        func (ServerType) String

                                                                                                                                                                                                        func (x ServerType) String() string

                                                                                                                                                                                                        func (ServerType) Type

                                                                                                                                                                                                        type SimpleProtoParams

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

                                                                                                                                                                                                        func (*SimpleProtoParams) Descriptor

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

                                                                                                                                                                                                          Deprecated: Use SimpleProtoParams.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                          func (*SimpleProtoParams) GetReqSize

                                                                                                                                                                                                          func (x *SimpleProtoParams) GetReqSize() int32

                                                                                                                                                                                                          func (*SimpleProtoParams) GetRespSize

                                                                                                                                                                                                          func (x *SimpleProtoParams) GetRespSize() int32

                                                                                                                                                                                                          func (*SimpleProtoParams) ProtoMessage

                                                                                                                                                                                                          func (*SimpleProtoParams) ProtoMessage()

                                                                                                                                                                                                          func (*SimpleProtoParams) ProtoReflect

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

                                                                                                                                                                                                          func (*SimpleProtoParams) Reset

                                                                                                                                                                                                          func (x *SimpleProtoParams) Reset()

                                                                                                                                                                                                          func (*SimpleProtoParams) String

                                                                                                                                                                                                          func (x *SimpleProtoParams) String() string

                                                                                                                                                                                                          type SimpleRequest

                                                                                                                                                                                                          type SimpleRequest struct {
                                                                                                                                                                                                          
                                                                                                                                                                                                          	// Desired payload type in the response from the server.
                                                                                                                                                                                                          	// If response_type is RANDOM, server randomly chooses one from other formats.
                                                                                                                                                                                                          	ResponseType PayloadType `` /* 128-byte string literal not displayed */
                                                                                                                                                                                                          	// 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

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

                                                                                                                                                                                                              Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                              func (*SimpleRequest) GetExpectCompressed

                                                                                                                                                                                                              func (x *SimpleRequest) GetExpectCompressed() *BoolValue

                                                                                                                                                                                                              func (*SimpleRequest) GetFillGrpclbRouteType

                                                                                                                                                                                                              func (x *SimpleRequest) GetFillGrpclbRouteType() bool

                                                                                                                                                                                                              func (*SimpleRequest) GetFillOauthScope

                                                                                                                                                                                                              func (x *SimpleRequest) GetFillOauthScope() bool

                                                                                                                                                                                                              func (*SimpleRequest) GetFillServerId

                                                                                                                                                                                                              func (x *SimpleRequest) GetFillServerId() bool

                                                                                                                                                                                                              func (*SimpleRequest) GetFillUsername

                                                                                                                                                                                                              func (x *SimpleRequest) GetFillUsername() bool

                                                                                                                                                                                                              func (*SimpleRequest) GetPayload

                                                                                                                                                                                                              func (x *SimpleRequest) GetPayload() *Payload

                                                                                                                                                                                                              func (*SimpleRequest) GetResponseCompressed

                                                                                                                                                                                                              func (x *SimpleRequest) GetResponseCompressed() *BoolValue

                                                                                                                                                                                                              func (*SimpleRequest) GetResponseSize

                                                                                                                                                                                                              func (x *SimpleRequest) GetResponseSize() int32

                                                                                                                                                                                                              func (*SimpleRequest) GetResponseStatus

                                                                                                                                                                                                              func (x *SimpleRequest) GetResponseStatus() *EchoStatus

                                                                                                                                                                                                              func (*SimpleRequest) GetResponseType

                                                                                                                                                                                                              func (x *SimpleRequest) GetResponseType() PayloadType

                                                                                                                                                                                                              func (*SimpleRequest) ProtoMessage

                                                                                                                                                                                                              func (*SimpleRequest) ProtoMessage()

                                                                                                                                                                                                              func (*SimpleRequest) ProtoReflect

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

                                                                                                                                                                                                              func (*SimpleRequest) Reset

                                                                                                                                                                                                              func (x *SimpleRequest) Reset()

                                                                                                                                                                                                              func (*SimpleRequest) String

                                                                                                                                                                                                              func (x *SimpleRequest) String() string

                                                                                                                                                                                                              type SimpleResponse

                                                                                                                                                                                                              type SimpleResponse struct {
                                                                                                                                                                                                              
                                                                                                                                                                                                              	// Payload 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 `` /* 143-byte string literal not displayed */
                                                                                                                                                                                                              	// 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

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

                                                                                                                                                                                                                  Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                  func (*SimpleResponse) GetGrpclbRouteType

                                                                                                                                                                                                                  func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

                                                                                                                                                                                                                  func (*SimpleResponse) GetHostname

                                                                                                                                                                                                                  func (x *SimpleResponse) GetHostname() string

                                                                                                                                                                                                                  func (*SimpleResponse) GetOauthScope

                                                                                                                                                                                                                  func (x *SimpleResponse) GetOauthScope() string

                                                                                                                                                                                                                  func (*SimpleResponse) GetPayload

                                                                                                                                                                                                                  func (x *SimpleResponse) GetPayload() *Payload

                                                                                                                                                                                                                  func (*SimpleResponse) GetServerId

                                                                                                                                                                                                                  func (x *SimpleResponse) GetServerId() string

                                                                                                                                                                                                                  func (*SimpleResponse) GetUsername

                                                                                                                                                                                                                  func (x *SimpleResponse) GetUsername() string

                                                                                                                                                                                                                  func (*SimpleResponse) ProtoMessage

                                                                                                                                                                                                                  func (*SimpleResponse) ProtoMessage()

                                                                                                                                                                                                                  func (*SimpleResponse) ProtoReflect

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

                                                                                                                                                                                                                  func (*SimpleResponse) Reset

                                                                                                                                                                                                                  func (x *SimpleResponse) Reset()

                                                                                                                                                                                                                  func (*SimpleResponse) String

                                                                                                                                                                                                                  func (x *SimpleResponse) String() string

                                                                                                                                                                                                                  type StreamingInputCallRequest

                                                                                                                                                                                                                  type StreamingInputCallRequest struct {
                                                                                                                                                                                                                  
                                                                                                                                                                                                                  	// 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

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

                                                                                                                                                                                                                      Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) GetExpectCompressed

                                                                                                                                                                                                                      func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) GetPayload

                                                                                                                                                                                                                      func (x *StreamingInputCallRequest) GetPayload() *Payload

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) ProtoMessage

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) ProtoMessage()

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) ProtoReflect

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) Reset

                                                                                                                                                                                                                      func (x *StreamingInputCallRequest) Reset()

                                                                                                                                                                                                                      func (*StreamingInputCallRequest) String

                                                                                                                                                                                                                      func (x *StreamingInputCallRequest) String() string

                                                                                                                                                                                                                      type StreamingInputCallResponse

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

                                                                                                                                                                                                                        Client-streaming response.

                                                                                                                                                                                                                        func (*StreamingInputCallResponse) Descriptor

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

                                                                                                                                                                                                                          Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) GetAggregatedPayloadSize

                                                                                                                                                                                                                          func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) ProtoMessage

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) ProtoMessage()

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) ProtoReflect

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) Reset

                                                                                                                                                                                                                          func (x *StreamingInputCallResponse) Reset()

                                                                                                                                                                                                                          func (*StreamingInputCallResponse) String

                                                                                                                                                                                                                          func (x *StreamingInputCallResponse) String() string

                                                                                                                                                                                                                          type StreamingOutputCallRequest

                                                                                                                                                                                                                          type StreamingOutputCallRequest struct {
                                                                                                                                                                                                                          
                                                                                                                                                                                                                          	// 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 `` /* 128-byte string literal not displayed */
                                                                                                                                                                                                                          	// Configuration for each expected response message.
                                                                                                                                                                                                                          	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
                                                                                                                                                                                                                          	// Optional input payload sent along with the request.
                                                                                                                                                                                                                          	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
                                                                                                                                                                                                                          	// Whether server should return a given 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

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

                                                                                                                                                                                                                              Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) GetPayload

                                                                                                                                                                                                                              func (x *StreamingOutputCallRequest) GetPayload() *Payload

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) GetResponseParameters

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

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) GetResponseStatus

                                                                                                                                                                                                                              func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) GetResponseType

                                                                                                                                                                                                                              func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) ProtoMessage

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) ProtoMessage()

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) ProtoReflect

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) Reset

                                                                                                                                                                                                                              func (x *StreamingOutputCallRequest) Reset()

                                                                                                                                                                                                                              func (*StreamingOutputCallRequest) String

                                                                                                                                                                                                                              func (x *StreamingOutputCallRequest) String() string

                                                                                                                                                                                                                              type StreamingOutputCallResponse

                                                                                                                                                                                                                              type StreamingOutputCallResponse struct {
                                                                                                                                                                                                                              
                                                                                                                                                                                                                              	// Payload 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

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

                                                                                                                                                                                                                                  Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) GetPayload

                                                                                                                                                                                                                                  func (x *StreamingOutputCallResponse) GetPayload() *Payload

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) ProtoMessage

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) ProtoMessage()

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) ProtoReflect

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) Reset

                                                                                                                                                                                                                                  func (x *StreamingOutputCallResponse) Reset()

                                                                                                                                                                                                                                  func (*StreamingOutputCallResponse) String

                                                                                                                                                                                                                                  func (x *StreamingOutputCallResponse) String() string

                                                                                                                                                                                                                                  type TestServiceClient

                                                                                                                                                                                                                                  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.

                                                                                                                                                                                                                                    type TestServiceServer

                                                                                                                                                                                                                                    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

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

                                                                                                                                                                                                                                      type TestService_FullDuplexCallServer

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

                                                                                                                                                                                                                                      type TestService_HalfDuplexCallClient

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

                                                                                                                                                                                                                                      type TestService_HalfDuplexCallServer

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

                                                                                                                                                                                                                                      type TestService_StreamingInputCallClient

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

                                                                                                                                                                                                                                      type TestService_StreamingInputCallServer

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

                                                                                                                                                                                                                                      type TestService_StreamingOutputCallClient

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

                                                                                                                                                                                                                                      type TestService_StreamingOutputCallServer

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

                                                                                                                                                                                                                                      type UnimplementedBenchmarkServiceServer

                                                                                                                                                                                                                                      type UnimplementedBenchmarkServiceServer struct {
                                                                                                                                                                                                                                      }

                                                                                                                                                                                                                                        UnimplementedBenchmarkServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                        func (UnimplementedBenchmarkServiceServer) StreamingBothWays

                                                                                                                                                                                                                                        func (UnimplementedBenchmarkServiceServer) StreamingCall

                                                                                                                                                                                                                                        func (UnimplementedBenchmarkServiceServer) StreamingFromClient

                                                                                                                                                                                                                                        func (UnimplementedBenchmarkServiceServer) StreamingFromServer

                                                                                                                                                                                                                                        func (UnimplementedBenchmarkServiceServer) UnaryCall

                                                                                                                                                                                                                                        type UnimplementedLoadBalancerStatsServiceServer

                                                                                                                                                                                                                                        type UnimplementedLoadBalancerStatsServiceServer struct {
                                                                                                                                                                                                                                        }

                                                                                                                                                                                                                                          UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                          func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats

                                                                                                                                                                                                                                          type UnimplementedReconnectServiceServer

                                                                                                                                                                                                                                          type UnimplementedReconnectServiceServer struct {
                                                                                                                                                                                                                                          }

                                                                                                                                                                                                                                            UnimplementedReconnectServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                            func (UnimplementedReconnectServiceServer) Start

                                                                                                                                                                                                                                            func (UnimplementedReconnectServiceServer) Stop

                                                                                                                                                                                                                                            type UnimplementedReportQpsScenarioServiceServer

                                                                                                                                                                                                                                            type UnimplementedReportQpsScenarioServiceServer struct {
                                                                                                                                                                                                                                            }

                                                                                                                                                                                                                                              UnimplementedReportQpsScenarioServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                              func (UnimplementedReportQpsScenarioServiceServer) ReportScenario

                                                                                                                                                                                                                                              type UnimplementedServiceClient

                                                                                                                                                                                                                                              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.

                                                                                                                                                                                                                                                type UnimplementedServiceServer

                                                                                                                                                                                                                                                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

                                                                                                                                                                                                                                                  type UnimplementedTestServiceServer struct {
                                                                                                                                                                                                                                                  }

                                                                                                                                                                                                                                                    UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) CacheableUnaryCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) EmptyCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) FullDuplexCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) HalfDuplexCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) StreamingInputCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) UnaryCall

                                                                                                                                                                                                                                                    func (UnimplementedTestServiceServer) UnimplementedCall

                                                                                                                                                                                                                                                    type UnimplementedUnimplementedServiceServer

                                                                                                                                                                                                                                                    type UnimplementedUnimplementedServiceServer struct {
                                                                                                                                                                                                                                                    }

                                                                                                                                                                                                                                                      UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                      func (UnimplementedUnimplementedServiceServer) UnimplementedCall

                                                                                                                                                                                                                                                      type UnimplementedWorkerServiceServer

                                                                                                                                                                                                                                                      type UnimplementedWorkerServiceServer struct {
                                                                                                                                                                                                                                                      }

                                                                                                                                                                                                                                                        UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                        func (UnimplementedWorkerServiceServer) CoreCount

                                                                                                                                                                                                                                                        func (UnimplementedWorkerServiceServer) QuitWorker

                                                                                                                                                                                                                                                        func (UnimplementedWorkerServiceServer) RunClient

                                                                                                                                                                                                                                                        func (UnimplementedWorkerServiceServer) RunServer

                                                                                                                                                                                                                                                        type UnimplementedXdsUpdateClientConfigureServiceServer

                                                                                                                                                                                                                                                        type UnimplementedXdsUpdateClientConfigureServiceServer struct {
                                                                                                                                                                                                                                                        }

                                                                                                                                                                                                                                                          UnimplementedXdsUpdateClientConfigureServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                          func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure

                                                                                                                                                                                                                                                          type UnimplementedXdsUpdateHealthServiceServer

                                                                                                                                                                                                                                                          type UnimplementedXdsUpdateHealthServiceServer struct {
                                                                                                                                                                                                                                                          }

                                                                                                                                                                                                                                                            UnimplementedXdsUpdateHealthServiceServer must be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                            func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing

                                                                                                                                                                                                                                                            func (UnimplementedXdsUpdateHealthServiceServer) SetServing

                                                                                                                                                                                                                                                            type UnsafeBenchmarkServiceServer

                                                                                                                                                                                                                                                            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

                                                                                                                                                                                                                                                              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

                                                                                                                                                                                                                                                                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

                                                                                                                                                                                                                                                                  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

                                                                                                                                                                                                                                                                    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

                                                                                                                                                                                                                                                                      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

                                                                                                                                                                                                                                                                        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

                                                                                                                                                                                                                                                                          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

                                                                                                                                                                                                                                                                            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

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

                                                                                                                                                                                                                                                                              func (*Void) Descriptor

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

                                                                                                                                                                                                                                                                                Deprecated: Use Void.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                                                                func (*Void) ProtoMessage

                                                                                                                                                                                                                                                                                func (*Void) ProtoMessage()

                                                                                                                                                                                                                                                                                func (*Void) ProtoReflect

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

                                                                                                                                                                                                                                                                                func (*Void) Reset

                                                                                                                                                                                                                                                                                func (x *Void) Reset()

                                                                                                                                                                                                                                                                                func (*Void) String

                                                                                                                                                                                                                                                                                func (x *Void) String() string

                                                                                                                                                                                                                                                                                type WorkerServiceClient

                                                                                                                                                                                                                                                                                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.

                                                                                                                                                                                                                                                                                  type WorkerServiceServer

                                                                                                                                                                                                                                                                                  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

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

                                                                                                                                                                                                                                                                                    type WorkerService_RunClientServer

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

                                                                                                                                                                                                                                                                                    type WorkerService_RunServerClient

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

                                                                                                                                                                                                                                                                                    type WorkerService_RunServerServer

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

                                                                                                                                                                                                                                                                                    type XdsUpdateClientConfigureServiceClient

                                                                                                                                                                                                                                                                                    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.

                                                                                                                                                                                                                                                                                      type XdsUpdateClientConfigureServiceServer

                                                                                                                                                                                                                                                                                      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

                                                                                                                                                                                                                                                                                        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.

                                                                                                                                                                                                                                                                                          type XdsUpdateHealthServiceServer

                                                                                                                                                                                                                                                                                          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

                                                                                                                                                                                                                                                                                            Path Synopsis