 Documentation
      ¶
      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(TestService_FullDuplexCallServer) error
- func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error
- func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error
- func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) 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 ¶
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
            
          
  
    
  
      
      func (*SimpleAnyRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimpleAnyRequest.ProtoReflect.Descriptor instead.
func (*SimpleAnyRequest) GetUserId ¶
func (x *SimpleAnyRequest) GetUserId() int32
func (*SimpleAnyRequest) GetUserProps ¶
func (x *SimpleAnyRequest) GetUserProps() *anypb.Any
func (*SimpleAnyRequest) ProtoMessage ¶
func (*SimpleAnyRequest) ProtoMessage()
func (*SimpleAnyRequest) ProtoReflect ¶
func (x *SimpleAnyRequest) ProtoReflect() protoreflect.Message
func (*SimpleAnyRequest) Reset ¶
func (x *SimpleAnyRequest) Reset()
func (*SimpleAnyRequest) String ¶
func (x *SimpleAnyRequest) String() string
type SimpleAnyResponse ¶
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
            
          
  
    
  
      
      func (*SimpleAnyResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimpleAnyResponse.ProtoReflect.Descriptor instead.
func (*SimpleAnyResponse) GetUserId ¶
func (x *SimpleAnyResponse) GetUserId() int32
func (*SimpleAnyResponse) GetUserProps ¶
func (x *SimpleAnyResponse) GetUserProps() *anypb.Any
func (*SimpleAnyResponse) ProtoMessage ¶
func (*SimpleAnyResponse) ProtoMessage()
func (*SimpleAnyResponse) ProtoReflect ¶
func (x *SimpleAnyResponse) ProtoReflect() protoreflect.Message
func (*SimpleAnyResponse) Reset ¶
func (x *SimpleAnyResponse) Reset()
func (*SimpleAnyResponse) String ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) (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)
	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, 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
	UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error)
	// contains filtered or unexported methods
}
    TestServiceServer is the server API for TestService service. All implementations must 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 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) 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) UnaryAny ¶
func (UnimplementedTestServiceServer) UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error)
func (UnimplementedTestServiceServer) UnaryCall ¶
func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
func (UnimplementedTestServiceServer) UnaryUpdateCall ¶
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 ¶
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
            
          
  
    
  
      
      func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetUpdateMask ¶
func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶
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
            
          
  
    
  
      
      func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetUpdateMask ¶
func (x *UpdateResponse) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string
type User ¶
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
            
          
  
    
  
      
      
    func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message