Documentation ¶
Index ¶
- Variables
- func RegisterEchoServer(s grpc.ServiceRegistrar, srv EchoServer)
- type EchoClient
- type EchoRequest
- func (*EchoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EchoRequest) GetMessage() string
- func (x *EchoRequest) GetRepetitions() uint32
- func (x *EchoRequest) GetStatusCode() int32
- func (*EchoRequest) ProtoMessage()
- func (x *EchoRequest) ProtoReflect() protoreflect.Message
- func (x *EchoRequest) Reset()
- func (x *EchoRequest) String() string
- type EchoResponse
- type EchoServer
- type EchoStreamRequest
- func (*EchoStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EchoStreamRequest) GetFailureIndex() int32
- func (x *EchoStreamRequest) GetInterval() *durationpb.Duration
- func (x *EchoStreamRequest) GetMessage() string
- func (x *EchoStreamRequest) GetRepetitions() uint32
- func (x *EchoStreamRequest) GetResponses() uint64
- func (x *EchoStreamRequest) GetStatusCode() int32
- func (*EchoStreamRequest) ProtoMessage()
- func (x *EchoStreamRequest) ProtoReflect() protoreflect.Message
- func (x *EchoStreamRequest) Reset()
- func (x *EchoStreamRequest) String() string
- type EchoStreamResponse
- func (*EchoStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EchoStreamResponse) GetIndex() uint64
- func (x *EchoStreamResponse) GetMessage() string
- func (*EchoStreamResponse) ProtoMessage()
- func (x *EchoStreamResponse) ProtoReflect() protoreflect.Message
- func (x *EchoStreamResponse) Reset()
- func (x *EchoStreamResponse) String() string
- type Echo_EchoStreamClient
- type Echo_EchoStreamServer
- type UnimplementedEchoServer
- type UnsafeEchoServer
Constants ¶
This section is empty.
Variables ¶
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)
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.