peerstore

package

Go to main page

Versions in this module

v0

v0.9.0

Nov 14, 2023

Changes in this version

type WakuPeerstore

+ PeersByPubSubTopics func(pubSubTopics []string, specificPeers ...peer.ID) peer.IDSlice

type WakuPeerstoreImpl

+ func (ps *WakuPeerstoreImpl) PeersByPubSubTopics(pubSubTopics []string, specificPeers ...peer.ID) peer.IDSlice

v0.8.1

Oct 7, 2023

Changes in this version

type Origin

+ const PeerManager

type WakuPeerstore

+ RemovePubSubTopic func(p peer.ID, topic string) error

type WakuPeerstoreImpl

+ func (ps *WakuPeerstoreImpl) RemovePubSubTopic(p peer.ID, topic string) error

v0.8.0

Sep 17, 2023

Changes in this version

+ func NewWakuPeerstore(p peerstore.Peerstore) peerstore.Peerstore

+ type ConnectionFailures struct

+ type Origin int64

+ const DNSDiscovery

+ const Discv5

+ const PeerExchange

+ const Rendezvous

+ const Static

+ const Unknown

+ type WakuPeerstore interface

+ AddConnFailure func(p peer.AddrInfo)

+ AddPubSubTopic func(p peer.ID, topic string) error

+ ConnFailures func(p peer.AddrInfo) int

+ Direction func(p peer.ID) (network.Direction, error)

+ ENR func(p peer.ID) (*enode.Node, error)

+ Origin func(p peer.ID) (Origin, error)

+ PeersByOrigin func(origin Origin) peer.IDSlice

+ PeersByPubSubTopic func(pubSubTopic string) peer.IDSlice

+ PubSubTopics func(p peer.ID) ([]string, error)

+ ResetConnFailures func(p peer.AddrInfo)

+ SetDirection func(p peer.ID, direction network.Direction) error

+ SetENR func(p peer.ID, enr *enode.Node) error

+ SetOrigin func(p peer.ID, origin Origin) error

+ SetPubSubTopics func(p peer.ID, topics []string) 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) AddPubSubTopic(p peer.ID, topic string) 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) Direction(p peer.ID) (network.Direction, error)

+ func (ps *WakuPeerstoreImpl) ENR(p peer.ID) (*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, error)

+ func (ps *WakuPeerstoreImpl) PeerInfo(peerID peer.ID) peer.AddrInfo

+ func (ps *WakuPeerstoreImpl) Peers() peer.IDSlice

+ func (ps *WakuPeerstoreImpl) PeersByOrigin(expectedOrigin Origin) peer.IDSlice

+ func (ps *WakuPeerstoreImpl) PeersByPubSubTopic(pubSubTopic string) 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) PubSubTopics(p peer.ID) ([]string, error)

+ 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) SetDirection(p peer.ID, direction network.Direction) error

+ 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) SetPubSubTopics(p peer.ID, topics []string) 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL