Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- type EchoStatus
- type ResponseParameters
- func (*ResponseParameters) Descriptor() ([]byte, []int)deprecated
- 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 SimpleAnyRequest
- func (*SimpleAnyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleAnyRequest) GetUserId() int32
- func (x *SimpleAnyRequest) GetUserProps() *anypb.Any
- func (*SimpleAnyRequest) ProtoMessage()
- func (x *SimpleAnyRequest) ProtoReflect() protoreflect.Message
- func (x *SimpleAnyRequest) Reset()
- func (x *SimpleAnyRequest) String() string
- type SimpleAnyResponse
- func (*SimpleAnyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleAnyResponse) GetUserId() int32
- func (x *SimpleAnyResponse) GetUserProps() *anypb.Any
- func (*SimpleAnyResponse) ProtoMessage()
- func (x *SimpleAnyResponse) ProtoReflect() protoreflect.Message
- func (x *SimpleAnyResponse) Reset()
- func (x *SimpleAnyResponse) String() string
- type SimpleRequest
- func (*SimpleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleRequest) GetResponseStatus() *EchoStatus
- func (x *SimpleRequest) GetUser() *User
- func (*SimpleRequest) ProtoMessage()
- func (x *SimpleRequest) ProtoReflect() protoreflect.Message
- func (x *SimpleRequest) Reset()
- func (x *SimpleRequest) String() string
- type SimpleResponse
- type StreamingInputCallRequest
- func (*StreamingInputCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamingInputCallRequest) GetUser() *User
- 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 (x *StreamingInputCallResponse) GetUser() *User
- 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) GetResponseParameters() []*ResponseParameters
- func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
- func (x *StreamingOutputCallRequest) GetUser() *User
- 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) GetUser() *User
- 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, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedTestServiceServer) FullDuplexCall(...) error
- func (UnimplementedTestServiceServer) HalfDuplexCall(...) error
- func (UnimplementedTestServiceServer) StreamingInputCall(...) error
- func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, ...) error
- func (UnimplementedTestServiceServer) UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error)
- func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
- func (UnimplementedTestServiceServer) UnaryUpdateCall(context.Context, *UpdateRequest) (*UpdateResponse, error)
- type UnsafeTestServiceServer
- type UpdateRequest
- type UpdateResponse
- type User
Constants ¶
const ( TestService_EmptyCall_FullMethodName = "/grpc_client_cli.testing.TestService/EmptyCall" TestService_UnaryCall_FullMethodName = "/grpc_client_cli.testing.TestService/UnaryCall" TestService_UnaryUpdateCall_FullMethodName = "/grpc_client_cli.testing.TestService/UnaryUpdateCall" TestService_StreamingOutputCall_FullMethodName = "/grpc_client_cli.testing.TestService/StreamingOutputCall" TestService_StreamingInputCall_FullMethodName = "/grpc_client_cli.testing.TestService/StreamingInputCall" TestService_FullDuplexCall_FullMethodName = "/grpc_client_cli.testing.TestService/FullDuplexCall" TestService_HalfDuplexCall_FullMethodName = "/grpc_client_cli.testing.TestService/HalfDuplexCall" TestService_UnaryAny_FullMethodName = "/grpc_client_cli.testing.TestService/UnaryAny" )
Variables ¶
var File_test_proto protoreflect.FileDescriptor
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc_client_cli.testing.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EmptyCall", Handler: _TestService_EmptyCall_Handler, }, { MethodName: "UnaryCall", Handler: _TestService_UnaryCall_Handler, }, { MethodName: "UnaryUpdateCall", Handler: _TestService_UnaryUpdateCall_Handler, }, { MethodName: "UnaryAny", Handler: _TestService_UnaryAny_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.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 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 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
deprecated
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 SimpleAnyRequest ¶ added in v1.13.0
type SimpleAnyRequest struct { UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` UserProps *anypb.Any `protobuf:"bytes,2,opt,name=user_props,json=userProps,proto3" json:"user_props,omitempty"` // contains filtered or unexported fields }
func (*SimpleAnyRequest) Descriptor
deprecated
added in
v1.13.0
func (*SimpleAnyRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleAnyRequest.ProtoReflect.Descriptor instead.
func (*SimpleAnyRequest) GetUserId ¶ added in v1.13.0
func (x *SimpleAnyRequest) GetUserId() int32
func (*SimpleAnyRequest) GetUserProps ¶ added in v1.13.0
func (x *SimpleAnyRequest) GetUserProps() *anypb.Any
func (*SimpleAnyRequest) ProtoMessage ¶ added in v1.13.0
func (*SimpleAnyRequest) ProtoMessage()
func (*SimpleAnyRequest) ProtoReflect ¶ added in v1.13.0
func (x *SimpleAnyRequest) ProtoReflect() protoreflect.Message
func (*SimpleAnyRequest) Reset ¶ added in v1.13.0
func (x *SimpleAnyRequest) Reset()
func (*SimpleAnyRequest) String ¶ added in v1.13.0
func (x *SimpleAnyRequest) String() string
type SimpleAnyResponse ¶ added in v1.13.0
type SimpleAnyResponse struct { UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` UserProps *anypb.Any `protobuf:"bytes,2,opt,name=user_props,json=userProps,proto3" json:"user_props,omitempty"` // contains filtered or unexported fields }
func (*SimpleAnyResponse) Descriptor
deprecated
added in
v1.13.0
func (*SimpleAnyResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleAnyResponse.ProtoReflect.Descriptor instead.
func (*SimpleAnyResponse) GetUserId ¶ added in v1.13.0
func (x *SimpleAnyResponse) GetUserId() int32
func (*SimpleAnyResponse) GetUserProps ¶ added in v1.13.0
func (x *SimpleAnyResponse) GetUserProps() *anypb.Any
func (*SimpleAnyResponse) ProtoMessage ¶ added in v1.13.0
func (*SimpleAnyResponse) ProtoMessage()
func (*SimpleAnyResponse) ProtoReflect ¶ added in v1.13.0
func (x *SimpleAnyResponse) ProtoReflect() protoreflect.Message
func (*SimpleAnyResponse) Reset ¶ added in v1.13.0
func (x *SimpleAnyResponse) Reset()
func (*SimpleAnyResponse) String ¶ added in v1.13.0
func (x *SimpleAnyResponse) String() string
type SimpleRequest ¶
type SimpleRequest struct { ResponseStatus *EchoStatus `protobuf:"bytes,1,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"` User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,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) GetResponseStatus ¶
func (x *SimpleRequest) GetResponseStatus() *EchoStatus
func (*SimpleRequest) GetUser ¶ added in v1.9.0
func (x *SimpleRequest) GetUser() *User
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 { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,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) GetUser ¶ added in v1.9.0
func (x *SimpleResponse) GetUser() *User
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 { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,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) GetUser ¶ added in v1.9.0
func (x *StreamingInputCallRequest) GetUser() *User
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 */ User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // 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) GetUser ¶ added in v1.9.0
func (x *StreamingInputCallResponse) GetUser() *User
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 { // Configuration for each expected response message. ResponseParameters []*ResponseParameters `protobuf:"bytes,1,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"` // Optional input payload sent along with the request. User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // Whether server should return a given status ResponseStatus *EchoStatus `protobuf:"bytes,3,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) GetResponseParameters ¶
func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters
func (*StreamingOutputCallRequest) GetResponseStatus ¶
func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus
func (*StreamingOutputCallRequest) GetUser ¶ added in v1.9.0
func (x *StreamingOutputCallRequest) GetUser() *User
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. User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,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) GetUser ¶ added in v1.9.0
func (x *StreamingOutputCallResponse) GetUser() *User
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 *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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 one response. // The server returns the client payload as-is. UnaryUpdateCall(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, 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) (grpc.ServerStreamingClient[StreamingOutputCallResponse], 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) (grpc.ClientStreamingClient[StreamingInputCallRequest, StreamingInputCallResponse], 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) (grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse], 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) (grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse], error) UnaryAny(ctx context.Context, in *SimpleAnyRequest, opts ...grpc.CallOption) (*SimpleAnyResponse, 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.
A simple service to test the various types of RPCs and experiment with performance with various types of payload.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { // One empty request followed by one empty response. EmptyCall(context.Context, *emptypb.Empty) (*emptypb.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 one response. // The server returns the client payload as-is. UnaryUpdateCall(context.Context, *UpdateRequest) (*UpdateResponse, error) // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. StreamingOutputCall(*StreamingOutputCallRequest, grpc.ServerStreamingServer[StreamingOutputCallResponse]) error // A sequence of requests followed by one response (streamed upload). // The server returns the aggregated size of client payload as the result. StreamingInputCall(grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]) 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(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) 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(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error) }
TestServiceServer is the server API for TestService service. All implementations should embed UnimplementedTestServiceServer for forward compatibility.
A simple service to test the various types of RPCs and experiment with performance with various types of payload.
type TestService_FullDuplexCallClient ¶
type TestService_FullDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_FullDuplexCallServer ¶
type TestService_FullDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_HalfDuplexCallClient ¶
type TestService_HalfDuplexCallClient = grpc.BidiStreamingClient[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_HalfDuplexCallServer ¶
type TestService_HalfDuplexCallServer = grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingInputCallClient ¶
type TestService_StreamingInputCallClient = grpc.ClientStreamingClient[StreamingInputCallRequest, StreamingInputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingInputCallServer ¶
type TestService_StreamingInputCallServer = grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingOutputCallClient ¶
type TestService_StreamingOutputCallClient = grpc.ServerStreamingClient[StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type TestService_StreamingOutputCallServer ¶
type TestService_StreamingOutputCallServer = grpc.ServerStreamingServer[StreamingOutputCallResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct{}
UnimplementedTestServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedTestServiceServer) FullDuplexCall ¶
func (UnimplementedTestServiceServer) FullDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) HalfDuplexCall ¶
func (UnimplementedTestServiceServer) HalfDuplexCall(grpc.BidiStreamingServer[StreamingOutputCallRequest, StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) StreamingInputCall ¶
func (UnimplementedTestServiceServer) StreamingInputCall(grpc.ClientStreamingServer[StreamingInputCallRequest, StreamingInputCallResponse]) error
func (UnimplementedTestServiceServer) StreamingOutputCall ¶
func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, grpc.ServerStreamingServer[StreamingOutputCallResponse]) error
func (UnimplementedTestServiceServer) UnaryAny ¶ added in v1.13.0
func (UnimplementedTestServiceServer) UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error)
func (UnimplementedTestServiceServer) UnaryCall ¶
func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
func (UnimplementedTestServiceServer) UnaryUpdateCall ¶ added in v1.21.0
func (UnimplementedTestServiceServer) UnaryUpdateCall(context.Context, *UpdateRequest) (*UpdateResponse, 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.
type UpdateRequest ¶ added in v1.21.0
type UpdateRequest struct { UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
Dummy request with a fieldmask
func (*UpdateRequest) Descriptor
deprecated
added in
v1.21.0
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetUpdateMask ¶ added in v1.21.0
func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateRequest) ProtoMessage ¶ added in v1.21.0
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶ added in v1.21.0
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶ added in v1.21.0
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶ added in v1.21.0
func (x *UpdateRequest) String() string
type UpdateResponse ¶ added in v1.21.0
type UpdateResponse struct { UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
Dummy response with a fieldmask
func (*UpdateResponse) Descriptor
deprecated
added in
v1.21.0
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetUpdateMask ¶ added in v1.21.0
func (x *UpdateResponse) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateResponse) ProtoMessage ¶ added in v1.21.0
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶ added in v1.21.0
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶ added in v1.21.0
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶ added in v1.21.0
func (x *UpdateResponse) String() string
type User ¶ added in v1.9.0
type User struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*User) Descriptor
deprecated
added in
v1.9.0
func (*User) ProtoMessage ¶ added in v1.9.0
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶ added in v1.9.0
func (x *User) ProtoReflect() protoreflect.Message