Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for PayloadType.


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

Enum value maps for GrpclbRouteType.


var File_interop_grpc_testing_test_proto protoreflect.FileDescriptor

Functions

func RegisterLoadBalancerStatsServiceServer

func RegisterLoadBalancerStatsServiceServer(s *grpc.Server, srv LoadBalancerStatsServiceServer)

func RegisterTestServiceServer

func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

func RegisterUnimplementedServiceServer

func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer)

Types

type EchoStatus

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

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

func (*EchoStatus) Descriptor

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

Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

func (*EchoStatus) GetCode

func (x *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage

func (x *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) ProtoReflect

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

func (*EchoStatus) Reset

func (x *EchoStatus) Reset()

func (*EchoStatus) String

func (x *EchoStatus) String() string

type Empty

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

func (*Empty) Descriptor

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type GrpclbRouteType

type GrpclbRouteType int32

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

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

func (GrpclbRouteType) Descriptor

func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor

func (GrpclbRouteType) Enum

func (x GrpclbRouteType) Enum() *GrpclbRouteType

func (GrpclbRouteType) EnumDescriptor

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

Deprecated: Use GrpclbRouteType.Descriptor instead.

func (GrpclbRouteType) Number

func (x GrpclbRouteType) Number() protoreflect.EnumNumber

func (GrpclbRouteType) String

func (x GrpclbRouteType) String() string

func (GrpclbRouteType) Type

func (GrpclbRouteType) Type() protoreflect.EnumType

type LoadBalancerStatsRequest

type LoadBalancerStatsRequest struct {

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

func (*LoadBalancerStatsRequest) Descriptor

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

Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsRequest) GetNumRpcs

func (x *LoadBalancerStatsRequest) GetNumRpcs() int32

func (*LoadBalancerStatsRequest) GetTimeoutSec

func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32

func (*LoadBalancerStatsRequest) ProtoMessage

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest) ProtoReflect

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

func (*LoadBalancerStatsRequest) Reset

func (x *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest) String

func (x *LoadBalancerStatsRequest) String() string

type LoadBalancerStatsResponse

type LoadBalancerStatsResponse struct {
	RpcsByPeer map[string]int32 "" /* 182 byte string literal not displayed */

	NumFailures int32 `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`

	RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer "" /* 187 byte string literal not displayed */

}

func (*LoadBalancerStatsResponse) Descriptor

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

Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse) GetNumFailures

func (x *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod

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

func (*LoadBalancerStatsResponse) GetRpcsByPeer

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

func (*LoadBalancerStatsResponse) ProtoMessage

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) ProtoReflect

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

func (*LoadBalancerStatsResponse) Reset

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) String

func (x *LoadBalancerStatsResponse) String() string

type LoadBalancerStatsResponse_RpcsByPeer

type LoadBalancerStatsResponse_RpcsByPeer struct {
	RpcsByPeer map[string]int32 "" /* 182 byte string literal not displayed */

}

func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor

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

Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer

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

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect

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

func (*LoadBalancerStatsResponse_RpcsByPeer) Reset

func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()

func (*LoadBalancerStatsResponse_RpcsByPeer) String

func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string

type LoadBalancerStatsServiceClient

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

LoadBalancerStatsServiceClient is the client API for LoadBalancerStatsService service.

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

type LoadBalancerStatsServiceServer

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

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

type Payload

type Payload struct {

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

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

func (*Payload) Descriptor

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetBody

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

func (*Payload) GetType

func (x *Payload) GetType() PayloadType

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect

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

func (*Payload) Reset

func (x *Payload) Reset()

func (*Payload) String

func (x *Payload) String() string

type PayloadType

type PayloadType int32

The type of payload that should be returned.

const (
	// Compressable text format.
	PayloadType_COMPRESSABLE PayloadType = 0
	// Uncompressable binary format.
	PayloadType_UNCOMPRESSABLE PayloadType = 1
	// Randomly chosen from all other formats defined in this enum.
	PayloadType_RANDOM PayloadType = 2
)

func (PayloadType) Descriptor

func (PayloadType) Descriptor() protoreflect.EnumDescriptor

func (PayloadType) Enum

func (x PayloadType) Enum() *PayloadType

func (PayloadType) EnumDescriptor

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

Deprecated: Use PayloadType.Descriptor instead.

func (PayloadType) Number

func (x PayloadType) Number() protoreflect.EnumNumber

func (PayloadType) String

func (x PayloadType) String() string

func (PayloadType) Type

func (PayloadType) Type() protoreflect.EnumType

type ResponseParameters

type ResponseParameters struct {

	// Desired payload sizes in responses from the server.
	// If response_type is COMPRESSABLE, this denotes the size before compression.
	Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Desired interval between consecutive responses in the response stream in
	// microseconds.
	IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
	// contains filtered or unexported fields
}

Configuration for a particular response.

func (*ResponseParameters) Descriptor

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

Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.

func (*ResponseParameters) GetIntervalUs

func (x *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize

func (x *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) ProtoReflect

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

func (*ResponseParameters) Reset

func (x *ResponseParameters) Reset()

func (*ResponseParameters) String

func (x *ResponseParameters) String() string

type SimpleRequest

type SimpleRequest struct {
	ResponseType PayloadType "" /* 128 byte string literal not displayed */

	ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`

	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`

	FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`

	FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`

	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`

	FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`

	FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"`

}

Unary request.

func (*SimpleRequest) Descriptor

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

func (*SimpleRequest) GetFillGrpclbRouteType

func (x *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope

func (x *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId

func (x *SimpleRequest) GetFillServerId() bool

func (*SimpleRequest) GetFillUsername

func (x *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload

func (x *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseSize

func (x *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus

func (x *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType

func (x *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect

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

func (*SimpleRequest) Reset

func (x *SimpleRequest) Reset()

func (*SimpleRequest) String

func (x *SimpleRequest) String() string

type SimpleResponse

type SimpleResponse struct {
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`

	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`

	OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`

	ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`

	GrpclbRouteType GrpclbRouteType "" /* 143 byte string literal not displayed */

	Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`

}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse) GetGrpclbRouteType

func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetHostname

func (x *SimpleResponse) GetHostname() string

func (*SimpleResponse) GetOauthScope

func (x *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload

func (x *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId

func (x *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername

func (x *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect

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

func (*SimpleResponse) Reset

func (x *SimpleResponse) Reset()

func (*SimpleResponse) String

func (x *SimpleResponse) String() string

type StreamingInputCallRequest

type StreamingInputCallRequest struct {

	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

Client-streaming request.

func (*StreamingInputCallRequest) Descriptor

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

Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingInputCallRequest) GetPayload

func (x *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) ProtoReflect

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

func (*StreamingInputCallRequest) Reset

func (x *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String

func (x *StreamingInputCallRequest) String() string

type StreamingInputCallResponse

type StreamingInputCallResponse struct {
	AggregatedPayloadSize int32 "" /* 127 byte string literal not displayed */

}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor

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

Deprecated: Use StreamingInputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingInputCallResponse) GetAggregatedPayloadSize

func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) ProtoReflect

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

func (*StreamingInputCallResponse) Reset

func (x *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String

func (x *StreamingInputCallResponse) String() string

type StreamingOutputCallRequest

type StreamingOutputCallRequest struct {
	ResponseType PayloadType "" /* 128 byte string literal not displayed */

	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`

	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`

	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`

}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor

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

Deprecated: Use StreamingOutputCallRequest.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallRequest) GetPayload

func (x *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseParameters

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

func (*StreamingOutputCallRequest) GetResponseStatus

func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType

func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) ProtoReflect

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

func (*StreamingOutputCallRequest) Reset

func (x *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String

func (x *StreamingOutputCallRequest) String() string

type StreamingOutputCallResponse

type StreamingOutputCallResponse struct {

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

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

func (*StreamingOutputCallResponse) Descriptor

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

Deprecated: Use StreamingOutputCallResponse.ProtoReflect.Descriptor instead.

func (*StreamingOutputCallResponse) GetPayload

func (x *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) ProtoReflect

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

func (*StreamingOutputCallResponse) Reset

func (x *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String

func (x *StreamingOutputCallResponse) String() string

type TestServiceClient

type TestServiceClient interface {
	// One empty request followed by one empty response.
	EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// One request followed by one response.
	// The server returns the client payload as-is.
	UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// One request followed by a sequence of responses (streamed download).
	// The server returns the payload with client desired type and sizes.
	StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error)
	// A sequence of requests followed by one response (streamed upload).
	// The server returns the aggregated size of client payload as the result.
	StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error)
	// A sequence of requests with each request served by the server immediately.
	// As one request could lead to multiple responses, this interface
	// demonstrates the idea of full duplexing.
	FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error)
	// A sequence of requests followed by a sequence of responses.
	// The server buffers all the client requests and then serves them in order. A
	// stream of responses are returned to the client when the server starts with
	// first request.
	HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error)
}

TestServiceClient is the client API for TestService service.

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

type TestServiceServer

type TestServiceServer interface {
	// One empty request followed by one empty response.
	EmptyCall(context.Context, *Empty) (*Empty, error)
	// One request followed by one response.
	// The server returns the client payload as-is.
	UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
	// One request followed by a sequence of responses (streamed download).
	// The server returns the payload with client desired type and sizes.
	StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
	// A sequence of requests followed by one response (streamed upload).
	// The server returns the aggregated size of client payload as the result.
	StreamingInputCall(TestService_StreamingInputCallServer) error
	// A sequence of requests with each request served by the server immediately.
	// As one request could lead to multiple responses, this interface
	// demonstrates the idea of full duplexing.
	FullDuplexCall(TestService_FullDuplexCallServer) error
	// A sequence of requests followed by a sequence of responses.
	// The server buffers all the client requests and then serves them in order. A
	// stream of responses are returned to the client when the server starts with
	// first request.
	HalfDuplexCall(TestService_HalfDuplexCallServer) error
	// contains filtered or unexported methods
}

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

type TestService_FullDuplexCallClient

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

type TestService_FullDuplexCallServer

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

type TestService_HalfDuplexCallClient

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

type TestService_HalfDuplexCallServer

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

type TestService_StreamingInputCallClient

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

type TestService_StreamingInputCallServer

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

type TestService_StreamingOutputCallClient

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

type TestService_StreamingOutputCallServer

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

type UnimplementedLoadBalancerStatsServiceServer

type UnimplementedLoadBalancerStatsServiceServer struct {
}

UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats

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

type UnimplementedServiceClient

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

UnimplementedServiceClient is the client API for UnimplementedService service.

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

type UnimplementedServiceServer

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

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

type UnimplementedTestServiceServer

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) EmptyCall

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

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

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

type UnimplementedUnimplementedServiceServer

type UnimplementedUnimplementedServiceServer struct {
}

UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUnimplementedServiceServer) UnimplementedCall

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

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