Versions in this module Expand all Collapse all v0 v0.12.4 Jul 29, 2021 v0.12.3 Jul 29, 2021 Changes in this version + var ErrIntOverflowDht = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDht = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDht = fmt.Errorf("proto: unexpected end of group") + var Message_ConnectionType_name = map[int32]string + var Message_ConnectionType_value = map[string]int32 + var Message_MessageType_name = map[int32]string + var Message_MessageType_value = map[string]int32 + func Connectedness(c Message_ConnectionType) network.Connectedness + func PBPeerToPeerInfo(pbp Message_Peer) peer.AddrInfo + func PBPeersToPeerInfos(pbps []Message_Peer) []*peer.AddrInfo + type Message struct + CloserPeers []Message_Peer + ClusterLevelRaw int32 + Key []byte + ProviderPeers []Message_Peer + Record *pb.Record + Type Message_MessageType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewMessage(typ Message_MessageType, key []byte, level int) *Message + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetCloserPeers() []Message_Peer + func (m *Message) GetClusterLevel() int + func (m *Message) GetClusterLevelRaw() int32 + func (m *Message) GetKey() []byte + func (m *Message) GetProviderPeers() []Message_Peer + func (m *Message) GetRecord() *pb.Record + func (m *Message) GetType() Message_MessageType + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) SetClusterLevel(level int) + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type MessageSender interface + SendMessage func(ctx context.Context, p peer.ID, pmes *Message) error + SendRequest func(ctx context.Context, p peer.ID, pmes *Message) (*Message, error) + type Message_ConnectionType int32 + const Message_CANNOT_CONNECT + const Message_CAN_CONNECT + const Message_CONNECTED + const Message_NOT_CONNECTED + func ConnectionType(c network.Connectedness) Message_ConnectionType + func (Message_ConnectionType) EnumDescriptor() ([]byte, []int) + func (x Message_ConnectionType) String() string + type Message_MessageType int32 + const Message_ADD_PROVIDER + const Message_FIND_NODE + const Message_GET_PROVIDERS + const Message_GET_VALUE + const Message_PING + const Message_PUT_VALUE + func (Message_MessageType) EnumDescriptor() ([]byte, []int) + func (x Message_MessageType) String() string + type Message_Peer struct + Addrs [][]byte + Connection Message_ConnectionType + Id byteString + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func PeerInfosToPBPeers(n network.Network, peers []peer.AddrInfo) []Message_Peer + func PeerRoutingInfosToPBPeers(peers []PeerRoutingInfo) []Message_Peer + func RawPeerInfosToPBPeers(peers []peer.AddrInfo) []Message_Peer + func (*Message_Peer) Descriptor() ([]byte, []int) + func (*Message_Peer) ProtoMessage() + func (m *Message_Peer) Addresses() []ma.Multiaddr + func (m *Message_Peer) GetAddrs() [][]byte + func (m *Message_Peer) GetConnection() Message_ConnectionType + func (m *Message_Peer) Marshal() (dAtA []byte, err error) + func (m *Message_Peer) MarshalTo(dAtA []byte) (int, error) + func (m *Message_Peer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message_Peer) Reset() + func (m *Message_Peer) Size() (n int) + func (m *Message_Peer) String() string + func (m *Message_Peer) Unmarshal(dAtA []byte) error + func (m *Message_Peer) XXX_DiscardUnknown() + func (m *Message_Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message_Peer) XXX_Merge(src proto.Message) + func (m *Message_Peer) XXX_Size() int + func (m *Message_Peer) XXX_Unmarshal(b []byte) error + type PeerRoutingInfo struct + type ProtocolMessenger struct + func NewProtocolMessenger(msgSender MessageSender, opts ...ProtocolMessengerOption) (*ProtocolMessenger, error) + func (pm *ProtocolMessenger) GetClosestPeers(ctx context.Context, p peer.ID, id peer.ID) ([]*peer.AddrInfo, error) + func (pm *ProtocolMessenger) GetProviders(ctx context.Context, p peer.ID, key multihash.Multihash) ([]*peer.AddrInfo, []*peer.AddrInfo, error) + func (pm *ProtocolMessenger) GetValue(ctx context.Context, p peer.ID, key string) (*recpb.Record, []*peer.AddrInfo, error) + func (pm *ProtocolMessenger) Ping(ctx context.Context, p peer.ID) error + func (pm *ProtocolMessenger) PutProvider(ctx context.Context, p peer.ID, key multihash.Multihash, host host.Host) error + func (pm *ProtocolMessenger) PutValue(ctx context.Context, p peer.ID, rec *recpb.Record) error + type ProtocolMessengerOption func(*ProtocolMessenger) error + func WithValidator(validator record.Validator) ProtocolMessengerOption