grpc: google.golang.org/grpc/interop/grpc_testing Index | Files

package grpc_testing

import "google.golang.org/grpc/interop/grpc_testing"

Index

Package Files

test.pb.go test_grpc.pb.go

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

func RegisterLoadBalancerStatsServiceServer Uses

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

func RegisterTestServiceServer Uses

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

func RegisterUnimplementedServiceServer Uses

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

type EchoStatus Uses

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 Uses

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

func (*EchoStatus) GetCode Uses

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage Uses

func (m *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage Uses

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) Reset Uses

func (m *EchoStatus) Reset()

func (*EchoStatus) String Uses

func (m *EchoStatus) String() string

func (*EchoStatus) XXX_DiscardUnknown Uses

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal Uses

func (m *EchoStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStatus) XXX_Merge Uses

func (m *EchoStatus) XXX_Merge(src proto.Message)

func (*EchoStatus) XXX_Size Uses

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal Uses

func (m *EchoStatus) XXX_Unmarshal(b []byte) error

type Empty Uses

type Empty struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor Uses

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

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) Reset Uses

func (m *Empty) Reset()

func (*Empty) String Uses

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown Uses

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal Uses

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge Uses

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size Uses

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal Uses

func (m *Empty) XXX_Unmarshal(b []byte) error

type GrpclbRouteType Uses

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 Uses

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

func (GrpclbRouteType) String Uses

func (x GrpclbRouteType) String() string

type LoadBalancerStatsRequest Uses

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 Uses

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

func (*LoadBalancerStatsRequest) GetNumRpcs Uses

func (m *LoadBalancerStatsRequest) GetNumRpcs() int32

func (*LoadBalancerStatsRequest) GetTimeoutSec Uses

func (m *LoadBalancerStatsRequest) GetTimeoutSec() int32

func (*LoadBalancerStatsRequest) ProtoMessage Uses

func (*LoadBalancerStatsRequest) ProtoMessage()

func (*LoadBalancerStatsRequest) Reset Uses

func (m *LoadBalancerStatsRequest) Reset()

func (*LoadBalancerStatsRequest) String Uses

func (m *LoadBalancerStatsRequest) String() string

func (*LoadBalancerStatsRequest) XXX_DiscardUnknown Uses

func (m *LoadBalancerStatsRequest) XXX_DiscardUnknown()

func (*LoadBalancerStatsRequest) XXX_Marshal Uses

func (m *LoadBalancerStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerStatsRequest) XXX_Merge Uses

func (m *LoadBalancerStatsRequest) XXX_Merge(src proto.Message)

func (*LoadBalancerStatsRequest) XXX_Size Uses

func (m *LoadBalancerStatsRequest) XXX_Size() int

func (*LoadBalancerStatsRequest) XXX_Unmarshal Uses

func (m *LoadBalancerStatsRequest) XXX_Unmarshal(b []byte) error

type LoadBalancerStatsResponse Uses

type LoadBalancerStatsResponse struct {
    // The number of completed RPCs for each peer.
    RpcsByPeer map[string]int32 `protobuf:"bytes,1,rep,name=rpcs_by_peer,json=rpcsByPeer,proto3" json:"rpcs_by_peer,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // 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 `protobuf:"bytes,3,rep,name=rpcs_by_method,json=rpcsByMethod,proto3" json:"rpcs_by_method,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
    XXX_unrecognized     []byte                                           `json:"-"`
    XXX_sizecache        int32                                            `json:"-"`
}

func (*LoadBalancerStatsResponse) Descriptor Uses

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

func (*LoadBalancerStatsResponse) GetNumFailures Uses

func (m *LoadBalancerStatsResponse) GetNumFailures() int32

func (*LoadBalancerStatsResponse) GetRpcsByMethod Uses

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

func (*LoadBalancerStatsResponse) GetRpcsByPeer Uses

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

func (*LoadBalancerStatsResponse) ProtoMessage Uses

func (*LoadBalancerStatsResponse) ProtoMessage()

func (*LoadBalancerStatsResponse) Reset Uses

func (m *LoadBalancerStatsResponse) Reset()

func (*LoadBalancerStatsResponse) String Uses

func (m *LoadBalancerStatsResponse) String() string

func (*LoadBalancerStatsResponse) XXX_DiscardUnknown Uses

func (m *LoadBalancerStatsResponse) XXX_DiscardUnknown()

func (*LoadBalancerStatsResponse) XXX_Marshal Uses

func (m *LoadBalancerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerStatsResponse) XXX_Merge Uses

func (m *LoadBalancerStatsResponse) XXX_Merge(src proto.Message)

func (*LoadBalancerStatsResponse) XXX_Size Uses

func (m *LoadBalancerStatsResponse) XXX_Size() int

func (*LoadBalancerStatsResponse) XXX_Unmarshal Uses

func (m *LoadBalancerStatsResponse) XXX_Unmarshal(b []byte) error

type LoadBalancerStatsResponse_RpcsByPeer Uses

type LoadBalancerStatsResponse_RpcsByPeer struct {
    // The number of completed RPCs for each peer.
    RpcsByPeer           map[string]int32 `protobuf:"bytes,1,rep,name=rpcs_by_peer,json=rpcsByPeer,proto3" json:"rpcs_by_peer,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*LoadBalancerStatsResponse_RpcsByPeer) Descriptor Uses

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

func (*LoadBalancerStatsResponse_RpcsByPeer) GetRpcsByPeer Uses

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

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage Uses

func (*LoadBalancerStatsResponse_RpcsByPeer) ProtoMessage()

func (*LoadBalancerStatsResponse_RpcsByPeer) Reset Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) Reset()

func (*LoadBalancerStatsResponse_RpcsByPeer) String Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) String() string

func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_DiscardUnknown()

func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Marshal Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Merge(src proto.Message)

func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Size Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Size() int

func (*LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal Uses

func (m *LoadBalancerStatsResponse_RpcsByPeer) XXX_Unmarshal(b []byte) error

type LoadBalancerStatsServiceClient Uses

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 Uses

func NewLoadBalancerStatsServiceClient(cc grpc.ClientConnInterface) LoadBalancerStatsServiceClient

type LoadBalancerStatsServiceServer Uses

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 Uses

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 Uses

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

func (*Payload) GetBody Uses

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

func (*Payload) GetType Uses

func (m *Payload) GetType() PayloadType

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) Reset Uses

func (m *Payload) Reset()

func (*Payload) String Uses

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown Uses

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal Uses

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge Uses

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size Uses

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal Uses

func (m *Payload) XXX_Unmarshal(b []byte) error

type PayloadType Uses

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 Uses

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

func (PayloadType) String Uses

func (x PayloadType) String() string

type ResponseParameters Uses

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 Uses

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

func (*ResponseParameters) GetIntervalUs Uses

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize Uses

func (m *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage Uses

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) Reset Uses

func (m *ResponseParameters) Reset()

func (*ResponseParameters) String Uses

func (m *ResponseParameters) String() string

func (*ResponseParameters) XXX_DiscardUnknown Uses

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal Uses

func (m *ResponseParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseParameters) XXX_Merge Uses

func (m *ResponseParameters) XXX_Merge(src proto.Message)

func (*ResponseParameters) XXX_Size Uses

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal Uses

func (m *ResponseParameters) XXX_Unmarshal(b []byte) error

type SimpleRequest Uses

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 `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // 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 Uses

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

func (*SimpleRequest) GetFillGrpclbRouteType Uses

func (m *SimpleRequest) GetFillGrpclbRouteType() bool

func (*SimpleRequest) GetFillOauthScope Uses

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillServerId Uses

func (m *SimpleRequest) GetFillServerId() bool

func (*SimpleRequest) GetFillUsername Uses

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload Uses

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseSize Uses

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus Uses

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType Uses

func (m *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage Uses

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset Uses

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String Uses

func (m *SimpleRequest) String() string

func (*SimpleRequest) XXX_DiscardUnknown Uses

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal Uses

func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleRequest) XXX_Merge Uses

func (m *SimpleRequest) XXX_Merge(src proto.Message)

func (*SimpleRequest) XXX_Size Uses

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal Uses

func (m *SimpleRequest) XXX_Unmarshal(b []byte) error

type SimpleResponse Uses

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 `protobuf:"varint,5,opt,name=grpclb_route_type,json=grpclbRouteType,proto3,enum=grpc.testing.GrpclbRouteType" json:"grpclb_route_type,omitempty"`
    // 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 Uses

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

func (*SimpleResponse) GetGrpclbRouteType Uses

func (m *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType

func (*SimpleResponse) GetHostname Uses

func (m *SimpleResponse) GetHostname() string

func (*SimpleResponse) GetOauthScope Uses

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload Uses

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetServerId Uses

func (m *SimpleResponse) GetServerId() string

func (*SimpleResponse) GetUsername Uses

func (m *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage Uses

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset Uses

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String Uses

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown Uses

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal Uses

func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleResponse) XXX_Merge Uses

func (m *SimpleResponse) XXX_Merge(src proto.Message)

func (*SimpleResponse) XXX_Size Uses

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal Uses

func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type StreamingInputCallRequest Uses

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 Uses

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

func (*StreamingInputCallRequest) GetPayload Uses

func (m *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage Uses

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) Reset Uses

func (m *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String Uses

func (m *StreamingInputCallRequest) String() string

func (*StreamingInputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal Uses

func (m *StreamingInputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallRequest) XXX_Merge Uses

func (m *StreamingInputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingInputCallRequest) XXX_Size Uses

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal Uses

func (m *StreamingInputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingInputCallResponse Uses

type StreamingInputCallResponse struct {
    // Aggregated size of payloads received from the client.
    AggregatedPayloadSize int32    `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize,proto3" json:"aggregated_payload_size,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor Uses

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

func (*StreamingInputCallResponse) GetAggregatedPayloadSize Uses

func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage Uses

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) Reset Uses

func (m *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String Uses

func (m *StreamingInputCallResponse) String() string

func (*StreamingInputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal Uses

func (m *StreamingInputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingInputCallResponse) XXX_Merge Uses

func (m *StreamingInputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingInputCallResponse) XXX_Size Uses

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal Uses

func (m *StreamingInputCallResponse) XXX_Unmarshal(b []byte) error

type StreamingOutputCallRequest Uses

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 `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // 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 Uses

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

func (*StreamingOutputCallRequest) GetPayload Uses

func (m *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseParameters Uses

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

func (*StreamingOutputCallRequest) GetResponseStatus Uses

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType Uses

func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage Uses

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) Reset Uses

func (m *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String Uses

func (m *StreamingOutputCallRequest) String() string

func (*StreamingOutputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal Uses

func (m *StreamingOutputCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallRequest) XXX_Merge Uses

func (m *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingOutputCallRequest) XXX_Size Uses

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal Uses

func (m *StreamingOutputCallRequest) XXX_Unmarshal(b []byte) error

type StreamingOutputCallResponse Uses

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 Uses

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

func (*StreamingOutputCallResponse) GetPayload Uses

func (m *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage Uses

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) Reset Uses

func (m *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String Uses

func (m *StreamingOutputCallResponse) String() string

func (*StreamingOutputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal Uses

func (m *StreamingOutputCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingOutputCallResponse) XXX_Merge Uses

func (m *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingOutputCallResponse) XXX_Size Uses

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal Uses

func (m *StreamingOutputCallResponse) XXX_Unmarshal(b []byte) error

type TestServiceClient Uses

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 Uses

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer Uses

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 Uses

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

type TestService_FullDuplexCallServer Uses

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

type TestService_HalfDuplexCallClient Uses

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

type TestService_HalfDuplexCallServer Uses

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

type TestService_StreamingInputCallClient Uses

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

type TestService_StreamingInputCallServer Uses

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

type TestService_StreamingOutputCallClient Uses

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

type TestService_StreamingOutputCallServer Uses

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

type UnimplementedLoadBalancerStatsServiceServer Uses

type UnimplementedLoadBalancerStatsServiceServer struct {
}

UnimplementedLoadBalancerStatsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLoadBalancerStatsServiceServer) GetClientStats Uses

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

type UnimplementedServiceClient Uses

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 Uses

func NewUnimplementedServiceClient(cc grpc.ClientConnInterface) UnimplementedServiceClient

type UnimplementedServiceServer Uses

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 Uses

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) EmptyCall Uses

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

func (UnimplementedTestServiceServer) FullDuplexCall Uses

func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error

func (UnimplementedTestServiceServer) HalfDuplexCall Uses

func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error

func (UnimplementedTestServiceServer) StreamingInputCall Uses

func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error

func (UnimplementedTestServiceServer) StreamingOutputCall Uses

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

func (UnimplementedTestServiceServer) UnaryCall Uses

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

type UnimplementedUnimplementedServiceServer Uses

type UnimplementedUnimplementedServiceServer struct {
}

UnimplementedUnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUnimplementedServiceServer) UnimplementedCall Uses

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

type UnsafeLoadBalancerStatsServiceServer Uses

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 Uses

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 Uses

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.

Package grpc_testing imports 7 packages (graph) and is imported by 186 packages. Updated 2020-09-30. Refresh now. Tools for package owners.