peerdb

May 21, 2024

Changes in this version

+ var ErrPeerNotFound = leveldb.ErrNotFound

+ var File_p2p_node_peerManager_peerdb_peer_info_proto protoreflect.FileDescriptor

+ type AddrInfo struct

+ func (addr *AddrInfo) ProtoDecode(protoAddr *ProtoAddrInfo) error

+ func (addr *AddrInfo) ProtoEncode() *ProtoAddrInfo

+ type PeerDB struct

+ func NewPeerDB(dbDirName string, locationName string) (*PeerDB, error)

+ func (p *PeerDB) Close() error

+ func (p *PeerDB) Delete(_ context.Context, key datastore.Key) error

+ func (p *PeerDB) Get(_ context.Context, key datastore.Key) (value []byte, err error)

+ func (p *PeerDB) GetSize(_ context.Context, key datastore.Key) (size int, err error)

+ func (p *PeerDB) Has(_ context.Context, key datastore.Key) (exists bool, err error)

+ func (p *PeerDB) Put(_ context.Context, key datastore.Key, value []byte) error

+ func (p *PeerDB) Query(ctx context.Context, q query.Query) (query.Results, error)

+ func (p *PeerDB) Sync(ctx context.Context, prefix datastore.Key) error

+ func (pdb *PeerDB) GetPeerCount() int

+ type PeerInfo struct

+ AddrInfo AddrInfo

+ Entropy uint64

+ Protected bool

+ PubKey []byte

+ func (pi *PeerInfo) ProtoDecode(ppi *ProtoPeerInfo) error

+ func (pi *PeerInfo) ProtoEncode() *ProtoPeerInfo

+ type ProtoAddrInfo struct

+ Addrs []string

+ ID string

+ func (*ProtoAddrInfo) Descriptor() ([]byte, []int)

+ func (*ProtoAddrInfo) ProtoMessage()

+ func (x *ProtoAddrInfo) GetAddrs() []string

+ func (x *ProtoAddrInfo) GetID() string

+ func (x *ProtoAddrInfo) ProtoReflect() protoreflect.Message

+ func (x *ProtoAddrInfo) Reset()

+ func (x *ProtoAddrInfo) String() string

+ type ProtoPeerInfo struct

+ AddrInfo *ProtoAddrInfo

+ Entropy uint64

+ Protected bool

+ PubKey []byte

+ func (*ProtoPeerInfo) Descriptor() ([]byte, []int)

+ func (*ProtoPeerInfo) ProtoMessage()

+ func (x *ProtoPeerInfo) GetAddrInfo() *ProtoAddrInfo

+ func (x *ProtoPeerInfo) GetEntropy() uint64

+ func (x *ProtoPeerInfo) GetProtected() bool

+ func (x *ProtoPeerInfo) GetPubKey() []byte

+ func (x *ProtoPeerInfo) ProtoReflect() protoreflect.Message

+ func (x *ProtoPeerInfo) Reset()

+ func (x *ProtoPeerInfo) String() string