Documentation
¶
Index ¶
- Variables
- func RegisterTransferServer(s grpc.ServiceRegistrar, srv TransferServer)
- type Chunk
- type Info
- type Packet
- type TransferClient
- type TransferServer
- type Transfer_ReceiveClient
- type Transfer_ReceiveServer
- type Transfer_SendClient
- type Transfer_SendServer
- type UnimplementedTransferServer
- type UnsafeTransferServer
Constants ¶
This section is empty.
Variables ¶
var File_io_proto protoreflect.FileDescriptor
var Transfer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Io.Transfer", HandlerType: (*TransferServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Receive", Handler: _Transfer_Receive_Handler, ServerStreams: true, }, { StreamName: "Send", Handler: _Transfer_Send_Handler, ClientStreams: true, }, }, Metadata: "io.proto", }
Transfer_ServiceDesc is the grpc.ServiceDesc for Transfer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTransferServer ¶
func RegisterTransferServer(s grpc.ServiceRegistrar, srv TransferServer)
Types ¶
type Chunk ¶
type Chunk struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*Chunk) Descriptor
deprecated
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) ProtoReflect ¶
func (x *Chunk) ProtoReflect() protoreflect.Message
type Info ¶
type Info struct {
Msg *anypb.Any `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
func (*Info) Descriptor
deprecated
func (*Info) ProtoMessage ¶
func (*Info) ProtoMessage()
func (*Info) ProtoReflect ¶
func (x *Info) ProtoReflect() protoreflect.Message
type Packet ¶
type Packet struct {
Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
Chunk *Chunk `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
// contains filtered or unexported fields
}
func (*Packet) Descriptor
deprecated
func (*Packet) ProtoMessage ¶
func (*Packet) ProtoMessage()
func (*Packet) ProtoReflect ¶
func (x *Packet) ProtoReflect() protoreflect.Message
type TransferClient ¶
type TransferClient interface {
Receive(ctx context.Context, in *Info, opts ...grpc.CallOption) (Transfer_ReceiveClient, error)
Send(ctx context.Context, opts ...grpc.CallOption) (Transfer_SendClient, error)
}
TransferClient is the client API for Transfer 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 NewTransferClient ¶
func NewTransferClient(cc grpc.ClientConnInterface) TransferClient
type TransferServer ¶
type TransferServer interface {
Receive(*Info, Transfer_ReceiveServer) error
Send(Transfer_SendServer) error
// contains filtered or unexported methods
}
TransferServer is the server API for Transfer service. All implementations must embed UnimplementedTransferServer for forward compatibility
type Transfer_ReceiveClient ¶
type Transfer_ReceiveClient interface {
Recv() (*Packet, error)
grpc.ClientStream
}
type Transfer_ReceiveServer ¶
type Transfer_ReceiveServer interface {
Send(*Packet) error
grpc.ServerStream
}
type Transfer_SendClient ¶
type Transfer_SendServer ¶
type UnimplementedTransferServer ¶
type UnimplementedTransferServer struct {
}
UnimplementedTransferServer must be embedded to have forward compatible implementations.
func (UnimplementedTransferServer) Receive ¶
func (UnimplementedTransferServer) Receive(*Info, Transfer_ReceiveServer) error
func (UnimplementedTransferServer) Send ¶
func (UnimplementedTransferServer) Send(Transfer_SendServer) error
type UnsafeTransferServer ¶
type UnsafeTransferServer interface {
// contains filtered or unexported methods
}
UnsafeTransferServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransferServer will result in compilation errors.
Source Files