grpc_testing

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_test_proto protoreflect.FileDescriptor
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: "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 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.

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

TestServiceServer is the server API for TestService service. All implementations should 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 should be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) EmptyCall 

func (UnimplementedTestServiceServer) EmptyCall(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

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 added in v1.13.0 

func (UnimplementedTestServiceServer) UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, 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.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.