Documentation ¶
Index ¶
- Variables
- func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
- 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 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) GetFillOauthScope() bool
- func (m *SimpleRequest) GetFillUsername() bool
- func (m *SimpleRequest) GetPayload() *Payload
- func (m *SimpleRequest) GetResponseSize() int32
- 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) GetOauthScope() string
- func (m *SimpleResponse) GetPayload() *Payload
- 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) 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 TestServiceServer
- 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 UnimplementedTestServiceServer
- func (*UnimplementedTestServiceServer) EmptyCall(ctx context.Context, req *Empty) (*Empty, error)
- func (*UnimplementedTestServiceServer) FullDuplexCall(srv TestService_FullDuplexCallServer) error
- func (*UnimplementedTestServiceServer) HalfDuplexCall(srv TestService_HalfDuplexCallServer) error
- func (*UnimplementedTestServiceServer) StreamingInputCall(srv TestService_StreamingInputCallServer) error
- func (*UnimplementedTestServiceServer) StreamingOutputCall(req *StreamingOutputCallRequest, srv TestService_StreamingOutputCallServer) error
- func (*UnimplementedTestServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)
Constants ¶
This section is empty.
Variables ¶
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 RegisterTestServiceServer ¶
func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
Types ¶
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 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Unary request.
func (*SimpleRequest) Descriptor ¶
func (*SimpleRequest) Descriptor() ([]byte, []int)
func (*SimpleRequest) GetFillOauthScope ¶
func (m *SimpleRequest) GetFillOauthScope() 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) 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"` 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) GetOauthScope ¶
func (m *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (m *SimpleResponse) GetPayload() *Payload
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"` 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) 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTestServiceClient ¶
func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { // One empty request followed by one empty response. EmptyCall(context.Context, *Empty) (*Empty, error) // One request followed by one response. // The server returns the client payload as-is. UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(TestService_StreamingInputCallServer) error // A sequence of requests with each request served by the server immediately. // As one request could lead to multiple responses, this interface // demonstrates the idea of full duplexing. FullDuplexCall(TestService_FullDuplexCallServer) error // A sequence of requests followed by a sequence of responses. // The server buffers all the client requests and then serves them in order. A // stream of responses are returned to the client when the server starts with // first request. HalfDuplexCall(TestService_HalfDuplexCallServer) error }
TestServiceServer is the server API for TestService service.
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 UnimplementedTestServiceServer ¶ added in v1.24.0
type UnimplementedTestServiceServer struct { }
UnimplementedTestServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTestServiceServer) FullDuplexCall ¶ added in v1.24.0
func (*UnimplementedTestServiceServer) FullDuplexCall(srv TestService_FullDuplexCallServer) error
func (*UnimplementedTestServiceServer) HalfDuplexCall ¶ added in v1.24.0
func (*UnimplementedTestServiceServer) HalfDuplexCall(srv TestService_HalfDuplexCallServer) error
func (*UnimplementedTestServiceServer) StreamingInputCall ¶ added in v1.24.0
func (*UnimplementedTestServiceServer) StreamingInputCall(srv TestService_StreamingInputCallServer) error
func (*UnimplementedTestServiceServer) StreamingOutputCall ¶ added in v1.24.0
func (*UnimplementedTestServiceServer) StreamingOutputCall(req *StreamingOutputCallRequest, srv TestService_StreamingOutputCallServer) error
func (*UnimplementedTestServiceServer) UnaryCall ¶ added in v1.24.0
func (*UnimplementedTestServiceServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)