testinggrpc

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

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
}

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

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

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

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

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

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

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

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

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

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

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

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

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

type ReconnectServiceServer interface {
	Start(context.Context, *testing.ReconnectParams) (*testing.Empty, error)
	Stop(context.Context, *testing.Empty) (*testing.ReconnectInfo, error)
}

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

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

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

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

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

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

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

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

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

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

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

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

type UnimplementedBenchmarkServiceServer struct {
}

type UnimplementedHookServiceServer struct {
}

type UnimplementedLoadBalancerStatsServiceServer struct {
}

type UnimplementedReconnectServiceServer struct {
}

type UnimplementedReportQpsScenarioServiceServer struct {
}

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

type UnimplementedServiceServer interface {
	// A call that no server should implement
	UnimplementedCall(context.Context, *testing.Empty) (*testing.Empty, error)
}

type UnimplementedTestServiceServer struct {
}

type UnimplementedUnimplementedServiceServer struct {
}

type UnimplementedWorkerServiceServer struct {
}

type UnimplementedXdsUpdateClientConfigureServiceServer struct {
}

type UnimplementedXdsUpdateHealthServiceServer struct {
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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