Versions in this module Expand all Collapse all v0 v0.4.0 Oct 8, 2023 Changes in this version + var File_blachris_arpcnet_v1_link_service_proto protoreflect.FileDescriptor + var File_blachris_arpcnet_v1_rpcframe_proto protoreflect.FileDescriptor + var LinkService_ServiceDesc = grpc.ServiceDesc + func RegisterLinkServiceServer(s grpc.ServiceRegistrar, srv LinkServiceServer) + type Announce struct + DeadlineUnixMs uint64 + Id uint64 + Name []byte + Value *Metric + func (*Announce) Descriptor() ([]byte, []int) + func (*Announce) ProtoMessage() + func (x *Announce) GetDeadlineUnixMs() uint64 + func (x *Announce) GetId() uint64 + func (x *Announce) GetName() []byte + func (x *Announce) GetValue() *Metric + func (x *Announce) ProtoReflect() protoreflect.Message + func (x *Announce) Reset() + func (x *Announce) String() string + type DownData struct + Chunk []byte + Remaining uint32 + func (*DownData) Descriptor() ([]byte, []int) + func (*DownData) ProtoMessage() + func (x *DownData) GetChunk() []byte + func (x *DownData) GetRemaining() uint32 + func (x *DownData) ProtoReflect() protoreflect.Message + func (x *DownData) Reset() + func (x *DownData) String() string + type DownFinish struct + Message string + Metadata *MD + Status uint32 + func (*DownFinish) Descriptor() ([]byte, []int) + func (*DownFinish) ProtoMessage() + func (x *DownFinish) GetMessage() string + func (x *DownFinish) GetMetadata() *MD + func (x *DownFinish) GetStatus() uint32 + func (x *DownFinish) ProtoReflect() protoreflect.Message + func (x *DownFinish) Reset() + func (x *DownFinish) String() string + type DownResponse struct + Metadata *MD + func (*DownResponse) Descriptor() ([]byte, []int) + func (*DownResponse) ProtoMessage() + func (x *DownResponse) GetMetadata() *MD + func (x *DownResponse) ProtoReflect() protoreflect.Message + func (x *DownResponse) Reset() + func (x *DownResponse) String() string + type LinkFrame struct + Type isLinkFrame_Type + func (*LinkFrame) Descriptor() ([]byte, []int) + func (*LinkFrame) ProtoMessage() + func (m *LinkFrame) GetType() isLinkFrame_Type + func (x *LinkFrame) GetAnnounce() *Announce + func (x *LinkFrame) GetQuery() *Query + func (x *LinkFrame) GetRpcFrame() *RPCFrame + func (x *LinkFrame) ProtoReflect() protoreflect.Message + func (x *LinkFrame) Reset() + func (x *LinkFrame) String() string + type LinkFrame_Announce struct + Announce *Announce + type LinkFrame_Query struct + Query *Query + type LinkFrame_RpcFrame struct + RpcFrame *RPCFrame + type LinkServiceClient interface + Link func(ctx context.Context, opts ...grpc.CallOption) (LinkService_LinkClient, error) + func NewLinkServiceClient(cc grpc.ClientConnInterface) LinkServiceClient + type LinkServiceServer interface + Link func(LinkService_LinkServer) error + type LinkService_LinkClient interface + Recv func() (*LinkFrame, error) + Send func(*LinkFrame) error + type LinkService_LinkServer interface + Recv func() (*LinkFrame, error) + Send func(*LinkFrame) error + type MD struct + KvPairs []string + func (*MD) Descriptor() ([]byte, []int) + func (*MD) ProtoMessage() + func (x *MD) GetKvPairs() []string + func (x *MD) ProtoReflect() protoreflect.Message + func (x *MD) Reset() + func (x *MD) String() string + type Metric struct + Hops int32 + func (*Metric) Descriptor() ([]byte, []int) + func (*Metric) ProtoMessage() + func (x *Metric) GetHops() int32 + func (x *Metric) ProtoReflect() protoreflect.Message + func (x *Metric) Reset() + func (x *Metric) String() string + type Query struct + DeadlineUnixMs uint64 + Id uint64 + Name []byte + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (x *Query) GetDeadlineUnixMs() uint64 + func (x *Query) GetId() uint64 + func (x *Query) GetName() []byte + func (x *Query) ProtoReflect() protoreflect.Message + func (x *Query) Reset() + func (x *Query) String() string + type RPCFrame struct + Id uint64 + Type isRPCFrame_Type + func (*RPCFrame) Descriptor() ([]byte, []int) + func (*RPCFrame) ProtoMessage() + func (m *RPCFrame) GetType() isRPCFrame_Type + func (x *RPCFrame) GetDownData() *DownData + func (x *RPCFrame) GetDownFinish() *DownFinish + func (x *RPCFrame) GetDownResp() *DownResponse + func (x *RPCFrame) GetId() uint64 + func (x *RPCFrame) GetUpCancel() *UpCancel + func (x *RPCFrame) GetUpClose() *UpClose + func (x *RPCFrame) GetUpData() *UpData + func (x *RPCFrame) GetUpStart() *UpStart + func (x *RPCFrame) ProtoReflect() protoreflect.Message + func (x *RPCFrame) Reset() + func (x *RPCFrame) String() string + type RPCFrame_DownData struct + DownData *DownData + type RPCFrame_DownFinish struct + DownFinish *DownFinish + type RPCFrame_DownResp struct + DownResp *DownResponse + type RPCFrame_UpCancel struct + UpCancel *UpCancel + type RPCFrame_UpClose struct + UpClose *UpClose + type RPCFrame_UpData struct + UpData *UpData + type RPCFrame_UpStart struct + UpStart *UpStart + type UnimplementedLinkServiceServer struct + func (UnimplementedLinkServiceServer) Link(LinkService_LinkServer) error + type UnsafeLinkServiceServer interface + type UpCancel struct + Message string + func (*UpCancel) Descriptor() ([]byte, []int) + func (*UpCancel) ProtoMessage() + func (x *UpCancel) GetMessage() string + func (x *UpCancel) ProtoReflect() protoreflect.Message + func (x *UpCancel) Reset() + func (x *UpCancel) String() string + type UpClose struct + func (*UpClose) Descriptor() ([]byte, []int) + func (*UpClose) ProtoMessage() + func (x *UpClose) ProtoReflect() protoreflect.Message + func (x *UpClose) Reset() + func (x *UpClose) String() string + type UpData struct + Chunk []byte + Remaining uint32 + func (*UpData) Descriptor() ([]byte, []int) + func (*UpData) ProtoMessage() + func (x *UpData) GetChunk() []byte + func (x *UpData) GetRemaining() uint32 + func (x *UpData) ProtoReflect() protoreflect.Message + func (x *UpData) Reset() + func (x *UpData) String() string + type UpStart struct + DestinationId []byte + Metadata *MD + Properties map[string][]byte + SourceId []byte + func (*UpStart) Descriptor() ([]byte, []int) + func (*UpStart) ProtoMessage() + func (x *UpStart) GetDestinationId() []byte + func (x *UpStart) GetMetadata() *MD + func (x *UpStart) GetProperties() map[string][]byte + func (x *UpStart) GetSourceId() []byte + func (x *UpStart) ProtoReflect() protoreflect.Message + func (x *UpStart) Reset() + func (x *UpStart) String() string