Documentation ¶
Index ¶
- Variables
- func RegisterLoadBalancerStatsServiceService(s grpc.ServiceRegistrar, srv *LoadBalancerStatsServiceService)
- func RegisterTestServiceService(s grpc.ServiceRegistrar, srv *TestServiceService)
- func RegisterUnimplementedServiceService(s grpc.ServiceRegistrar, srv *UnimplementedServiceService)
- type EchoStatus
- func (*EchoStatus) Descriptor() ([]byte, []int)
- func (m *EchoStatus) GetCode() int32
- func (m *EchoStatus) GetMessage() string
- func (*EchoStatus) ProtoMessage()
- func (m *EchoStatus) Reset()
- func (m *EchoStatus) String() string
- func (m *EchoStatus) XXX_DiscardUnknown()
- func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoStatus) XXX_Merge(src proto.Message)
- func (m *EchoStatus) XXX_Size() int
- func (m *EchoStatus) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type GrpclbRouteType
- type LoadBalancerStatsRequest
- func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)
- func (m *LoadBalancerStatsRequest) GetNumRpcs() int32
- func (m *LoadBalancerStatsRequest) GetTimeoutSec() int32
- func (*LoadBalancerStatsRequest) ProtoMessage()
- func (m *LoadBalancerStatsRequest) Reset()
- func (m *LoadBalancerStatsRequest) String() string
- func (m *LoadBalancerStatsRequest) XXX_DiscardUnknown()
- func (m *LoadBalancerStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadBalancerStatsRequest) XXX_Merge(src proto.Message)
- func (m *LoadBalancerStatsRequest) XXX_Size() int
- func (m *LoadBalancerStatsRequest) XXX_Unmarshal(b []byte) error
- type LoadBalancerStatsResponse
- func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)
- func (m *LoadBalancerStatsResponse) GetNumFailures() int32
- func (m *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
- func (m *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse) ProtoMessage()
- func (m *LoadBalancerStatsResponse) Reset()
- func (m *LoadBalancerStatsResponse) String() string
- func (m *LoadBalancerStatsResponse) XXX_DiscardUnknown()
- func (m *LoadBalancerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadBalancerStatsResponse) XXX_Merge(src proto.Message)
- func (m *LoadBalancerStatsResponse) XXX_Size() int
- func (m *LoadBalancerStatsResponse) XXX_Unmarshal(b []byte) error
- type LoadBalancerStatsResponse_RpcsByPeer
- func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)
- func (m *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
- func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
- func (m *LoadBalancerStatsResponse_RpcsByPeer) Reset()
- func (m *LoadBalancerStatsResponse_RpcsByPeer) String() string
- func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown()
- func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge(src proto.Message)
- func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Size() int
- func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal(b []byte) error
- type LoadBalancerStatsServiceClient
- type LoadBalancerStatsServiceService
- type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (m *Payload) GetBody() []byte
- func (m *Payload) GetType() PayloadType
- func (*Payload) ProtoMessage()
- func (m *Payload) Reset()
- func (m *Payload) String() string
- func (m *Payload) XXX_DiscardUnknown()
- func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payload) XXX_Merge(src proto.Message)
- func (m *Payload) XXX_Size() int
- func (m *Payload) XXX_Unmarshal(b []byte) error
- type PayloadType
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)
- func (m *ResponseParameters) GetIntervalUs() int32
- func (m *ResponseParameters) GetSize() int32
- func (*ResponseParameters) ProtoMessage()
- func (m *ResponseParameters) Reset()
- func (m *ResponseParameters) String() string
- func (m *ResponseParameters) XXX_DiscardUnknown()
- func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseParameters) XXX_Merge(src proto.Message)
- func (m *ResponseParameters) XXX_Size() int
- func (m *ResponseParameters) XXX_Unmarshal(b []byte) error
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)
- func (m *SimpleRequest) GetFillGrpclbRouteType() bool
- func (m *SimpleRequest) GetFillOauthScope() bool
- func (m *SimpleRequest) GetFillServerId() bool
- func (m *SimpleRequest) GetFillUsername() bool
- func (m *SimpleRequest) GetPayload() *Payload
- func (m *SimpleRequest) GetResponseSize() int32
- func (m *SimpleRequest) GetResponseStatus() *EchoStatus
- func (m *SimpleRequest) GetResponseType() PayloadType
- func (*SimpleRequest) ProtoMessage()
- func (m *SimpleRequest) Reset()
- func (m *SimpleRequest) String() string
- func (m *SimpleRequest) XXX_DiscardUnknown()
- func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleRequest) XXX_Merge(src proto.Message)
- func (m *SimpleRequest) XXX_Size() int
- func (m *SimpleRequest) XXX_Unmarshal(b []byte) error
- type SimpleResponse
- func (*SimpleResponse) Descriptor() ([]byte, []int)
- func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
- func (m *SimpleResponse) GetHostname() string
- func (m *SimpleResponse) GetOauthScope() string
- func (m *SimpleResponse) GetPayload() *Payload
- func (m *SimpleResponse) GetServerId() string
- func (m *SimpleResponse) GetUsername() string
- func (*SimpleResponse) ProtoMessage()
- func (m *SimpleResponse) Reset()
- func (m *SimpleResponse) String() string
- func (m *SimpleResponse) XXX_DiscardUnknown()
- func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleResponse) XXX_Merge(src proto.Message)
- func (m *SimpleResponse) XXX_Size() int
- func (m *SimpleResponse) XXX_Unmarshal(b []byte) error
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
- func (m *StreamingInputCallRequest) GetPayload() *Payload
- func (*StreamingInputCallRequest) ProtoMessage()
- func (m *StreamingInputCallRequest) Reset()
- func (m *StreamingInputCallRequest) String() string
- func (m *StreamingInputCallRequest) XXX_DiscardUnknown()
- func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)
- func (m *StreamingInputCallRequest) XXX_Size() int
- func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error
- type StreamingInputCallResponse
- func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
- func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
- func (*StreamingInputCallResponse) ProtoMessage()
- func (m *StreamingInputCallResponse) Reset()
- func (m *StreamingInputCallResponse) String() string
- func (m *StreamingInputCallResponse) XXX_DiscardUnknown()
- func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)
- func (m *StreamingInputCallResponse) XXX_Size() int
- func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error
- type StreamingOutputCallRequest
- func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
- func (m *StreamingOutputCallRequest) GetPayload() *Payload
- func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (m *StreamingOutputCallRequest) GetResponseType() PayloadType
- func (*StreamingOutputCallRequest) ProtoMessage()
- func (m *StreamingOutputCallRequest) Reset()
- func (m *StreamingOutputCallRequest) String() string
- func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()
- func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)
- func (m *StreamingOutputCallRequest) XXX_Size() int
- func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error
- type StreamingOutputCallResponse
- func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
- func (m *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (m *StreamingOutputCallResponse) Reset()
- func (m *StreamingOutputCallResponse) String() string
- func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()
- func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)
- func (m *StreamingOutputCallResponse) XXX_Size() int
- func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error
- type TestServiceClient
- type TestServiceService
- type TestService_FullDuplexCallClient
- type TestService_FullDuplexCallServer
- type TestService_HalfDuplexCallClient
- type TestService_HalfDuplexCallServer
- type TestService_StreamingInputCallClient
- type TestService_StreamingInputCallServer
- type TestService_StreamingOutputCallClient
- type TestService_StreamingOutputCallServer
- type UnimplementedServiceClient
- type UnimplementedServiceService
- type UnstableLoadBalancerStatsServiceService
- type UnstableTestServiceService
- type UnstableUnimplementedServiceService
Constants ¶
This section is empty.
Variables ¶
var GrpclbRouteType_name = map[int32]string{
0: "GRPCLB_ROUTE_TYPE_UNKNOWN",
1: "GRPCLB_ROUTE_TYPE_FALLBACK",
2: "GRPCLB_ROUTE_TYPE_BACKEND",
}
var GrpclbRouteType_value = map[string]int32{
"GRPCLB_ROUTE_TYPE_UNKNOWN": 0,
"GRPCLB_ROUTE_TYPE_FALLBACK": 1,
"GRPCLB_ROUTE_TYPE_BACKEND": 2,
}
var PayloadType_name = map[int32]string{
0: "COMPRESSABLE",
1: "UNCOMPRESSABLE",
2: "RANDOM",
}
var PayloadType_value = map[string]int32{
"COMPRESSABLE": 0,
"UNCOMPRESSABLE": 1,
"RANDOM": 2,
}
Functions ¶
func RegisterLoadBalancerStatsServiceService ¶ added in v1.32.0
func RegisterLoadBalancerStatsServiceService(s grpc.ServiceRegistrar, srv *LoadBalancerStatsServiceService)
RegisterLoadBalancerStatsServiceService registers a service implementation with a gRPC server.
func RegisterTestServiceService ¶ added in v1.32.0
func RegisterTestServiceService(s grpc.ServiceRegistrar, srv *TestServiceService)
RegisterTestServiceService registers a service implementation with a gRPC server.
func RegisterUnimplementedServiceService ¶ added in v1.32.0
func RegisterUnimplementedServiceService(s grpc.ServiceRegistrar, srv *UnimplementedServiceService)
RegisterUnimplementedServiceService registers a service implementation with a gRPC server.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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 ¶ added in v1.0.3
func (*EchoStatus) Descriptor() ([]byte, []int)
func (*EchoStatus) GetCode ¶ added in v1.0.3
func (m *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶ added in v1.0.3
func (m *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶ added in v1.0.3
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) Reset ¶ added in v1.0.3
func (m *EchoStatus) Reset()
func (*EchoStatus) String ¶ added in v1.0.3
func (m *EchoStatus) String() string
func (*EchoStatus) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *EchoStatus) XXX_DiscardUnknown()
func (*EchoStatus) XXX_Marshal ¶ added in v1.12.0
func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoStatus) XXX_Merge ¶ added in v1.12.0
func (m *EchoStatus) XXX_Merge(src proto.Message)
func (*EchoStatus) XXX_Size ¶ added in v1.12.0
func (m *EchoStatus) XXX_Size() int
func (*EchoStatus) XXX_Unmarshal ¶ added in v1.12.0
func (m *EchoStatus) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶ added in v1.12.0
func (*Empty) XXX_Unmarshal ¶ added in v1.12.0
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) EnumDescriptor ¶ added in v1.26.0
func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)
func (GrpclbRouteType) String ¶ added in v1.26.0
func (x GrpclbRouteType) String() string
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadBalancerStatsRequest) Descriptor ¶ added in v1.28.0
func (*LoadBalancerStatsRequest) Descriptor() ([]byte, []int)
func (*LoadBalancerStatsRequest) GetNumRpcs ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) GetNumRpcs() int32
func (*LoadBalancerStatsRequest) GetTimeoutSec ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) GetTimeoutSec() int32
func (*LoadBalancerStatsRequest) ProtoMessage ¶ added in v1.28.0
func (*LoadBalancerStatsRequest) ProtoMessage()
func (*LoadBalancerStatsRequest) Reset ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) Reset()
func (*LoadBalancerStatsRequest) String ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) String() string
func (*LoadBalancerStatsRequest) XXX_DiscardUnknown ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) XXX_DiscardUnknown()
func (*LoadBalancerStatsRequest) XXX_Marshal ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadBalancerStatsRequest) XXX_Merge ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) XXX_Merge(src proto.Message)
func (*LoadBalancerStatsRequest) XXX_Size ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) XXX_Size() int
func (*LoadBalancerStatsRequest) XXX_Unmarshal ¶ added in v1.28.0
func (m *LoadBalancerStatsRequest) XXX_Unmarshal(b []byte) error
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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadBalancerStatsResponse) Descriptor ¶ added in v1.28.0
func (*LoadBalancerStatsResponse) Descriptor() ([]byte, []int)
func (*LoadBalancerStatsResponse) GetNumFailures ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) GetNumFailures() int32
func (*LoadBalancerStatsResponse) GetRpcsByMethod ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse) GetRpcsByMethod() map[string]*LoadBalancerStatsResponse_RpcsByPeer
func (*LoadBalancerStatsResponse) GetRpcsByPeer ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse) ProtoMessage ¶ added in v1.28.0
func (*LoadBalancerStatsResponse) ProtoMessage()
func (*LoadBalancerStatsResponse) Reset ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) Reset()
func (*LoadBalancerStatsResponse) String ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) String() string
func (*LoadBalancerStatsResponse) XXX_DiscardUnknown ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) XXX_DiscardUnknown()
func (*LoadBalancerStatsResponse) XXX_Marshal ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadBalancerStatsResponse) XXX_Merge ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) XXX_Merge(src proto.Message)
func (*LoadBalancerStatsResponse) XXX_Size ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) XXX_Size() int
func (*LoadBalancerStatsResponse) XXX_Unmarshal ¶ added in v1.28.0
func (m *LoadBalancerStatsResponse) XXX_Unmarshal(b []byte) error
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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor ¶ added in v1.31.0
func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor() ([]byte, []int)
func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer() map[string]int32
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage ¶ added in v1.31.0
func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()
func (*LoadBalancerStatsResponse_RpcsByPeer) Reset ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) Reset()
func (*LoadBalancerStatsResponse_RpcsByPeer) String ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) String() string
func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown()
func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Marshal ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge(src proto.Message)
func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Size ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Size() int
func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal ¶ added in v1.31.0
func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal(b []byte) error
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 LoadBalancerStatsServiceService ¶ added in v1.32.0
type LoadBalancerStatsServiceService struct { // Gets the backend distribution for RPCs sent by a test client. GetClientStats func(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) }
LoadBalancerStatsServiceService is the service API for LoadBalancerStatsService service. Fields should be assigned to their respective handler implementations only before RegisterLoadBalancerStatsServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
func NewLoadBalancerStatsServiceService ¶ added in v1.32.0
func NewLoadBalancerStatsServiceService(s interface{}) *LoadBalancerStatsServiceService
NewLoadBalancerStatsServiceService creates a new LoadBalancerStatsServiceService containing the implemented methods of the LoadBalancerStatsService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor ¶
func (*Payload) GetType ¶
func (m *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *Payload) XXX_DiscardUnknown()
func (*Payload) XXX_Marshal ¶ added in v1.12.0
func (*Payload) XXX_Unmarshal ¶ added in v1.12.0
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) EnumDescriptor ¶
func (PayloadType) EnumDescriptor() ([]byte, []int)
func (PayloadType) String ¶
func (x PayloadType) String() string
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Configuration for a particular response.
func (*ResponseParameters) Descriptor ¶
func (*ResponseParameters) Descriptor() ([]byte, []int)
func (*ResponseParameters) GetIntervalUs ¶
func (m *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (m *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) Reset ¶
func (m *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (m *ResponseParameters) String() string
func (*ResponseParameters) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *ResponseParameters) XXX_DiscardUnknown()
func (*ResponseParameters) XXX_Marshal ¶ added in v1.12.0
func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseParameters) XXX_Merge ¶ added in v1.12.0
func (m *ResponseParameters) XXX_Merge(src proto.Message)
func (*ResponseParameters) XXX_Size ¶ added in v1.12.0
func (m *ResponseParameters) XXX_Size() int
func (*ResponseParameters) XXX_Unmarshal ¶ added in v1.12.0
func (m *ResponseParameters) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Unary request.
func (*SimpleRequest) Descriptor ¶
func (*SimpleRequest) Descriptor() ([]byte, []int)
func (*SimpleRequest) GetFillGrpclbRouteType ¶ added in v1.26.0
func (m *SimpleRequest) GetFillGrpclbRouteType() bool
func (*SimpleRequest) GetFillOauthScope ¶
func (m *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillServerId ¶ added in v1.21.0
func (m *SimpleRequest) GetFillServerId() bool
func (*SimpleRequest) GetFillUsername ¶
func (m *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (m *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseSize ¶
func (m *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶ added in v1.0.3
func (m *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (m *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) Reset ¶
func (m *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (m *SimpleRequest) String() string
func (*SimpleRequest) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *SimpleRequest) XXX_DiscardUnknown()
func (*SimpleRequest) XXX_Marshal ¶ added in v1.12.0
func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleRequest) XXX_Merge ¶ added in v1.12.0
func (m *SimpleRequest) XXX_Merge(src proto.Message)
func (*SimpleRequest) XXX_Size ¶ added in v1.12.0
func (m *SimpleRequest) XXX_Size() int
func (*SimpleRequest) XXX_Unmarshal ¶ added in v1.12.0
func (m *SimpleRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor ¶
func (*SimpleResponse) Descriptor() ([]byte, []int)
func (*SimpleResponse) GetGrpclbRouteType ¶ added in v1.26.0
func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
func (*SimpleResponse) GetHostname ¶ added in v1.28.0
func (m *SimpleResponse) GetHostname() string
func (*SimpleResponse) GetOauthScope ¶
func (m *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (m *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetServerId ¶ added in v1.21.0
func (m *SimpleResponse) GetServerId() string
func (*SimpleResponse) GetUsername ¶
func (m *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) Reset ¶
func (m *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (m *SimpleResponse) String() string
func (*SimpleResponse) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *SimpleResponse) XXX_DiscardUnknown()
func (*SimpleResponse) XXX_Marshal ¶ added in v1.12.0
func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleResponse) XXX_Merge ¶ added in v1.12.0
func (m *SimpleResponse) XXX_Merge(src proto.Message)
func (*SimpleResponse) XXX_Size ¶ added in v1.12.0
func (m *SimpleResponse) XXX_Size() int
func (*SimpleResponse) XXX_Unmarshal ¶ added in v1.12.0
func (m *SimpleResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor ¶
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
func (*StreamingInputCallRequest) GetPayload ¶
func (m *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) Reset ¶
func (m *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (m *StreamingInputCallRequest) String() string
func (*StreamingInputCallRequest) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *StreamingInputCallRequest) XXX_DiscardUnknown()
func (*StreamingInputCallRequest) XXX_Marshal ¶ added in v1.12.0
func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingInputCallRequest) XXX_Merge ¶ added in v1.12.0
func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)
func (*StreamingInputCallRequest) XXX_Size ¶ added in v1.12.0
func (m *StreamingInputCallRequest) XXX_Size() int
func (*StreamingInputCallRequest) XXX_Unmarshal ¶ added in v1.12.0
func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct { // Aggregated size of payloads received from the client. AggregatedPayloadSize int32 `` /* 127-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor ¶
func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)
func (*StreamingInputCallResponse) GetAggregatedPayloadSize ¶
func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
func (*StreamingInputCallResponse) ProtoMessage ¶
func (*StreamingInputCallResponse) ProtoMessage()
func (*StreamingInputCallResponse) Reset ¶
func (m *StreamingInputCallResponse) Reset()
func (*StreamingInputCallResponse) String ¶
func (m *StreamingInputCallResponse) String() string
func (*StreamingInputCallResponse) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *StreamingInputCallResponse) XXX_DiscardUnknown()
func (*StreamingInputCallResponse) XXX_Marshal ¶ added in v1.12.0
func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingInputCallResponse) XXX_Merge ¶ added in v1.12.0
func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)
func (*StreamingInputCallResponse) XXX_Size ¶ added in v1.12.0
func (m *StreamingInputCallResponse) XXX_Size() int
func (*StreamingInputCallResponse) XXX_Unmarshal ¶ added in v1.12.0
func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor ¶
func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)
func (*StreamingOutputCallRequest) GetPayload ¶
func (m *StreamingOutputCallRequest) GetPayload() *Payload
func (*StreamingOutputCallRequest) GetResponseParameters ¶
func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶ added in v1.0.3
func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (m *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) Reset ¶
func (m *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (m *StreamingOutputCallRequest) String() string
func (*StreamingOutputCallRequest) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()
func (*StreamingOutputCallRequest) XXX_Marshal ¶ added in v1.12.0
func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingOutputCallRequest) XXX_Merge ¶ added in v1.12.0
func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)
func (*StreamingOutputCallRequest) XXX_Size ¶ added in v1.12.0
func (m *StreamingOutputCallRequest) XXX_Size() int
func (*StreamingOutputCallRequest) XXX_Unmarshal ¶ added in v1.12.0
func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct { // Payload to increase response size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor ¶
func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)
func (*StreamingOutputCallResponse) GetPayload ¶
func (m *StreamingOutputCallResponse) GetPayload() *Payload
func (*StreamingOutputCallResponse) ProtoMessage ¶
func (*StreamingOutputCallResponse) ProtoMessage()
func (*StreamingOutputCallResponse) Reset ¶
func (m *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (m *StreamingOutputCallResponse) String() string
func (*StreamingOutputCallResponse) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()
func (*StreamingOutputCallResponse) XXX_Marshal ¶ added in v1.12.0
func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingOutputCallResponse) XXX_Merge ¶ added in v1.12.0
func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)
func (*StreamingOutputCallResponse) XXX_Size ¶ added in v1.12.0
func (m *StreamingOutputCallResponse) XXX_Size() int
func (*StreamingOutputCallResponse) XXX_Unmarshal ¶ added in v1.12.0
func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error
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 TestServiceService ¶ added in v1.32.0
type TestServiceService struct { // One empty request followed by one empty response. EmptyCall func(context.Context, *Empty) (*Empty, error) // One request followed by one response. // The server returns the client payload as-is. UnaryCall func(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 func(*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 func(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 func(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 func(TestService_HalfDuplexCallServer) error }
TestServiceService is the service API for TestService service. Fields should be assigned to their respective handler implementations only before RegisterTestServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
func NewTestServiceService ¶ added in v1.32.0
func NewTestServiceService(s interface{}) *TestServiceService
NewTestServiceService creates a new TestServiceService containing the implemented methods of the TestService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.
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 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 UnimplementedServiceService ¶ added in v1.32.0
type UnimplementedServiceService struct { // A call that no server should implement UnimplementedCall func(context.Context, *Empty) (*Empty, error) }
UnimplementedServiceService is the service API for UnimplementedService service. Fields should be assigned to their respective handler implementations only before RegisterUnimplementedServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
func NewUnimplementedServiceService ¶ added in v1.32.0
func NewUnimplementedServiceService(s interface{}) *UnimplementedServiceService
NewUnimplementedServiceService creates a new UnimplementedServiceService containing the implemented methods of the UnimplementedService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.
type UnstableLoadBalancerStatsServiceService ¶ added in v1.32.0
type UnstableLoadBalancerStatsServiceService interface { // Gets the backend distribution for RPCs sent by a test client. GetClientStats(context.Context, *LoadBalancerStatsRequest) (*LoadBalancerStatsResponse, error) }
UnstableLoadBalancerStatsServiceService is the service API for LoadBalancerStatsService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.
type UnstableTestServiceService ¶ added in v1.32.0
type UnstableTestServiceService 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 }
UnstableTestServiceService is the service API for TestService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.
type UnstableUnimplementedServiceService ¶ added in v1.32.0
type UnstableUnimplementedServiceService interface { // A call that no server should implement UnimplementedCall(context.Context, *Empty) (*Empty, error) }
UnstableUnimplementedServiceService is the service API for UnimplementedService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.