Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
- func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer)
- func RegisterLoadBalancerStatsServiceServer(s grpc.ServiceRegistrar, srv LoadBalancerStatsServiceServer)
- func RegisterReconnectServiceServer(s grpc.ServiceRegistrar, srv ReconnectServiceServer)
- func RegisterReportQpsScenarioServiceServer(s grpc.ServiceRegistrar, srv ReportQpsScenarioServiceServer)
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)
- func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
- func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)
- func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)
- type BenchmarkServiceClient
- type BenchmarkServiceServer
- type BenchmarkService_StreamingBothWaysClient
- type BenchmarkService_StreamingBothWaysServer
- type BenchmarkService_StreamingCallClient
- type BenchmarkService_StreamingCallServer
- type BenchmarkService_StreamingFromClientClient
- type BenchmarkService_StreamingFromClientServer
- type BenchmarkService_StreamingFromServerClient
- type BenchmarkService_StreamingFromServerServer
- type HookServiceClient
- type HookServiceServer
- type LoadBalancerStatsServiceClient
- type LoadBalancerStatsServiceServer
- type ReconnectServiceClient
- type ReconnectServiceServer
- type ReportQpsScenarioServiceClient
- type ReportQpsScenarioServiceServer
- type TestServiceClient
- type TestServiceServer
- type TestService_FullDuplexCallClient
- type TestService_FullDuplexCallServer
- type TestService_HalfDuplexCallClient
- type TestService_HalfDuplexCallServer
- type TestService_StreamingInputCallClient
- type TestService_StreamingInputCallServer
- type TestService_StreamingOutputCallClient
- type TestService_StreamingOutputCallServer
- type UnimplementedBenchmarkServiceServer
- func (UnimplementedBenchmarkServiceServer) StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error
- func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error
- func (UnimplementedBenchmarkServiceServer) StreamingFromClient(BenchmarkService_StreamingFromClientServer) error
- func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*testing.SimpleRequest, BenchmarkService_StreamingFromServerServer) error
- func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
- type UnimplementedHookServiceServer
- func (UnimplementedHookServiceServer) ClearReturnStatus(context.Context, *testing.Empty) (*testing.Empty, error)
- func (UnimplementedHookServiceServer) Hook(context.Context, *testing.Empty) (*testing.Empty, error)
- func (UnimplementedHookServiceServer) SetReturnStatus(context.Context, *testing.SetReturnStatusRequest) (*testing.Empty, error)
- type UnimplementedLoadBalancerStatsServiceServer
- func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *testing.LoadBalancerAccumulatedStatsRequest) (*testing.LoadBalancerAccumulatedStatsResponse, error)
- func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats(context.Context, *testing.LoadBalancerStatsRequest) (*testing.LoadBalancerStatsResponse, error)
- type UnimplementedReconnectServiceServer
- type UnimplementedReportQpsScenarioServiceServer
- type UnimplementedServiceClient
- type UnimplementedServiceServer
- type UnimplementedTestServiceServer
- func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
- func (UnimplementedTestServiceServer) EmptyCall(context.Context, *testing.Empty) (*testing.Empty, error)
- func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error
- func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error
- func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error
- func (UnimplementedTestServiceServer) StreamingOutputCall(*testing.StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
- func (UnimplementedTestServiceServer) UnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
- func (UnimplementedTestServiceServer) UnimplementedCall(context.Context, *testing.Empty) (*testing.Empty, error)
- type UnimplementedUnimplementedServiceServer
- type UnimplementedWorkerServiceServer
- func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *testing.CoreRequest) (*testing.CoreResponse, error)
- func (UnimplementedWorkerServiceServer) QuitWorker(context.Context, *testing.Void) (*testing.Void, error)
- func (UnimplementedWorkerServiceServer) RunClient(WorkerService_RunClientServer) error
- func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error
- type UnimplementedXdsUpdateClientConfigureServiceServer
- type UnimplementedXdsUpdateHealthServiceServer
- func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *testing.HookRequest) (*testing.HookResponse, error)
- func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing(context.Context, *testing.Empty) (*testing.Empty, error)
- func (UnimplementedXdsUpdateHealthServiceServer) SetServing(context.Context, *testing.Empty) (*testing.Empty, error)
- type UnsafeBenchmarkServiceServer
- type UnsafeHookServiceServer
- type UnsafeLoadBalancerStatsServiceServer
- type UnsafeReconnectServiceServer
- type UnsafeReportQpsScenarioServiceServer
- type UnsafeTestServiceServer
- type UnsafeUnimplementedServiceServer
- type UnsafeWorkerServiceServer
- type UnsafeXdsUpdateClientConfigureServiceServer
- type UnsafeXdsUpdateHealthServiceServer
- type WorkerServiceClient
- type WorkerServiceServer
- type WorkerService_RunClientClient
- type WorkerService_RunClientServer
- type WorkerService_RunServerClient
- type WorkerService_RunServerServer
- type XdsUpdateClientConfigureServiceClient
- type XdsUpdateClientConfigureServiceServer
- type XdsUpdateHealthServiceClient
- type XdsUpdateHealthServiceServer
Constants ¶
const ( BenchmarkService_UnaryCall_FullMethodName = "/grpc.testing.BenchmarkService/UnaryCall" BenchmarkService_StreamingCall_FullMethodName = "/grpc.testing.BenchmarkService/StreamingCall" BenchmarkService_StreamingFromClient_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromClient" BenchmarkService_StreamingFromServer_FullMethodName = "/grpc.testing.BenchmarkService/StreamingFromServer" BenchmarkService_StreamingBothWays_FullMethodName = "/grpc.testing.BenchmarkService/StreamingBothWays" )
const ( TestService_EmptyCall_FullMethodName = "/grpc.testing.TestService/EmptyCall" TestService_UnaryCall_FullMethodName = "/grpc.testing.TestService/UnaryCall" TestService_CacheableUnaryCall_FullMethodName = "/grpc.testing.TestService/CacheableUnaryCall" TestService_StreamingOutputCall_FullMethodName = "/grpc.testing.TestService/StreamingOutputCall" TestService_StreamingInputCall_FullMethodName = "/grpc.testing.TestService/StreamingInputCall" TestService_FullDuplexCall_FullMethodName = "/grpc.testing.TestService/FullDuplexCall" TestService_HalfDuplexCall_FullMethodName = "/grpc.testing.TestService/HalfDuplexCall" TestService_UnimplementedCall_FullMethodName = "/grpc.testing.TestService/UnimplementedCall" )
const ( ReconnectService_Start_FullMethodName = "/grpc.testing.ReconnectService/Start" ReconnectService_Stop_FullMethodName = "/grpc.testing.ReconnectService/Stop" )
const ( LoadBalancerStatsService_GetClientStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientStats" LoadBalancerStatsService_GetClientAccumulatedStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientAccumulatedStats" )
const ( HookService_Hook_FullMethodName = "/grpc.testing.HookService/Hook" HookService_SetReturnStatus_FullMethodName = "/grpc.testing.HookService/SetReturnStatus" HookService_ClearReturnStatus_FullMethodName = "/grpc.testing.HookService/ClearReturnStatus" )
const ( XdsUpdateHealthService_SetServing_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SetServing" XdsUpdateHealthService_SetNotServing_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SetNotServing" XdsUpdateHealthService_SendHookRequest_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SendHookRequest" )
const ( WorkerService_RunServer_FullMethodName = "/grpc.testing.WorkerService/RunServer" WorkerService_RunClient_FullMethodName = "/grpc.testing.WorkerService/RunClient" WorkerService_CoreCount_FullMethodName = "/grpc.testing.WorkerService/CoreCount" WorkerService_QuitWorker_FullMethodName = "/grpc.testing.WorkerService/QuitWorker" )
const (
ReportQpsScenarioService_ReportScenario_FullMethodName = "/grpc.testing.ReportQpsScenarioService/ReportScenario"
)
const (
UnimplementedService_UnimplementedCall_FullMethodName = "/grpc.testing.UnimplementedService/UnimplementedCall"
)
const (
XdsUpdateClientConfigureService_Configure_FullMethodName = "/grpc.testing.XdsUpdateClientConfigureService/Configure"
)
Variables ¶
var BenchmarkService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.BenchmarkService", HandlerType: (*BenchmarkServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UnaryCall", Handler: _BenchmarkService_UnaryCall_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamingCall", Handler: _BenchmarkService_StreamingCall_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "StreamingFromClient", Handler: _BenchmarkService_StreamingFromClient_Handler, ClientStreams: true, }, { StreamName: "StreamingFromServer", Handler: _BenchmarkService_StreamingFromServer_Handler, ServerStreams: true, }, { StreamName: "StreamingBothWays", Handler: _BenchmarkService_StreamingBothWays_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/benchmark_service.proto", }
BenchmarkService_ServiceDesc is the grpc.ServiceDesc for BenchmarkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var HookService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.HookService", HandlerType: (*HookServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hook", Handler: _HookService_Hook_Handler, }, { MethodName: "SetReturnStatus", Handler: _HookService_SetReturnStatus_Handler, }, { MethodName: "ClearReturnStatus", Handler: _HookService_ClearReturnStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
HookService_ServiceDesc is the grpc.ServiceDesc for HookService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LoadBalancerStatsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.LoadBalancerStatsService", HandlerType: (*LoadBalancerStatsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetClientStats", Handler: _LoadBalancerStatsService_GetClientStats_Handler, }, { MethodName: "GetClientAccumulatedStats", Handler: _LoadBalancerStatsService_GetClientAccumulatedStats_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
LoadBalancerStatsService_ServiceDesc is the grpc.ServiceDesc for LoadBalancerStatsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReconnectService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.ReconnectService", HandlerType: (*ReconnectServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _ReconnectService_Start_Handler, }, { MethodName: "Stop", Handler: _ReconnectService_Stop_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
ReconnectService_ServiceDesc is the grpc.ServiceDesc for ReconnectService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReportQpsScenarioService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.ReportQpsScenarioService", HandlerType: (*ReportQpsScenarioServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReportScenario", Handler: _ReportQpsScenarioService_ReportScenario_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/report_qps_scenario_service.proto", }
ReportQpsScenarioService_ServiceDesc is the grpc.ServiceDesc for ReportQpsScenarioService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EmptyCall", Handler: _TestService_EmptyCall_Handler, }, { MethodName: "UnaryCall", Handler: _TestService_UnaryCall_Handler, }, { MethodName: "CacheableUnaryCall", Handler: _TestService_CacheableUnaryCall_Handler, }, { MethodName: "UnimplementedCall", Handler: _TestService_UnimplementedCall_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamingOutputCall", Handler: _TestService_StreamingOutputCall_Handler, ServerStreams: true, }, { StreamName: "StreamingInputCall", Handler: _TestService_StreamingInputCall_Handler, ClientStreams: true, }, { StreamName: "FullDuplexCall", Handler: _TestService_FullDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "HalfDuplexCall", Handler: _TestService_HalfDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/test.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UnimplementedService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.UnimplementedService", HandlerType: (*UnimplementedServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UnimplementedCall", Handler: _UnimplementedService_UnimplementedCall_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
UnimplementedService_ServiceDesc is the grpc.ServiceDesc for UnimplementedService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var WorkerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.WorkerService", HandlerType: (*WorkerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CoreCount", Handler: _WorkerService_CoreCount_Handler, }, { MethodName: "QuitWorker", Handler: _WorkerService_QuitWorker_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RunServer", Handler: _WorkerService_RunServer_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "RunClient", Handler: _WorkerService_RunClient_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/testing/worker_service.proto", }
WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var XdsUpdateClientConfigureService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.XdsUpdateClientConfigureService", HandlerType: (*XdsUpdateClientConfigureServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Configure", Handler: _XdsUpdateClientConfigureService_Configure_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
XdsUpdateClientConfigureService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateClientConfigureService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var XdsUpdateHealthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.XdsUpdateHealthService", HandlerType: (*XdsUpdateHealthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetServing", Handler: _XdsUpdateHealthService_SetServing_Handler, }, { MethodName: "SetNotServing", Handler: _XdsUpdateHealthService_SetNotServing_Handler, }, { MethodName: "SendHookRequest", Handler: _XdsUpdateHealthService_SendHookRequest_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/testing/test.proto", }
XdsUpdateHealthService_ServiceDesc is the grpc.ServiceDesc for XdsUpdateHealthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBenchmarkServiceServer ¶
func RegisterBenchmarkServiceServer(s grpc.ServiceRegistrar, srv BenchmarkServiceServer)
func RegisterHookServiceServer ¶
func RegisterHookServiceServer(s grpc.ServiceRegistrar, srv HookServiceServer)
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 *testing.SimpleRequest, opts ...grpc.CallOption) (*testing.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 *testing.SimpleRequest, opts ...grpc.CallOption) (BenchmarkService_StreamingFromServerClient, error) // Two-sided unbounded streaming between server to client // Both sides send the content of their own choice to the other StreamingBothWays(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingBothWaysClient, error) }
BenchmarkServiceClient is the client API for BenchmarkService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewBenchmarkServiceClient ¶
func NewBenchmarkServiceClient(cc grpc.ClientConnInterface) BenchmarkServiceClient
type BenchmarkServiceServer ¶
type BenchmarkServiceServer interface { // One request followed by one response. // The server returns the client payload as-is. UnaryCall(context.Context, *testing.SimpleRequest) (*testing.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(*testing.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 }
BenchmarkServiceServer is the server API for BenchmarkService service. All implementations should embed UnimplementedBenchmarkServiceServer for forward compatibility
type BenchmarkService_StreamingBothWaysClient ¶
type BenchmarkService_StreamingBothWaysClient interface { Send(*testing.SimpleRequest) error Recv() (*testing.SimpleResponse, error) grpc.ClientStream }
type BenchmarkService_StreamingBothWaysServer ¶
type BenchmarkService_StreamingBothWaysServer interface { Send(*testing.SimpleResponse) error Recv() (*testing.SimpleRequest, error) grpc.ServerStream }
type BenchmarkService_StreamingCallClient ¶
type BenchmarkService_StreamingCallClient interface { Send(*testing.SimpleRequest) error Recv() (*testing.SimpleResponse, error) grpc.ClientStream }
type BenchmarkService_StreamingCallServer ¶
type BenchmarkService_StreamingCallServer interface { Send(*testing.SimpleResponse) error Recv() (*testing.SimpleRequest, error) grpc.ServerStream }
type BenchmarkService_StreamingFromClientClient ¶
type BenchmarkService_StreamingFromClientClient interface { Send(*testing.SimpleRequest) error CloseAndRecv() (*testing.SimpleResponse, error) grpc.ClientStream }
type BenchmarkService_StreamingFromClientServer ¶
type BenchmarkService_StreamingFromClientServer interface { SendAndClose(*testing.SimpleResponse) error Recv() (*testing.SimpleRequest, error) grpc.ServerStream }
type BenchmarkService_StreamingFromServerClient ¶
type BenchmarkService_StreamingFromServerClient interface { Recv() (*testing.SimpleResponse, error) grpc.ClientStream }
type BenchmarkService_StreamingFromServerServer ¶
type BenchmarkService_StreamingFromServerServer interface { Send(*testing.SimpleResponse) error grpc.ServerStream }
type HookServiceClient ¶
type HookServiceClient interface { // Sends a request that will "hang" until the return status is set by a call // to a SetReturnStatus Hook(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) // Sets a return status for pending and upcoming calls to Hook SetReturnStatus(ctx context.Context, in *testing.SetReturnStatusRequest, opts ...grpc.CallOption) (*testing.Empty, error) // Clears the return status. Incoming calls to Hook will "hang" ClearReturnStatus(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) }
HookServiceClient is the client API for HookService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewHookServiceClient ¶
func NewHookServiceClient(cc grpc.ClientConnInterface) HookServiceClient
type HookServiceServer ¶
type HookServiceServer interface { // Sends a request that will "hang" until the return status is set by a call // to a SetReturnStatus Hook(context.Context, *testing.Empty) (*testing.Empty, error) // Sets a return status for pending and upcoming calls to Hook SetReturnStatus(context.Context, *testing.SetReturnStatusRequest) (*testing.Empty, error) // Clears the return status. Incoming calls to Hook will "hang" ClearReturnStatus(context.Context, *testing.Empty) (*testing.Empty, error) }
HookServiceServer is the server API for HookService service. All implementations should embed UnimplementedHookServiceServer for forward compatibility
type LoadBalancerStatsServiceClient ¶
type LoadBalancerStatsServiceClient interface { // Gets the backend distribution for RPCs sent by a test client. GetClientStats(ctx context.Context, in *testing.LoadBalancerStatsRequest, opts ...grpc.CallOption) (*testing.LoadBalancerStatsResponse, error) // Gets the accumulated stats for RPCs sent by a test client. GetClientAccumulatedStats(ctx context.Context, in *testing.LoadBalancerAccumulatedStatsRequest, opts ...grpc.CallOption) (*testing.LoadBalancerAccumulatedStatsResponse, error) }
LoadBalancerStatsServiceClient is the client API for LoadBalancerStatsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLoadBalancerStatsServiceClient ¶
func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient
type LoadBalancerStatsServiceServer ¶
type LoadBalancerStatsServiceServer interface { // Gets the backend distribution for RPCs sent by a test client. GetClientStats(context.Context, *testing.LoadBalancerStatsRequest) (*testing.LoadBalancerStatsResponse, error) // Gets the accumulated stats for RPCs sent by a test client. GetClientAccumulatedStats(context.Context, *testing.LoadBalancerAccumulatedStatsRequest) (*testing.LoadBalancerAccumulatedStatsResponse, error) }
LoadBalancerStatsServiceServer is the server API for LoadBalancerStatsService service. All implementations should embed UnimplementedLoadBalancerStatsServiceServer for forward compatibility
type ReconnectServiceClient ¶
type ReconnectServiceClient interface { Start(ctx context.Context, in *testing.ReconnectParams, opts ...grpc.CallOption) (*testing.Empty, error) Stop(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.ReconnectInfo, error) }
ReconnectServiceClient is the client API for ReconnectService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewReconnectServiceClient ¶
func NewReconnectServiceClient(cc grpc.ClientConnInterface) ReconnectServiceClient
type ReconnectServiceServer ¶
type ReconnectServiceServer interface { Start(context.Context, *testing.ReconnectParams) (*testing.Empty, error) Stop(context.Context, *testing.Empty) (*testing.ReconnectInfo, error) }
ReconnectServiceServer is the server API for ReconnectService service. All implementations should embed UnimplementedReconnectServiceServer for forward compatibility
type ReportQpsScenarioServiceClient ¶
type ReportQpsScenarioServiceClient interface { // Report results of a QPS test benchmark scenario. ReportScenario(ctx context.Context, in *testing.ScenarioResult, opts ...grpc.CallOption) (*testing.Void, error) }
ReportQpsScenarioServiceClient is the client API for ReportQpsScenarioService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewReportQpsScenarioServiceClient ¶
func NewReportQpsScenarioServiceClient(cc grpc.ClientConnInterface) ReportQpsScenarioServiceClient
type ReportQpsScenarioServiceServer ¶
type ReportQpsScenarioServiceServer interface { // Report results of a QPS test benchmark scenario. ReportScenario(context.Context, *testing.ScenarioResult) (*testing.Void, error) }
ReportQpsScenarioServiceServer is the server API for ReportQpsScenarioService service. All implementations should embed UnimplementedReportQpsScenarioServiceServer for forward compatibility
type TestServiceClient ¶
type TestServiceClient interface { // One empty request followed by one empty response. EmptyCall(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) // One request followed by one response. UnaryCall(ctx context.Context, in *testing.SimpleRequest, opts ...grpc.CallOption) (*testing.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 *testing.SimpleRequest, opts ...grpc.CallOption) (*testing.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 *testing.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 *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) }
TestServiceClient is the client API for TestService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { // One empty request followed by one empty response. EmptyCall(context.Context, *testing.Empty) (*testing.Empty, error) // One request followed by one response. UnaryCall(context.Context, *testing.SimpleRequest) (*testing.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, *testing.SimpleRequest) (*testing.SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(*testing.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, *testing.Empty) (*testing.Empty, error) }
TestServiceServer is the server API for TestService service. All implementations should embed UnimplementedTestServiceServer for forward compatibility
type TestService_FullDuplexCallClient ¶
type TestService_FullDuplexCallClient interface { Send(*testing.StreamingOutputCallRequest) error Recv() (*testing.StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_FullDuplexCallServer ¶
type TestService_FullDuplexCallServer interface { Send(*testing.StreamingOutputCallResponse) error Recv() (*testing.StreamingOutputCallRequest, error) grpc.ServerStream }
type TestService_HalfDuplexCallClient ¶
type TestService_HalfDuplexCallClient interface { Send(*testing.StreamingOutputCallRequest) error Recv() (*testing.StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_HalfDuplexCallServer ¶
type TestService_HalfDuplexCallServer interface { Send(*testing.StreamingOutputCallResponse) error Recv() (*testing.StreamingOutputCallRequest, error) grpc.ServerStream }
type TestService_StreamingInputCallClient ¶
type TestService_StreamingInputCallClient interface { Send(*testing.StreamingInputCallRequest) error CloseAndRecv() (*testing.StreamingInputCallResponse, error) grpc.ClientStream }
type TestService_StreamingInputCallServer ¶
type TestService_StreamingInputCallServer interface { SendAndClose(*testing.StreamingInputCallResponse) error Recv() (*testing.StreamingInputCallRequest, error) grpc.ServerStream }
type TestService_StreamingOutputCallClient ¶
type TestService_StreamingOutputCallClient interface { Recv() (*testing.StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_StreamingOutputCallServer ¶
type TestService_StreamingOutputCallServer interface { Send(*testing.StreamingOutputCallResponse) error grpc.ServerStream }
type UnimplementedBenchmarkServiceServer ¶
type UnimplementedBenchmarkServiceServer struct { }
UnimplementedBenchmarkServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedBenchmarkServiceServer) StreamingBothWays ¶
func (UnimplementedBenchmarkServiceServer) StreamingBothWays(BenchmarkService_StreamingBothWaysServer) error
func (UnimplementedBenchmarkServiceServer) StreamingCall ¶
func (UnimplementedBenchmarkServiceServer) StreamingCall(BenchmarkService_StreamingCallServer) error
func (UnimplementedBenchmarkServiceServer) StreamingFromClient ¶
func (UnimplementedBenchmarkServiceServer) StreamingFromClient(BenchmarkService_StreamingFromClientServer) error
func (UnimplementedBenchmarkServiceServer) StreamingFromServer ¶
func (UnimplementedBenchmarkServiceServer) StreamingFromServer(*testing.SimpleRequest, BenchmarkService_StreamingFromServerServer) error
func (UnimplementedBenchmarkServiceServer) UnaryCall ¶
func (UnimplementedBenchmarkServiceServer) UnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
type UnimplementedHookServiceServer ¶
type UnimplementedHookServiceServer struct { }
UnimplementedHookServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedHookServiceServer) ClearReturnStatus ¶
func (UnimplementedHookServiceServer) Hook ¶
func (UnimplementedHookServiceServer) SetReturnStatus ¶
func (UnimplementedHookServiceServer) SetReturnStatus(context.Context, *testing.SetReturnStatusRequest) (*testing.Empty, error)
type UnimplementedLoadBalancerStatsServiceServer ¶
type UnimplementedLoadBalancerStatsServiceServer struct { }
UnimplementedLoadBalancerStatsServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats ¶
func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats(context.Context, *testing.LoadBalancerAccumulatedStatsRequest) (*testing.LoadBalancerAccumulatedStatsResponse, error)
func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats ¶
func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats(context.Context, *testing.LoadBalancerStatsRequest) (*testing.LoadBalancerStatsResponse, error)
type UnimplementedReconnectServiceServer ¶
type UnimplementedReconnectServiceServer struct { }
UnimplementedReconnectServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedReconnectServiceServer) Start ¶
func (UnimplementedReconnectServiceServer) Start(context.Context, *testing.ReconnectParams) (*testing.Empty, error)
func (UnimplementedReconnectServiceServer) Stop ¶
func (UnimplementedReconnectServiceServer) Stop(context.Context, *testing.Empty) (*testing.ReconnectInfo, error)
type UnimplementedReportQpsScenarioServiceServer ¶
type UnimplementedReportQpsScenarioServiceServer struct { }
UnimplementedReportQpsScenarioServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedReportQpsScenarioServiceServer) ReportScenario ¶
func (UnimplementedReportQpsScenarioServiceServer) ReportScenario(context.Context, *testing.ScenarioResult) (*testing.Void, error)
type UnimplementedServiceClient ¶
type UnimplementedServiceClient interface { // A call that no server should implement UnimplementedCall(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) }
UnimplementedServiceClient is the client API for UnimplementedService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewUnimplementedServiceClient ¶
func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient
type UnimplementedServiceServer ¶
type UnimplementedServiceServer interface { // A call that no server should implement UnimplementedCall(context.Context, *testing.Empty) (*testing.Empty, error) }
UnimplementedServiceServer is the server API for UnimplementedService service. All implementations should embed UnimplementedUnimplementedServiceServer for forward compatibility
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct { }
UnimplementedTestServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedTestServiceServer) CacheableUnaryCall ¶
func (UnimplementedTestServiceServer) CacheableUnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
func (UnimplementedTestServiceServer) EmptyCall ¶
func (UnimplementedTestServiceServer) FullDuplexCall ¶
func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error
func (UnimplementedTestServiceServer) HalfDuplexCall ¶
func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error
func (UnimplementedTestServiceServer) StreamingInputCall ¶
func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error
func (UnimplementedTestServiceServer) StreamingOutputCall ¶
func (UnimplementedTestServiceServer) StreamingOutputCall(*testing.StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
func (UnimplementedTestServiceServer) UnaryCall ¶
func (UnimplementedTestServiceServer) UnaryCall(context.Context, *testing.SimpleRequest) (*testing.SimpleResponse, error)
type UnimplementedUnimplementedServiceServer ¶
type UnimplementedUnimplementedServiceServer struct { }
UnimplementedUnimplementedServiceServer should be embedded to have forward compatible implementations.
type UnimplementedWorkerServiceServer ¶
type UnimplementedWorkerServiceServer struct { }
UnimplementedWorkerServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedWorkerServiceServer) CoreCount ¶
func (UnimplementedWorkerServiceServer) CoreCount(context.Context, *testing.CoreRequest) (*testing.CoreResponse, error)
func (UnimplementedWorkerServiceServer) QuitWorker ¶
func (UnimplementedWorkerServiceServer) RunClient ¶
func (UnimplementedWorkerServiceServer) RunClient(WorkerService_RunClientServer) error
func (UnimplementedWorkerServiceServer) RunServer ¶
func (UnimplementedWorkerServiceServer) RunServer(WorkerService_RunServerServer) error
type UnimplementedXdsUpdateClientConfigureServiceServer ¶
type UnimplementedXdsUpdateClientConfigureServiceServer struct { }
UnimplementedXdsUpdateClientConfigureServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure ¶
type UnimplementedXdsUpdateHealthServiceServer ¶
type UnimplementedXdsUpdateHealthServiceServer struct { }
UnimplementedXdsUpdateHealthServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest ¶
func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest(context.Context, *testing.HookRequest) (*testing.HookResponse, error)
func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing ¶
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 UnsafeHookServiceServer ¶
type UnsafeHookServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHookServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HookServiceServer 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 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 *testing.CoreRequest, opts ...grpc.CallOption) (*testing.CoreResponse, error) // Quit this worker QuitWorker(ctx context.Context, in *testing.Void, opts ...grpc.CallOption) (*testing.Void, error) }
WorkerServiceClient is the client API for WorkerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWorkerServiceClient ¶
func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
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, *testing.CoreRequest) (*testing.CoreResponse, error) // Quit this worker QuitWorker(context.Context, *testing.Void) (*testing.Void, error) }
WorkerServiceServer is the server API for WorkerService service. All implementations should embed UnimplementedWorkerServiceServer for forward compatibility
type WorkerService_RunClientClient ¶
type WorkerService_RunClientClient interface { Send(*testing.ClientArgs) error Recv() (*testing.ClientStatus, error) grpc.ClientStream }
type WorkerService_RunClientServer ¶
type WorkerService_RunClientServer interface { Send(*testing.ClientStatus) error Recv() (*testing.ClientArgs, error) grpc.ServerStream }
type WorkerService_RunServerClient ¶
type WorkerService_RunServerClient interface { Send(*testing.ServerArgs) error Recv() (*testing.ServerStatus, error) grpc.ClientStream }
type WorkerService_RunServerServer ¶
type WorkerService_RunServerServer interface { Send(*testing.ServerStatus) error Recv() (*testing.ServerArgs, error) grpc.ServerStream }
type XdsUpdateClientConfigureServiceClient ¶
type XdsUpdateClientConfigureServiceClient interface { // Update the tes client's configuration. Configure(ctx context.Context, in *testing.ClientConfigureRequest, opts ...grpc.CallOption) (*testing.ClientConfigureResponse, error) }
XdsUpdateClientConfigureServiceClient is the client API for XdsUpdateClientConfigureService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewXdsUpdateClientConfigureServiceClient ¶
func NewXdsUpdateClientConfigureServiceClient(cc grpc.ClientConnInterface) XdsUpdateClientConfigureServiceClient
type XdsUpdateClientConfigureServiceServer ¶
type XdsUpdateClientConfigureServiceServer interface { // Update the tes client's configuration. Configure(context.Context, *testing.ClientConfigureRequest) (*testing.ClientConfigureResponse, error) }
XdsUpdateClientConfigureServiceServer is the server API for XdsUpdateClientConfigureService service. All implementations should embed UnimplementedXdsUpdateClientConfigureServiceServer for forward compatibility
type XdsUpdateHealthServiceClient ¶
type XdsUpdateHealthServiceClient interface { SetServing(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) SetNotServing(ctx context.Context, in *testing.Empty, opts ...grpc.CallOption) (*testing.Empty, error) SendHookRequest(ctx context.Context, in *testing.HookRequest, opts ...grpc.CallOption) (*testing.HookResponse, error) }
XdsUpdateHealthServiceClient is the client API for XdsUpdateHealthService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewXdsUpdateHealthServiceClient ¶
func NewXdsUpdateHealthServiceClient(cc grpc.ClientConnInterface) XdsUpdateHealthServiceClient
type XdsUpdateHealthServiceServer ¶
type XdsUpdateHealthServiceServer interface { SetServing(context.Context, *testing.Empty) (*testing.Empty, error) SetNotServing(context.Context, *testing.Empty) (*testing.Empty, error) SendHookRequest(context.Context, *testing.HookRequest) (*testing.HookResponse, error) }
XdsUpdateHealthServiceServer is the server API for XdsUpdateHealthService service. All implementations should embed UnimplementedXdsUpdateHealthServiceServer for forward compatibility