grpc_testing

package
v1.33.3 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2021 License: Apache-2.0 Imports: 9 Imported by: 1,158

Documentation

Index

Constants

This section is empty.

Variables

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

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

Enum value maps for GrpclbRouteType.

View Source 
var File_interop_grpc_testing_test_proto protoreflect.FileDescriptor

Functions

func RegisterLoadBalancerStatsServiceServer added in v1.28.0 

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

func RegisterTestServiceServer 

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

func RegisterUnimplementedServiceServer added in v1.0.5 

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

Types

type EchoStatus added in v1.0.3 

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 deprecated added in v1.0.3 

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

Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.

func (*EchoStatus) GetCode added in v1.0.3 

func (x *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage added in v1.0.3 

func (x *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage added in v1.0.3 

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) ProtoReflect added in v1.33.2 

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

func (*EchoStatus) Reset added in v1.0.3 

func (x *EchoStatus) Reset()

func (*EchoStatus) String added in v1.0.3 

func (x *EchoStatus) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v1.33.2 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type GrpclbRouteType added in v1.26.0 

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 added in v1.33.2 

func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor

func (GrpclbRouteType) Enum added in v1.33.2 

func (x GrpclbRouteType) Enum() *GrpclbRouteType

func (GrpclbRouteType) EnumDescriptor deprecated added in v1.26.0 

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

Deprecated: Use GrpclbRouteType.Descriptor instead.

func (GrpclbRouteType) Number added in v1.33.2 

func (x GrpclbRouteType) Number() protoreflect.EnumNumber

func (GrpclbRouteType) String added in v1.26.0 

func (x GrpclbRouteType) String() string

func (GrpclbRouteType) Type added in v1.33.2 

func (GrpclbRouteType) Type() protoreflect.EnumType

type LoadBalancerStatsRequest added in v1.28.0 

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 deprecated added in v1.28.0 

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

Deprecated: Use LoadBalancerStatsRequest.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsRequest) GetNumRpcs added in v1.28.0 

func (x *LoadBalancerStatsRequest) GetNumRpcs() int32

func (*LoadBalancerStatsRequest) GetTimeoutSec added in v1.28.0 

func (x *LoadBalancerStatsRequest) GetTimeoutSec() int32

func (*LoadBalancerStatsRequest) ProtoMessage added in v1.28.0 

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest) ProtoReflect added in v1.33.2 

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

func (*LoadBalancerStatsRequest) Reset added in v1.28.0 

func (x *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest) String added in v1.28.0 

func (x *LoadBalancerStatsRequest) String() string

type LoadBalancerStatsResponse added in v1.28.0 

type LoadBalancerStatsResponse struct {

	// The number of completed RPCs for each peer.
	RpcsByPeer map[string]int32 `` /* 182-byte string literal not displayed */
	// The number of RPCs that failed to record a remote peer.
	NumFailures int32 `protobuf:"varint,2,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
	// The number of completed RPCs for each method (UnaryCall or EmptyCall).
	RpcsByMethod map[string]*LoadBalancerStatsResponse_RpcsByPeer `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoadBalancerStatsResponse) Descriptor deprecated added in v1.28.0 

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

Deprecated: Use LoadBalancerStatsResponse.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse) GetNumFailures added in v1.28.0 

func (x *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod added in v1.31.0 

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

func (*LoadBalancerStatsResponse) GetRpcsByPeer added in v1.28.0 

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

func (*LoadBalancerStatsResponse) ProtoMessage added in v1.28.0 

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) ProtoReflect added in v1.33.2 

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

func (*LoadBalancerStatsResponse) Reset added in v1.28.0 

func (x *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) String added in v1.28.0 

func (x *LoadBalancerStatsResponse) String() string

type LoadBalancerStatsResponse_RpcsByPeer added in v1.31.0 

type LoadBalancerStatsResponse_RpcsByPeer struct {

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

func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor deprecated added in v1.31.0 

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

Deprecated: Use LoadBalancerStatsResponse_RpcsByPeer.ProtoReflect.Descriptor instead.

func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer added in v1.31.0 

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

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage added in v1.31.0 

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoReflect added in v1.33.2 

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

func (*LoadBalancerStatsResponse_RpcsByPeer) Reset added in v1.31.0 

func (x *LoadBalancerStatsResponse_RpcsByPeer) Reset()

func (*LoadBalancerStatsResponse_RpcsByPeer) String added in v1.31.0 

func (x *LoadBalancerStatsResponse_RpcsByPeer) String() string

type LoadBalancerStatsServiceClient added in v1.28.0 

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.

func NewLoadBalancerStatsServiceClient added in v1.28.0 

func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient

type LoadBalancerStatsServiceServer added in v1.28.0 

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 deprecated 

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 added in v1.33.2 

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 added in v1.33.2 

func (PayloadType) Descriptor() protoreflect.EnumDescriptor

func (PayloadType) Enum 

func (x PayloadType) Enum() *PayloadType

func (PayloadType) EnumDescriptor deprecated 

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

Deprecated: Use PayloadType.Descriptor instead.

func (PayloadType) Number added in v1.33.2 

func (x PayloadType) Number() protoreflect.EnumNumber

func (PayloadType) String 

func (x PayloadType) String() string

func (PayloadType) Type added in v1.33.2 

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 deprecated 

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 added in v1.33.2 

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 {

	// Desired payload type in the response from the server.
	// If response_type is RANDOM, server randomly chooses one from other formats.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Desired payload size in the response from the server.
	// If response_type is COMPRESSABLE, this denotes the size before compression.
	ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Whether SimpleResponse should include username.
	FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
	// Whether SimpleResponse should include OAuth scope.
	FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
	// Whether server should return a given status
	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	// Whether SimpleResponse should include server_id.
	FillServerId bool `protobuf:"varint,9,opt,name=fill_server_id,json=fillServerId,proto3" json:"fill_server_id,omitempty"`
	// Whether SimpleResponse should include grpclb_route_type.
	FillGrpclbRouteType bool `protobuf:"varint,10,opt,name=fill_grpclb_route_type,json=fillGrpclbRouteType,proto3" json:"fill_grpclb_route_type,omitempty"`
	// contains filtered or unexported fields
}

Unary request.

func (*SimpleRequest) Descriptor deprecated 

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

func (*SimpleRequest) GetFillGrpclbRouteType added in v1.26.0 

func (x *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope 

func (x *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId added in v1.21.0 

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 added in v1.0.3 

func (x *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType 

func (x *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage 

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect added in v1.33.2 

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

func (*SimpleRequest) Reset 

func (x *SimpleRequest) Reset()

func (*SimpleRequest) String 

func (x *SimpleRequest) String() string

type SimpleResponse 

type SimpleResponse struct {

	// Payload to increase message size.
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The user the request came from, for verifying authentication was
	// successful when the client expected it.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// OAuth scope.
	OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
	// Server ID. This must be unique among different server instances,
	// but the same across all RPC's made to a particular server instance.
	ServerId string `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// gRPCLB Path.
	GrpclbRouteType GrpclbRouteType `` /* 143-byte string literal not displayed */
	// Server hostname.
	Hostname string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor deprecated 

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse) GetGrpclbRouteType added in v1.26.0 

func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetHostname added in v1.28.0 

func (x *SimpleResponse) GetHostname() string

func (*SimpleResponse) GetOauthScope 

func (x *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload 

func (x *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId added in v1.21.0 

func (x *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername 

func (x *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage 

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect added in v1.33.2 

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 deprecated 

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 added in v1.33.2 

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 {

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

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor deprecated 

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 added in v1.33.2 

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 {

	// Desired payload type in the response from the server.
	// If response_type is RANDOM, the payload from each response in the stream
	// might be of different types. This is to simulate a mixed type of payload
	// stream.
	ResponseType PayloadType `` /* 128-byte string literal not displayed */
	// Configuration for each expected response message.
	ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
	// Optional input payload sent along with the request.
	Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Whether server should return a given status
	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	// contains filtered or unexported fields
}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor deprecated 

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 added in v1.0.3 

func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType 

func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage 

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) ProtoReflect added in v1.33.2 

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 deprecated 

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 added in v1.33.2 

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.

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, 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 added in v1.28.0 

type UnimplementedLoadBalancerStatsServiceServer struct {
}

UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats added in v1.28.0 

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

type UnimplementedServiceClient added in v1.0.5 

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.

func NewUnimplementedServiceClient added in v1.0.5 

func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient

type UnimplementedServiceServer added in v1.0.5 

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 added in v1.24.0 

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) EmptyCall added in v1.24.0 

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

func (UnimplementedTestServiceServer) FullDuplexCall added in v1.24.0 

func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error

func (UnimplementedTestServiceServer) HalfDuplexCall added in v1.24.0 

func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error

func (UnimplementedTestServiceServer) StreamingInputCall added in v1.24.0 

func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error

func (UnimplementedTestServiceServer) StreamingOutputCall added in v1.24.0 

func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error

func (UnimplementedTestServiceServer) UnaryCall added in v1.24.0 

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

type UnimplementedUnimplementedServiceServer added in v1.24.0 

type UnimplementedUnimplementedServiceServer struct {
}

UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUnimplementedServiceServer) UnimplementedCall added in v1.24.0 

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

type UnsafeLoadBalancerStatsServiceServer added in v1.33.0 

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 added in v1.33.0 

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 added in v1.33.0 

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.

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.