Versions in this module Expand all Collapse all v0 v0.7.0 Jun 26, 2023 Changes in this version + func NewWakuPeerstore(p peerstore.Peerstore) peerstore.Peerstore + type ConnectionFailures struct + type Origin int64 + const Discv5 + const DnsDiscovery + const PeerExchange + const Rendezvous + const Static + const Unknown + type WakuPeerstore interface + AddConnFailure func(p peer.AddrInfo) + ConnFailures func(p peer.AddrInfo) int + ENR func(p peer.ID, origin Origin) (*enode.Node, error) + Origin func(p peer.ID, origin Origin) (Origin, error) + PeersByOrigin func(origin Origin) peer.IDSlice + ResetConnFailures func(p peer.AddrInfo) + SetENR func(p peer.ID, enr *enode.Node) error + SetOrigin func(p peer.ID, origin Origin) error + type WakuPeerstoreImpl struct + func (ps *WakuPeerstoreImpl) AddAddr(p peer.ID, addr ma.Multiaddr, ttl time.Duration) + func (ps *WakuPeerstoreImpl) AddAddrs(p peer.ID, addrs []ma.Multiaddr, ttl time.Duration) + func (ps *WakuPeerstoreImpl) AddConnFailure(p peer.AddrInfo) + func (ps *WakuPeerstoreImpl) AddPrivKey(p peer.ID, privk ic.PrivKey) error + func (ps *WakuPeerstoreImpl) AddProtocols(p peer.ID, proto ...protocol.ID) error + func (ps *WakuPeerstoreImpl) AddPubKey(p peer.ID, pubk ic.PubKey) error + func (ps *WakuPeerstoreImpl) AddrStream(ctx context.Context, p peer.ID) <-chan ma.Multiaddr + func (ps *WakuPeerstoreImpl) Addrs(p peer.ID) []ma.Multiaddr + func (ps *WakuPeerstoreImpl) ClearAddrs(p peer.ID) + func (ps *WakuPeerstoreImpl) Close() error + func (ps *WakuPeerstoreImpl) ConnFailures(p peer.AddrInfo) int + func (ps *WakuPeerstoreImpl) ConsumePeerRecord(s *record.Envelope, ttl time.Duration) (accepted bool, err error) + func (ps *WakuPeerstoreImpl) ENR(p peer.ID, origin Origin) (*enode.Node, error) + func (ps *WakuPeerstoreImpl) FirstSupportedProtocol(p peer.ID, proto ...protocol.ID) (protocol.ID, error) + func (ps *WakuPeerstoreImpl) Get(p peer.ID, key string) (interface{}, error) + func (ps *WakuPeerstoreImpl) GetPeerRecord(p peer.ID) *record.Envelope + func (ps *WakuPeerstoreImpl) GetProtocols(p peer.ID) ([]protocol.ID, error) + func (ps *WakuPeerstoreImpl) LatencyEWMA(p peer.ID) time.Duration + func (ps *WakuPeerstoreImpl) Origin(p peer.ID, origin Origin) (Origin, error) + func (ps *WakuPeerstoreImpl) PeerInfo(peerID peer.ID) peer.AddrInfo + func (ps *WakuPeerstoreImpl) Peers() peer.IDSlice + func (ps *WakuPeerstoreImpl) PeersByOrigin(origin Origin) peer.IDSlice + func (ps *WakuPeerstoreImpl) PeersWithAddrs() peer.IDSlice + func (ps *WakuPeerstoreImpl) PeersWithKeys() peer.IDSlice + func (ps *WakuPeerstoreImpl) PrivKey(p peer.ID) ic.PrivKey + func (ps *WakuPeerstoreImpl) PubKey(p peer.ID) ic.PubKey + func (ps *WakuPeerstoreImpl) Put(p peer.ID, key string, val interface{}) error + func (ps *WakuPeerstoreImpl) RecordLatency(p peer.ID, t time.Duration) + func (ps *WakuPeerstoreImpl) RemovePeer(p peer.ID) + func (ps *WakuPeerstoreImpl) RemoveProtocols(p peer.ID, proto ...protocol.ID) error + func (ps *WakuPeerstoreImpl) ResetConnFailures(p peer.AddrInfo) + func (ps *WakuPeerstoreImpl) SetAddr(p peer.ID, addr ma.Multiaddr, ttl time.Duration) + func (ps *WakuPeerstoreImpl) SetAddrs(p peer.ID, addrs []ma.Multiaddr, ttl time.Duration) + func (ps *WakuPeerstoreImpl) SetENR(p peer.ID, enr *enode.Node) error + func (ps *WakuPeerstoreImpl) SetOrigin(p peer.ID, origin Origin) error + func (ps *WakuPeerstoreImpl) SetProtocols(p peer.ID, proto ...protocol.ID) error + func (ps *WakuPeerstoreImpl) SupportsProtocols(p peer.ID, proto ...protocol.ID) ([]protocol.ID, error) + func (ps *WakuPeerstoreImpl) UpdateAddrs(p peer.ID, oldTTL time.Duration, newTTL time.Duration)
Go to main page