test

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 4, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	ReconnectService_Start_FullMethodName = "/grpc.testing.ReconnectService/Start"
	ReconnectService_Stop_FullMethodName  = "/grpc.testing.ReconnectService/Stop"
)
View Source 
const (
	LoadBalancerStatsService_GetClientStats_FullMethodName            = "/grpc.testing.LoadBalancerStatsService/GetClientStats"
	LoadBalancerStatsService_GetClientAccumulatedStats_FullMethodName = "/grpc.testing.LoadBalancerStatsService/GetClientAccumulatedStats"
)
View Source 
const (
	HookService_Hook_FullMethodName              = "/grpc.testing.HookService/Hook"
	HookService_SetReturnStatus_FullMethodName   = "/grpc.testing.HookService/SetReturnStatus"
	HookService_ClearReturnStatus_FullMethodName = "/grpc.testing.HookService/ClearReturnStatus"
)
View Source 
const (
	XdsUpdateHealthService_SetServing_FullMethodName      = "/grpc.testing.XdsUpdateHealthService/SetServing"
	XdsUpdateHealthService_SetNotServing_FullMethodName   = "/grpc.testing.XdsUpdateHealthService/SetNotServing"
	XdsUpdateHealthService_SendHookRequest_FullMethodName = "/grpc.testing.XdsUpdateHealthService/SendHookRequest"
)
View Source 
const (
	UnimplementedService_UnimplementedCall_FullMethodName = "/grpc.testing.UnimplementedService/UnimplementedCall"
)
View Source 
const (
	XdsUpdateClientConfigureService_Configure_FullMethodName = "/grpc.testing.XdsUpdateClientConfigureService/Configure"
)

Variables

View Source 
var File_grpc_testing_test_proto protoreflect.FileDescriptor
View Source 
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)

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 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 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,
		},
		{
			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 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 RegisterTestServiceServer 

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

func RegisterUnimplementedServiceServer 

func RegisterUnimplementedServiceServer(s grpc.ServiceRegistrar, srv UnimplementedServiceServer)

func RegisterXdsUpdateClientConfigureServiceServer 

func RegisterXdsUpdateClientConfigureServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateClientConfigureServiceServer)

func RegisterXdsUpdateHealthServiceServer 

func RegisterXdsUpdateHealthServiceServer(s grpc.ServiceRegistrar, srv XdsUpdateHealthServiceServer)

Types

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 *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// Sets a return status for pending and upcoming calls to Hook
	SetReturnStatus(ctx context.Context, in *messages.SetReturnStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Clears the return status. Incoming calls to Hook will "hang"
	ClearReturnStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.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.

Hook service. Used to keep Kubernetes from shutting the pod down.

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, *empty.Empty) (*empty.Empty, error)
	// Sets a return status for pending and upcoming calls to Hook
	SetReturnStatus(context.Context, *messages.SetReturnStatusRequest) (*empty.Empty, error)
	// Clears the return status. Incoming calls to Hook will "hang"
	ClearReturnStatus(context.Context, *empty.Empty) (*empty.Empty, error)
	// contains filtered or unexported methods
}

HookServiceServer is the server API for HookService service. All implementations must embed UnimplementedHookServiceServer for forward compatibility.

Hook service. Used to keep Kubernetes from shutting the pod down.

type LoadBalancerStatsServiceClient 

type LoadBalancerStatsServiceClient interface {
	// Gets the backend distribution for RPCs sent by a test client.
	GetClientStats(ctx context.Context, in *messages.LoadBalancerStatsRequest, opts ...grpc.CallOption) (*messages.LoadBalancerStatsResponse, error)
	// Gets the accumulated stats for RPCs sent by a test client.
	GetClientAccumulatedStats(ctx context.Context, in *messages.LoadBalancerAccumulatedStatsRequest, opts ...grpc.CallOption) (*messages.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.

A service used to obtain stats for verifying LB behavior.

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, *messages.LoadBalancerStatsRequest) (*messages.LoadBalancerStatsResponse, error)
	// Gets the accumulated stats for RPCs sent by a test client.
	GetClientAccumulatedStats(context.Context, *messages.LoadBalancerAccumulatedStatsRequest) (*messages.LoadBalancerAccumulatedStatsResponse, error)
	// contains filtered or unexported methods
}

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

A service used to obtain stats for verifying LB behavior.

type ReconnectServiceClient 

type ReconnectServiceClient interface {
	Start(ctx context.Context, in *messages.ReconnectParams, opts ...grpc.CallOption) (*empty.Empty, error)
	Stop(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*messages.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.

A service used to control reconnect server.

func NewReconnectServiceClient 

func NewReconnectServiceClient(cc grpc.ClientConnInterface) ReconnectServiceClient

type ReconnectServiceServer 

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

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

A service used to control reconnect server.

type TestServiceClient 

type TestServiceClient interface {
	// One empty request followed by one empty response.
	EmptyCall(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// One request followed by one response.
	UnaryCall(ctx context.Context, in *messages.SimpleRequest, opts ...grpc.CallOption) (*messages.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 *messages.SimpleRequest, opts ...grpc.CallOption) (*messages.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 *messages.StreamingOutputCallRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[messages.StreamingOutputCallResponse], 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) (grpc.ClientStreamingClient[messages.StreamingInputCallRequest, messages.StreamingInputCallResponse], 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) (grpc.BidiStreamingClient[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse], 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) (grpc.BidiStreamingClient[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse], 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.Empty, opts ...grpc.CallOption) (*empty.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.

A simple service to test the various types of RPCs and experiment with performance with various types of payload.

func NewTestServiceClient 

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer 

type TestServiceServer interface {
	// One empty request followed by one empty response.
	EmptyCall(context.Context, *empty.Empty) (*empty.Empty, error)
	// One request followed by one response.
	UnaryCall(context.Context, *messages.SimpleRequest) (*messages.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, *messages.SimpleRequest) (*messages.SimpleResponse, error)
	// One request followed by a sequence of responses (streamed download).
	// The server returns the payload with client desired type and sizes.
	StreamingOutputCall(*messages.StreamingOutputCallRequest, grpc.ServerStreamingServer[messages.StreamingOutputCallResponse]) error
	// A sequence of requests followed by one response (streamed upload).
	// The server returns the aggregated size of client payload as the result.
	StreamingInputCall(grpc.ClientStreamingServer[messages.StreamingInputCallRequest, messages.StreamingInputCallResponse]) 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(grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]) 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(grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]) 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) (*empty.Empty, error)
	// contains filtered or unexported methods
}

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

A simple service to test the various types of RPCs and experiment with performance with various types of payload.

type TestService_FullDuplexCallClient 

type TestService_FullDuplexCallClient = grpc.BidiStreamingClient[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_FullDuplexCallServer 

type TestService_FullDuplexCallServer = grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_HalfDuplexCallClient 

type TestService_HalfDuplexCallClient = grpc.BidiStreamingClient[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_HalfDuplexCallServer 

type TestService_HalfDuplexCallServer = grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_StreamingInputCallClient 

type TestService_StreamingInputCallClient = grpc.ClientStreamingClient[messages.StreamingInputCallRequest, messages.StreamingInputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_StreamingInputCallServer 

type TestService_StreamingInputCallServer = grpc.ClientStreamingServer[messages.StreamingInputCallRequest, messages.StreamingInputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_StreamingOutputCallClient 

type TestService_StreamingOutputCallClient = grpc.ServerStreamingClient[messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_StreamingOutputCallServer 

type TestService_StreamingOutputCallServer = grpc.ServerStreamingServer[messages.StreamingOutputCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedHookServiceServer 

type UnimplementedHookServiceServer struct{}

UnimplementedHookServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHookServiceServer) ClearReturnStatus 

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

func (UnimplementedHookServiceServer) Hook 

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

func (UnimplementedHookServiceServer) SetReturnStatus 

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

type UnimplementedLoadBalancerStatsServiceServer 

type UnimplementedLoadBalancerStatsServiceServer struct{}

UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLoadBalancerStatsServiceServer) GetClientAccumulatedStats 

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

func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats 

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

type UnimplementedReconnectServiceServer 

type UnimplementedReconnectServiceServer struct{}

UnimplementedReconnectServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedReconnectServiceServer) Start 

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

func (UnimplementedReconnectServiceServer) Stop 

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

type UnimplementedServiceClient 

type UnimplementedServiceClient interface {
	// A call that no server should implement
	UnimplementedCall(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.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.

A simple service NOT implemented at servers so clients can test for that case.

func NewUnimplementedServiceClient 

func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient

type UnimplementedServiceServer 

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

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

A simple service NOT implemented at servers so clients can test for that case.

type UnimplementedTestServiceServer 

type UnimplementedTestServiceServer struct{}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTestServiceServer) CacheableUnaryCall 

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

func (UnimplementedTestServiceServer) EmptyCall 

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

func (UnimplementedTestServiceServer) FullDuplexCall 

func (UnimplementedTestServiceServer) FullDuplexCall(grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]) error

func (UnimplementedTestServiceServer) HalfDuplexCall 

func (UnimplementedTestServiceServer) HalfDuplexCall(grpc.BidiStreamingServer[messages.StreamingOutputCallRequest, messages.StreamingOutputCallResponse]) error

func (UnimplementedTestServiceServer) StreamingInputCall 

func (UnimplementedTestServiceServer) StreamingInputCall(grpc.ClientStreamingServer[messages.StreamingInputCallRequest, messages.StreamingInputCallResponse]) error

func (UnimplementedTestServiceServer) StreamingOutputCall 

func (UnimplementedTestServiceServer) StreamingOutputCall(*messages.StreamingOutputCallRequest, grpc.ServerStreamingServer[messages.StreamingOutputCallResponse]) error

func (UnimplementedTestServiceServer) UnaryCall 

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

func (UnimplementedTestServiceServer) UnimplementedCall 

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

type UnimplementedUnimplementedServiceServer 

type UnimplementedUnimplementedServiceServer struct{}

UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedUnimplementedServiceServer) UnimplementedCall 

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

type UnimplementedXdsUpdateClientConfigureServiceServer 

type UnimplementedXdsUpdateClientConfigureServiceServer struct{}

UnimplementedXdsUpdateClientConfigureServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedXdsUpdateClientConfigureServiceServer) Configure 

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

type UnimplementedXdsUpdateHealthServiceServer 

type UnimplementedXdsUpdateHealthServiceServer struct{}

UnimplementedXdsUpdateHealthServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedXdsUpdateHealthServiceServer) SendHookRequest 

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

func (UnimplementedXdsUpdateHealthServiceServer) SetNotServing 

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

func (UnimplementedXdsUpdateHealthServiceServer) SetServing 

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

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

type XdsUpdateClientConfigureServiceClient interface {
	// Update the tes client's configuration.
	Configure(ctx context.Context, in *messages.ClientConfigureRequest, opts ...grpc.CallOption) (*messages.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.

A service to dynamically update the configuration of an xDS test client.

func NewXdsUpdateClientConfigureServiceClient 

func NewXdsUpdateClientConfigureServiceClient(cc grpc.ClientConnInterface) XdsUpdateClientConfigureServiceClient

type XdsUpdateClientConfigureServiceServer 

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

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

A service to dynamically update the configuration of an xDS test client.

type XdsUpdateHealthServiceClient 

type XdsUpdateHealthServiceClient interface {
	SetServing(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	SetNotServing(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	SendHookRequest(ctx context.Context, in *messages.HookRequest, opts ...grpc.CallOption) (*messages.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.

A service to remotely control health status of an xDS test server.

func NewXdsUpdateHealthServiceClient 

func NewXdsUpdateHealthServiceClient(cc grpc.ClientConnInterface) XdsUpdateHealthServiceClient

type XdsUpdateHealthServiceServer 

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

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

A service to remotely control health status of an xDS test server.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.