grpc_testing

package
v1.21.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 11, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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 (*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 (*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 (*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 (*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.

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

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_FullDuplexCallServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_HalfDuplexCallClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_HalfDuplexCallServer

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) EmptyCall

func (UnimplementedTestServiceServer) UnaryAny added in v1.13.0

func (UnimplementedTestServiceServer) UnaryCall

func (UnimplementedTestServiceServer) UnaryUpdateCall added in v1.21.0

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) Descriptor() ([]byte, []int)

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetId added in v1.9.0

func (x *User) GetId() int32

func (*User) GetName added in v1.9.0

func (x *User) GetName() string

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

func (*User) Reset added in v1.9.0

func (x *User) Reset()

func (*User) String added in v1.9.0

func (x *User) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL