test

package
v0.85.0 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Echo_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "echo.v1.Echo",
	HandlerType: (*EchoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Echo",
			Handler:    _Echo_Echo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EchoStream",
			Handler:       _Echo_EchoStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "echo_service.proto",
}

Echo_ServiceDesc is the grpc.ServiceDesc for Echo service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_echo_service_proto protoreflect.FileDescriptor

Functions

func RegisterEchoServer 

func RegisterEchoServer(s grpc.ServiceRegistrar, srv EchoServer)

Types

type EchoClient 

type EchoClient interface {
	Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
	EchoStream(ctx context.Context, in *EchoStreamRequest, opts ...grpc.CallOption) (Echo_EchoStreamClient, error)
}

EchoClient is the client API for Echo 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 NewEchoClient 

func NewEchoClient(cc grpc.ClientConnInterface) EchoClient

type EchoRequest 

type EchoRequest struct {
	Message     string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Repetitions uint32 `protobuf:"varint,2,opt,name=repetitions,proto3" json:"repetitions,omitempty"`
	StatusCode  int32  `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoRequest) Descriptor deprecated 

func (*EchoRequest) Descriptor() ([]byte, []int)

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetMessage 

func (x *EchoRequest) GetMessage() string

func (*EchoRequest) GetRepetitions 

func (x *EchoRequest) GetRepetitions() uint32

func (*EchoRequest) GetStatusCode 

func (x *EchoRequest) GetStatusCode() int32

func (*EchoRequest) ProtoMessage 

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) ProtoReflect added in v0.75.0 

func (x *EchoRequest) ProtoReflect() protoreflect.Message

func (*EchoRequest) Reset 

func (x *EchoRequest) Reset()

func (*EchoRequest) String 

func (x *EchoRequest) String() string

type EchoResponse 

type EchoResponse struct {
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor deprecated 

func (*EchoResponse) Descriptor() ([]byte, []int)

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetMessage 

func (x *EchoResponse) GetMessage() string

func (*EchoResponse) ProtoMessage 

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) ProtoReflect added in v0.75.0 

func (x *EchoResponse) ProtoReflect() protoreflect.Message

func (*EchoResponse) Reset 

func (x *EchoResponse) Reset()

func (*EchoResponse) String 

func (x *EchoResponse) String() string

type EchoServer 

type EchoServer interface {
	Echo(context.Context, *EchoRequest) (*EchoResponse, error)
	EchoStream(*EchoStreamRequest, Echo_EchoStreamServer) error
	// contains filtered or unexported methods
}

EchoServer is the server API for Echo service. All implementations must embed UnimplementedEchoServer for forward compatibility

type EchoStreamRequest 

type EchoStreamRequest struct {
	Message      string               `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Repetitions  uint32               `protobuf:"varint,2,opt,name=repetitions,proto3" json:"repetitions,omitempty"`
	Responses    uint64               `protobuf:"varint,3,opt,name=responses,proto3" json:"responses,omitempty"`
	Interval     *durationpb.Duration `protobuf:"bytes,4,opt,name=interval,proto3" json:"interval,omitempty"`
	StatusCode   int32                `protobuf:"varint,5,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	FailureIndex int32                `protobuf:"varint,6,opt,name=failure_index,json=failureIndex,proto3" json:"failure_index,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoStreamRequest) Descriptor deprecated 

func (*EchoStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use EchoStreamRequest.ProtoReflect.Descriptor instead.

func (*EchoStreamRequest) GetFailureIndex 

func (x *EchoStreamRequest) GetFailureIndex() int32

func (*EchoStreamRequest) GetInterval 

func (x *EchoStreamRequest) GetInterval() *durationpb.Duration

func (*EchoStreamRequest) GetMessage 

func (x *EchoStreamRequest) GetMessage() string

func (*EchoStreamRequest) GetRepetitions 

func (x *EchoStreamRequest) GetRepetitions() uint32

func (*EchoStreamRequest) GetResponses 

func (x *EchoStreamRequest) GetResponses() uint64

func (*EchoStreamRequest) GetStatusCode 

func (x *EchoStreamRequest) GetStatusCode() int32

func (*EchoStreamRequest) ProtoMessage 

func (*EchoStreamRequest) ProtoMessage()

func (*EchoStreamRequest) ProtoReflect added in v0.75.0 

func (x *EchoStreamRequest) ProtoReflect() protoreflect.Message

func (*EchoStreamRequest) Reset 

func (x *EchoStreamRequest) Reset()

func (*EchoStreamRequest) String 

func (x *EchoStreamRequest) String() string

type EchoStreamResponse 

type EchoStreamResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Index   uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoStreamResponse) Descriptor deprecated 

func (*EchoStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use EchoStreamResponse.ProtoReflect.Descriptor instead.

func (*EchoStreamResponse) GetIndex 

func (x *EchoStreamResponse) GetIndex() uint64

func (*EchoStreamResponse) GetMessage 

func (x *EchoStreamResponse) GetMessage() string

func (*EchoStreamResponse) ProtoMessage 

func (*EchoStreamResponse) ProtoMessage()

func (*EchoStreamResponse) ProtoReflect added in v0.75.0 

func (x *EchoStreamResponse) ProtoReflect() protoreflect.Message

func (*EchoStreamResponse) Reset 

func (x *EchoStreamResponse) Reset()

func (*EchoStreamResponse) String 

func (x *EchoStreamResponse) String() string

type Echo_EchoStreamClient 

type Echo_EchoStreamClient interface {
	Recv() (*EchoStreamResponse, error)
	grpc.ClientStream
}

type Echo_EchoStreamServer 

type Echo_EchoStreamServer interface {
	Send(*EchoStreamResponse) error
	grpc.ServerStream
}

type UnimplementedEchoServer 

type UnimplementedEchoServer struct {
}

UnimplementedEchoServer must be embedded to have forward compatible implementations.

func (UnimplementedEchoServer) Echo 

func (UnimplementedEchoServer) Echo(context.Context, *EchoRequest) (*EchoResponse, error)

func (UnimplementedEchoServer) EchoStream 

func (UnimplementedEchoServer) EchoStream(*EchoStreamRequest, Echo_EchoStreamServer) error

type UnsafeEchoServer added in v0.75.0 

type UnsafeEchoServer interface {
	// contains filtered or unexported methods
}

UnsafeEchoServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EchoServer will result in compilation errors.

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.