Documentation
¶
Index ¶
- Variables
- type BoolValue
- type EchoStatus
- type GrpclbRouteType
- func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor
- func (x GrpclbRouteType) Enum() *GrpclbRouteType
- func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)deprecated
- func (x GrpclbRouteType) Number() protoreflect.EnumNumber
- func (x GrpclbRouteType) String() string
- func (GrpclbRouteType) Type() protoreflect.EnumType
- type Payload
- type PayloadType
- func (PayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x PayloadType) Enum() *PayloadType
- func (PayloadType) EnumDescriptor() ([]byte, []int)deprecated
- func (x PayloadType) Number() protoreflect.EnumNumber
- func (x PayloadType) String() string
- func (PayloadType) Type() protoreflect.EnumType
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseParameters) GetCompressed() *BoolValue
- func (x *ResponseParameters) GetIntervalUs() int32
- func (x *ResponseParameters) GetSize() int32
- func (*ResponseParameters) ProtoMessage()
- func (x *ResponseParameters) ProtoReflect() protoreflect.Message
- func (x *ResponseParameters) Reset()
- func (x *ResponseParameters) String() string
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleRequest) GetExpectCompressed() *BoolValue
- func (x *SimpleRequest) GetFillGrpclbRouteType() bool
- func (x *SimpleRequest) GetFillOauthScope() bool
- func (x *SimpleRequest) GetFillServerId() bool
- func (x *SimpleRequest) GetFillUsername() bool
- func (x *SimpleRequest) GetPayload() *Payload
- func (x *SimpleRequest) GetResponseCompressed() *BoolValue
- func (x *SimpleRequest) GetResponseSize() int32
- func (x *SimpleRequest) GetResponseStatus() *EchoStatus
- func (x *SimpleRequest) GetResponseType() PayloadType
- func (*SimpleRequest) ProtoMessage()
- func (x *SimpleRequest) ProtoReflect() protoreflect.Message
- func (x *SimpleRequest) Reset()
- func (x *SimpleRequest) String() string
- type SimpleResponse
- func (*SimpleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
- func (x *SimpleResponse) GetHostname() string
- func (x *SimpleResponse) GetOauthScope() string
- func (x *SimpleResponse) GetPayload() *Payload
- func (x *SimpleResponse) GetServerId() string
- func (x *SimpleResponse) GetUsername() string
- func (*SimpleResponse) ProtoMessage()
- func (x *SimpleResponse) ProtoReflect() protoreflect.Message
- func (x *SimpleResponse) Reset()
- func (x *SimpleResponse) String() string
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
- func (x *StreamingInputCallRequest) GetPayload() *Payload
- func (*StreamingInputCallRequest) ProtoMessage()
- func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallRequest) Reset()
- func (x *StreamingInputCallRequest) String() string
- type StreamingInputCallResponse
- func (*StreamingInputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32
- func (*StreamingInputCallResponse) ProtoMessage()
- func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingInputCallResponse) Reset()
- func (x *StreamingInputCallResponse) String() string
- type StreamingOutputCallRequest
- func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallRequest) GetPayload() *Payload
- func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
- func (*StreamingOutputCallRequest) ProtoMessage()
- func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallRequest) Reset()
- func (x *StreamingOutputCallRequest) String() string
- type StreamingOutputCallResponse
- func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallResponse) Reset()
- func (x *StreamingOutputCallResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( PayloadType_name = map[int32]string{ 0: "COMPRESSABLE", } PayloadType_value = map[string]int32{ "COMPRESSABLE": 0, } )
Enum value maps for PayloadType.
var ( GrpclbRouteType_name = map[int32]string{ 0: "GRPCLB_ROUTE_TYPE_UNKNOWN", 1: "GRPCLB_ROUTE_TYPE_FALLBACK", 2: "GRPCLB_ROUTE_TYPE_BACKEND", } GrpclbRouteType_value = map[string]int32{ "GRPCLB_ROUTE_TYPE_UNKNOWN": 0, "GRPCLB_ROUTE_TYPE_FALLBACK": 1, "GRPCLB_ROUTE_TYPE_BACKEND": 2, } )
Enum value maps for GrpclbRouteType.
var File_grpc_gcp_testing_messages_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BoolValue ¶
type BoolValue struct { // The bool value. Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*BoolValue) Descriptor
deprecated
func (*BoolValue) ProtoMessage ¶
func (*BoolValue) ProtoMessage()
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type EchoStatus ¶
type EchoStatus struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.
func (*EchoStatus) Descriptor
deprecated
func (*EchoStatus) Descriptor() ([]byte, []int)
Deprecated: Use EchoStatus.ProtoReflect.Descriptor instead.
func (*EchoStatus) GetCode ¶
func (x *EchoStatus) GetCode() int32
func (*EchoStatus) GetMessage ¶
func (x *EchoStatus) GetMessage() string
func (*EchoStatus) ProtoMessage ¶
func (*EchoStatus) ProtoMessage()
func (*EchoStatus) ProtoReflect ¶
func (x *EchoStatus) ProtoReflect() protoreflect.Message
func (*EchoStatus) Reset ¶
func (x *EchoStatus) Reset()
func (*EchoStatus) String ¶
func (x *EchoStatus) String() string
type GrpclbRouteType ¶
type GrpclbRouteType int32
The type of route that a client took to reach a server w.r.t. gRPCLB. The server must fill in "fallback" if it detects that the RPC reached the server via the "gRPCLB fallback" path, and "backend" if it detects that the RPC reached the server via "gRPCLB backend" path (i.e. if it got the address of this server from the gRPCLB server BalanceLoad RPC). Exactly how this detection is done is context and server dependent.
const ( // Server didn't detect the route that a client took to reach it. GrpclbRouteType_GRPCLB_ROUTE_TYPE_UNKNOWN GrpclbRouteType = 0 // Indicates that a client reached a server via gRPCLB fallback. GrpclbRouteType_GRPCLB_ROUTE_TYPE_FALLBACK GrpclbRouteType = 1 // Indicates that a client reached a server as a gRPCLB-given backend. GrpclbRouteType_GRPCLB_ROUTE_TYPE_BACKEND GrpclbRouteType = 2 )
func (GrpclbRouteType) Descriptor ¶
func (GrpclbRouteType) Descriptor() protoreflect.EnumDescriptor
func (GrpclbRouteType) Enum ¶
func (x GrpclbRouteType) Enum() *GrpclbRouteType
func (GrpclbRouteType) EnumDescriptor
deprecated
func (GrpclbRouteType) EnumDescriptor() ([]byte, []int)
Deprecated: Use GrpclbRouteType.Descriptor instead.
func (GrpclbRouteType) Number ¶
func (x GrpclbRouteType) Number() protoreflect.EnumNumber
func (GrpclbRouteType) String ¶
func (x GrpclbRouteType) String() string
func (GrpclbRouteType) Type ¶
func (GrpclbRouteType) Type() protoreflect.EnumType
type Payload ¶
type Payload struct { // The type of data in body. Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc_gcp.continuous_load_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) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type PayloadType ¶
type PayloadType int32
The type of payload that should be returned.
const ( // Compressable text format. PayloadType_COMPRESSABLE PayloadType = 0 )
func (PayloadType) Descriptor ¶
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 ¶
func (x PayloadType) Number() protoreflect.EnumNumber
func (PayloadType) String ¶
func (x PayloadType) String() string
func (PayloadType) Type ¶
func (PayloadType) Type() protoreflect.EnumType
type ResponseParameters ¶
type ResponseParameters struct { // Desired payload sizes in responses from the server. 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"` // Whether to request the server to compress the response. This field is // "nullable" in order to interoperate seamlessly with clients not able to // implement the full compression tests by introspecting the call to verify // the response's compression status. Compressed *BoolValue `protobuf:"bytes,3,opt,name=compressed,proto3" json:"compressed,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) GetCompressed ¶
func (x *ResponseParameters) GetCompressed() *BoolValue
func (*ResponseParameters) GetIntervalUs ¶
func (x *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (x *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) ProtoReflect ¶
func (x *ResponseParameters) ProtoReflect() protoreflect.Message
func (*ResponseParameters) Reset ¶
func (x *ResponseParameters) Reset()
func (*ResponseParameters) String ¶
func (x *ResponseParameters) String() string
type SimpleRequest ¶
type SimpleRequest struct { // Desired payload type in the response from the server. // If response_type is RANDOM, server randomly chooses one from other formats. ResponseType PayloadType `` /* 148-byte string literal not displayed */ // Desired payload size in the response from the server. 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 to request the server to compress the response. This field is // "nullable" in order to interoperate seamlessly with clients not able to // implement the full compression tests by introspecting the call to verify // the response's compression status. ResponseCompressed *BoolValue `protobuf:"bytes,6,opt,name=response_compressed,json=responseCompressed,proto3" json:"response_compressed,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 the server should expect this request to be compressed. ExpectCompressed *BoolValue `protobuf:"bytes,8,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,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) GetExpectCompressed ¶
func (x *SimpleRequest) GetExpectCompressed() *BoolValue
func (*SimpleRequest) GetFillGrpclbRouteType ¶
func (x *SimpleRequest) GetFillGrpclbRouteType() bool
func (*SimpleRequest) GetFillOauthScope ¶
func (x *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillServerId ¶
func (x *SimpleRequest) GetFillServerId() bool
func (*SimpleRequest) GetFillUsername ¶
func (x *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (x *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseCompressed ¶
func (x *SimpleRequest) GetResponseCompressed() *BoolValue
func (*SimpleRequest) GetResponseSize ¶
func (x *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) GetResponseStatus ¶
func (x *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetResponseType ¶
func (x *SimpleRequest) GetResponseType() PayloadType
func (*SimpleRequest) ProtoMessage ¶
func (*SimpleRequest) ProtoMessage()
func (*SimpleRequest) ProtoReflect ¶
func (x *SimpleRequest) ProtoReflect() protoreflect.Message
func (*SimpleRequest) Reset ¶
func (x *SimpleRequest) Reset()
func (*SimpleRequest) String ¶
func (x *SimpleRequest) String() string
type SimpleResponse ¶
type SimpleResponse struct { // Payload 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 `` /* 163-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 ¶
func (x *SimpleResponse) GetGrpclbRouteType() GrpclbRouteType
func (*SimpleResponse) GetHostname ¶
func (x *SimpleResponse) GetHostname() string
func (*SimpleResponse) GetOauthScope ¶
func (x *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (x *SimpleResponse) GetPayload() *Payload
func (*SimpleResponse) GetServerId ¶
func (x *SimpleResponse) GetServerId() string
func (*SimpleResponse) GetUsername ¶
func (x *SimpleResponse) GetUsername() string
func (*SimpleResponse) ProtoMessage ¶
func (*SimpleResponse) ProtoMessage()
func (*SimpleResponse) ProtoReflect ¶
func (x *SimpleResponse) ProtoReflect() protoreflect.Message
func (*SimpleResponse) Reset ¶
func (x *SimpleResponse) Reset()
func (*SimpleResponse) String ¶
func (x *SimpleResponse) String() string
type StreamingInputCallRequest ¶
type StreamingInputCallRequest struct { // Optional input payload sent along with the request. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // Whether the server should expect this request to be compressed. This field // is "nullable" in order to interoperate seamlessly with servers not able to // implement the full compression tests by introspecting the call to verify // the request's compression status. ExpectCompressed *BoolValue `protobuf:"bytes,2,opt,name=expect_compressed,json=expectCompressed,proto3" json:"expect_compressed,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) GetExpectCompressed ¶
func (x *StreamingInputCallRequest) GetExpectCompressed() *BoolValue
func (*StreamingInputCallRequest) GetPayload ¶
func (x *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) ProtoReflect ¶
func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingInputCallRequest) Reset ¶
func (x *StreamingInputCallRequest) Reset()
func (*StreamingInputCallRequest) String ¶
func (x *StreamingInputCallRequest) String() string
type StreamingInputCallResponse ¶
type StreamingInputCallResponse struct { // 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 ¶
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 `` /* 148-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 ¶
func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetResponseType ¶
func (x *StreamingOutputCallRequest) GetResponseType() PayloadType
func (*StreamingOutputCallRequest) ProtoMessage ¶
func (*StreamingOutputCallRequest) ProtoMessage()
func (*StreamingOutputCallRequest) ProtoReflect ¶
func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallRequest) Reset ¶
func (x *StreamingOutputCallRequest) Reset()
func (*StreamingOutputCallRequest) String ¶
func (x *StreamingOutputCallRequest) String() string
type StreamingOutputCallResponse ¶
type StreamingOutputCallResponse struct { // Payload to increase response size. Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
Server-streaming response, as configured by the request and parameters.
func (*StreamingOutputCallResponse) Descriptor
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 ¶
func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
func (*StreamingOutputCallResponse) Reset ¶
func (x *StreamingOutputCallResponse) Reset()
func (*StreamingOutputCallResponse) String ¶
func (x *StreamingOutputCallResponse) String() string