Documentation
¶
Overview ¶
Package proto ...
Index ¶
- Variables
- func DRPCRegisterStreams(mux drpc.Mux, impl DRPCStreamsServer) error
- func RegisterStreamsHandler(handler any) server.RegistrationFunc
- func RegisterStreamsServer(s grpc.ServiceRegistrar, srv StreamsServer)
- type CallRequest
- type CallResponse
- func (*CallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CallResponse) GetMsg() string
- func (x *CallResponse) GetPayload() []byte
- func (*CallResponse) ProtoMessage()
- func (x *CallResponse) ProtoReflect() protoreflect.Message
- func (x *CallResponse) Reset()
- func (x *CallResponse) String() string
- type DRPCStreamsClient
- type DRPCStreamsDescription
- type DRPCStreamsServer
- type DRPCStreamsUnimplementedServer
- type DRPCStreams_CallStream
- type StreamsClient
- type StreamsServer
- type UnimplementedStreamsServer
- type UnsafeStreamsServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_echo_proto protoreflect.FileDescriptor
View Source
var Streams_ServiceDesc = grpc.ServiceDesc{ ServiceName: "echo.Streams", HandlerType: (*StreamsServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Call", Handler: _Streams_Call_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "echo.proto", }
Streams_ServiceDesc is the grpc.ServiceDesc for Streams service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DRPCRegisterStreams ¶
func DRPCRegisterStreams(mux drpc.Mux, impl DRPCStreamsServer) error
func RegisterStreamsHandler ¶
func RegisterStreamsHandler(handler any) server.RegistrationFunc
RegisterStreamsHandler will return a registration function that can be provided to entrypoints as a handler registration.
func RegisterStreamsServer ¶
func RegisterStreamsServer(s grpc.ServiceRegistrar, srv StreamsServer)
Types ¶
type CallRequest ¶
type CallRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*CallRequest) Descriptor
deprecated
func (*CallRequest) Descriptor() ([]byte, []int)
Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.
func (*CallRequest) GetName ¶
func (x *CallRequest) GetName() string
func (*CallRequest) ProtoMessage ¶
func (*CallRequest) ProtoMessage()
func (*CallRequest) ProtoReflect ¶
func (x *CallRequest) ProtoReflect() protoreflect.Message
func (*CallRequest) Reset ¶
func (x *CallRequest) Reset()
func (*CallRequest) String ¶
func (x *CallRequest) String() string
type CallResponse ¶
type CallResponse struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
func (*CallResponse) Descriptor
deprecated
func (*CallResponse) Descriptor() ([]byte, []int)
Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.
func (*CallResponse) GetMsg ¶
func (x *CallResponse) GetMsg() string
func (*CallResponse) GetPayload ¶
func (x *CallResponse) GetPayload() []byte
func (*CallResponse) ProtoMessage ¶
func (*CallResponse) ProtoMessage()
func (*CallResponse) ProtoReflect ¶
func (x *CallResponse) ProtoReflect() protoreflect.Message
func (*CallResponse) Reset ¶
func (x *CallResponse) Reset()
func (*CallResponse) String ¶
func (x *CallResponse) String() string
type DRPCStreamsClient ¶
type DRPCStreamsClient interface {
DRPCConn() drpc.Conn
Call(ctx context.Context, in *CallRequest) (*CallResponse, error)
}
func NewDRPCStreamsClient ¶
func NewDRPCStreamsClient(cc drpc.Conn) DRPCStreamsClient
type DRPCStreamsDescription ¶
type DRPCStreamsDescription struct{}
func (DRPCStreamsDescription) NumMethods ¶
func (DRPCStreamsDescription) NumMethods() int
type DRPCStreamsServer ¶
type DRPCStreamsServer interface {
Call(context.Context, *CallRequest) (*CallResponse, error)
}
type DRPCStreamsUnimplementedServer ¶
type DRPCStreamsUnimplementedServer struct{}
func (*DRPCStreamsUnimplementedServer) Call ¶
func (s *DRPCStreamsUnimplementedServer) Call(context.Context, *CallRequest) (*CallResponse, error)
type DRPCStreams_CallStream ¶
type DRPCStreams_CallStream interface {
drpc.Stream
SendAndClose(*CallResponse) error
}
type StreamsClient ¶
type StreamsClient interface {
Call(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
}
StreamsClient is the client API for Streams 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 NewStreamsClient ¶
func NewStreamsClient(cc grpc.ClientConnInterface) StreamsClient
type StreamsServer ¶
type StreamsServer interface {
Call(context.Context, *CallRequest) (*CallResponse, error)
// contains filtered or unexported methods
}
StreamsServer is the server API for Streams service. All implementations must embed UnimplementedStreamsServer for forward compatibility
type UnimplementedStreamsServer ¶
type UnimplementedStreamsServer struct {
}
UnimplementedStreamsServer must be embedded to have forward compatible implementations.
func (UnimplementedStreamsServer) Call ¶
func (UnimplementedStreamsServer) Call(context.Context, *CallRequest) (*CallResponse, error)
type UnsafeStreamsServer ¶
type UnsafeStreamsServer interface {
// contains filtered or unexported methods
}
UnsafeStreamsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamsServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.