package grpc_testing
import "google.golang.org/grpc/test/grpc_testing"
Index ¶
- Variables
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (x *Empty) ProtoReflect() protoreflect.Message
- func (x *Empty) Reset()
- func (x *Empty) String() string
- type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (x *Payload) GetBody() []byte
- func (x *Payload) GetType() PayloadType
- func (*Payload) ProtoMessage()
- func (x *Payload) ProtoReflect() protoreflect.Message
- func (x *Payload) Reset()
- func (x *Payload) String() string
- type PayloadType
- func (PayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x PayloadType) Enum() *PayloadType
- func (PayloadType) EnumDescriptor() ([]byte, []int)
- func (x PayloadType) Number() protoreflect.EnumNumber
- func (x PayloadType) String() string
- func (PayloadType) Type() protoreflect.EnumType
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)
- 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)
- func (x *SimpleRequest) GetFillOauthScope() bool
- func (x *SimpleRequest) GetFillUsername() bool
- func (x *SimpleRequest) GetPayload() *Payload
- func (x *SimpleRequest) GetResponseSize() int32
- 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)
- func (x *SimpleResponse) GetOauthScope() string
- func (x *SimpleResponse) GetPayload() *Payload
- 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)
- 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)
- 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)
- func (x *StreamingOutputCallRequest) GetPayload() *Payload
- func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
- 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)
- func (x *StreamingOutputCallResponse) GetPayload() *Payload
- func (*StreamingOutputCallResponse) ProtoMessage()
- func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message
- func (x *StreamingOutputCallResponse) Reset()
- func (x *StreamingOutputCallResponse) String() string
- 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(context.Context, *Empty) (*Empty, error)
- func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error
- func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error
- func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error
- func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
- func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- type UnsafeTestServiceServer
Variables ¶
var ( PayloadType_name = map[int32]string{ 0: "COMPRESSABLE", 1: "UNCOMPRESSABLE", 2: "RANDOM", } PayloadType_value = map[string]int32{ "COMPRESSABLE": 0, "UNCOMPRESSABLE": 1, "RANDOM": 2, } )
Enum value maps for PayloadType.
var File_test_grpc_testing_test_proto protoreflect.FileDescriptor
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.testing.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EmptyCall", Handler: _TestService_EmptyCall_Handler, }, { MethodName: "UnaryCall", Handler: _TestService_UnaryCall_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamingOutputCall", Handler: _TestService_StreamingOutputCall_Handler, ServerStreams: true, }, { StreamName: "StreamingInputCall", Handler: _TestService_StreamingInputCall_Handler, ClientStreams: true, }, { StreamName: "FullDuplexCall", Handler: _TestService_FullDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "HalfDuplexCall", Handler: _TestService_HalfDuplexCall_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "test/grpc_testing/test.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
Types ¶
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor ¶
Deprecated: Use Empty.ProtoReflect.Descriptor instead.
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
func (*Empty) Reset ¶
func (x *Empty) Reset()
func (*Empty) String ¶
type Payload ¶
type Payload struct { // The type of data in body. Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"` // Primary contents of payload. Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
A block of data, to simply increase gRPC message size.
func (*Payload) Descriptor ¶
Deprecated: Use Payload.ProtoReflect.Descriptor instead.
func (*Payload) GetBody ¶
func (*Payload) GetType ¶
func (x *Payload) GetType() PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
func (*Payload) Reset ¶
func (x *Payload) Reset()
func (*Payload) String ¶
type PayloadType ¶
type PayloadType int32
The type of payload that should be returned.
const ( // Compressable text format. PayloadType_COMPRESSABLE PayloadType = 0 // Uncompressable binary format. PayloadType_UNCOMPRESSABLE PayloadType = 1 // Randomly chosen from all other formats defined in this enum. PayloadType_RANDOM PayloadType = 2 )
func (PayloadType) Descriptor ¶
func (PayloadType) Descriptor() protoreflect.EnumDescriptor
func (PayloadType) Enum ¶
func (x PayloadType) Enum() *PayloadType
func (PayloadType) EnumDescriptor ¶
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. // If response_type is COMPRESSABLE, this denotes the size before compression. Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` // Desired interval between consecutive responses in the response stream in // microseconds. IntervalUs int32 `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"` // contains filtered or unexported fields }
Configuration for a particular response.
func (*ResponseParameters) Descriptor ¶
func (*ResponseParameters) Descriptor() ([]byte, []int)
Deprecated: Use ResponseParameters.ProtoReflect.Descriptor instead.
func (*ResponseParameters) GetIntervalUs ¶
func (x *ResponseParameters) GetIntervalUs() int32
func (*ResponseParameters) GetSize ¶
func (x *ResponseParameters) GetSize() int32
func (*ResponseParameters) ProtoMessage ¶
func (*ResponseParameters) ProtoMessage()
func (*ResponseParameters) ProtoReflect ¶
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 `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"` // contains filtered or unexported fields }
Unary request.
func (*SimpleRequest) Descriptor ¶
func (*SimpleRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.
func (*SimpleRequest) GetFillOauthScope ¶
func (x *SimpleRequest) GetFillOauthScope() bool
func (*SimpleRequest) GetFillUsername ¶
func (x *SimpleRequest) GetFillUsername() bool
func (*SimpleRequest) GetPayload ¶
func (x *SimpleRequest) GetPayload() *Payload
func (*SimpleRequest) GetResponseSize ¶
func (x *SimpleRequest) GetResponseSize() int32
func (*SimpleRequest) 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"` // contains filtered or unexported fields }
Unary response, as configured by the request.
func (*SimpleResponse) Descriptor ¶
func (*SimpleResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.
func (*SimpleResponse) GetOauthScope ¶
func (x *SimpleResponse) GetOauthScope() string
func (*SimpleResponse) GetPayload ¶
func (x *SimpleResponse) GetPayload() *Payload
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"` // contains filtered or unexported fields }
Client-streaming request.
func (*StreamingInputCallRequest) Descriptor ¶
func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamingInputCallRequest.ProtoReflect.Descriptor instead.
func (*StreamingInputCallRequest) GetPayload ¶
func (x *StreamingInputCallRequest) GetPayload() *Payload
func (*StreamingInputCallRequest) ProtoMessage ¶
func (*StreamingInputCallRequest) ProtoMessage()
func (*StreamingInputCallRequest) ProtoReflect ¶
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 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize,proto3" json:"aggregated_payload_size,omitempty"` // contains filtered or unexported fields }
Client-streaming response.
func (*StreamingInputCallResponse) Descriptor ¶
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 `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"` // contains filtered or unexported fields }
Server-streaming request.
func (*StreamingOutputCallRequest) Descriptor ¶
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) 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 ¶
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
type TestServiceClient ¶
type TestServiceClient interface { // One empty request followed by one empty response. EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) // One request followed by one response. // The server returns the client payload as-is. UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error) // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error) // A sequence of requests with each request served by the server immediately. // As one request could lead to multiple responses, this interface // demonstrates the idea of full duplexing. FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error) // A sequence of requests followed by a sequence of responses. // The server buffers all the client requests and then serves them in order. A // stream of responses are returned to the client when the server starts with // first request. HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error) }
TestServiceClient is the client API for TestService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { // One empty request followed by one empty response. EmptyCall(context.Context, *Empty) (*Empty, error) // One request followed by one response. // The server returns the client payload as-is. UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(TestService_StreamingInputCallServer) error // A sequence of requests with each request served by the server immediately. // As one request could lead to multiple responses, this interface // demonstrates the idea of full duplexing. FullDuplexCall(TestService_FullDuplexCallServer) error // A sequence of requests followed by a sequence of responses. // The server buffers all the client requests and then serves them in order. A // stream of responses are returned to the client when the server starts with // first request. HalfDuplexCall(TestService_HalfDuplexCallServer) error // contains filtered or unexported methods }
TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility
type TestService_FullDuplexCallClient ¶
type TestService_FullDuplexCallClient interface { Send(*StreamingOutputCallRequest) error Recv() (*StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_FullDuplexCallServer ¶
type TestService_FullDuplexCallServer interface { Send(*StreamingOutputCallResponse) error Recv() (*StreamingOutputCallRequest, error) grpc.ServerStream }
type TestService_HalfDuplexCallClient ¶
type TestService_HalfDuplexCallClient interface { Send(*StreamingOutputCallRequest) error Recv() (*StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_HalfDuplexCallServer ¶
type TestService_HalfDuplexCallServer interface { Send(*StreamingOutputCallResponse) error Recv() (*StreamingOutputCallRequest, error) grpc.ServerStream }
type TestService_StreamingInputCallClient ¶
type TestService_StreamingInputCallClient interface { Send(*StreamingInputCallRequest) error CloseAndRecv() (*StreamingInputCallResponse, error) grpc.ClientStream }
type TestService_StreamingInputCallServer ¶
type TestService_StreamingInputCallServer interface { SendAndClose(*StreamingInputCallResponse) error Recv() (*StreamingInputCallRequest, error) grpc.ServerStream }
type TestService_StreamingOutputCallClient ¶
type TestService_StreamingOutputCallClient interface { Recv() (*StreamingOutputCallResponse, error) grpc.ClientStream }
type TestService_StreamingOutputCallServer ¶
type TestService_StreamingOutputCallServer interface { Send(*StreamingOutputCallResponse) error grpc.ServerStream }
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct { }
UnimplementedTestServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTestServiceServer) EmptyCall ¶
func (UnimplementedTestServiceServer) FullDuplexCall ¶
func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error
func (UnimplementedTestServiceServer) HalfDuplexCall ¶
func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error
func (UnimplementedTestServiceServer) StreamingInputCall ¶
func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error
func (UnimplementedTestServiceServer) StreamingOutputCall ¶
func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
func (UnimplementedTestServiceServer) UnaryCall ¶
func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
type UnsafeTestServiceServer ¶
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.
Source Files ¶
test.pb.go test_grpc.pb.go
- Version
- v1.47.0
- Published
- May 31, 2022
- Platform
- linux/amd64
- Imports
- 9 packages
- Last checked
- 35 minutes ago –
Tools for package owners.