discv5

Nov 14, 2023

Changes in this version

type DiscoveryV5

+ func (d *DiscoveryV5) DefaultPredicate() Predicate

+ type TestPeerDiscoverer struct

+ func NewTestPeerDiscoverer() *TestPeerDiscoverer

+ func (t *TestPeerDiscoverer) Clear()

+ func (t *TestPeerDiscoverer) HasPeer(p peer.ID) bool

+ func (t *TestPeerDiscoverer) PeerCount() int

+ func (t *TestPeerDiscoverer) Subscribe(ctx context.Context, ch <-chan service.PeerData)

Sep 17, 2023

Changes in this version

type DiscoveryV5

+ func (d *DiscoveryV5) PeerIterator(predicate ...Predicate) (enode.Iterator, error)

+ type Metrics interface

+ RecordError func(err metricsErrCategory)

type PeerConnector

+ Subscribe func(context.Context, <-chan peermanager.PeerData)

+ type Predicate func(enode.Iterator) enode.Iterator

+ func FilterCapabilities(flags wenr.WakuEnrBitfield) Predicate

+ func FilterPredicate(predicate func(*enode.Node) bool) Predicate

+ func FilterShard(cluster, index uint16) Predicate

Jun 26, 2023

Changes in this version

type DiscoveryV5

+ func (d *DiscoveryV5) FindPeersWithPredicate(ctx context.Context, predicate func(*enode.Node) bool) (enode.Iterator, error)

+ func (d *DiscoveryV5) FindPeersWithShard(ctx context.Context, cluster, index uint16) (enode.Iterator, error)

+ func (d *DiscoveryV5) Iterate(ctx context.Context, iterator enode.Iterator, ...)

type DiscoveryV5Option

+ func WithAutoFindPeers(find bool) DiscoveryV5Option

+ func WithPredicate(predicate func(*enode.Node) bool) DiscoveryV5Option

May 12, 2023

Changes in this version

type DiscoveryV5

+ func (d *DiscoveryV5) SetHost(h host.Host)

Feb 17, 2023

Changes in this version

+ var ErrNoDiscV5Listener = errors.New("no discv5 listener")

Jan 23, 2023

Changes in this version

type DiscoveryV5

+ func (d *DiscoveryV5) Iterator() (enode.Iterator, error)

+ type PeerConnector interface

+ PeerChannel func() chan<- peer.AddrInfo

Dec 21, 2022

Changes in this version

+ const MaxPeersToDiscover

+ type DiscoveryV5 struct

+ NAT nat.Interface

+ func NewDiscoveryV5(host host.Host, priv *ecdsa.PrivateKey, localnode *enode.LocalNode, ...) (*DiscoveryV5, error)

+ func (d *DiscoveryV5) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error)

+ func (d *DiscoveryV5) FindNodes(ctx context.Context, topic string, opts ...discovery.Option) ([]PeerRecord, error)

+ func (d *DiscoveryV5) FindPeers(ctx context.Context, topic string, opts ...discovery.Option) (<-chan peer.AddrInfo, error)

+ func (d *DiscoveryV5) IsStarted() bool

+ func (d *DiscoveryV5) Node() *enode.Node

+ func (d *DiscoveryV5) SetBootnodes(nodes []*enode.Node) error

+ func (d *DiscoveryV5) Start(ctx context.Context) error

+ func (d *DiscoveryV5) Stop()

+ type DiscoveryV5Option func(*discV5Parameters)

+ func DefaultOptions() []DiscoveryV5Option

+ func WithAdvertiseAddr(addr net.IP) DiscoveryV5Option

+ func WithAutoUpdate(autoUpdate bool) DiscoveryV5Option

+ func WithBootnodes(bootnodes []*enode.Node) DiscoveryV5Option

+ func WithUDPPort(port int) DiscoveryV5Option

+ type PeerRecord struct

+ Node enode.Node

+ Peer peer.AddrInfo