discv5

Documentation

Index

• Variables
• type DiscoveryV5
  • func NewDiscoveryV5(priv *ecdsa.PrivateKey, localnode *enode.LocalNode, ...) (*DiscoveryV5, error)
  • func (d *DiscoveryV5) DefaultPredicate() Predicate
  • func (d *DiscoveryV5) Iterate(ctx context.Context, iterator enode.Iterator, ...)
  • func (d *DiscoveryV5) Node() *enode.Node
  • func (d *DiscoveryV5) PeerIterator(predicate ...Predicate) (enode.Iterator, error)
  • func (d *DiscoveryV5) SetBootnodes(nodes []*enode.Node) error
  • func (d *DiscoveryV5) SetHost(h host.Host)
  • func (d *DiscoveryV5) Start(ctx context.Context) error
  • func (d *DiscoveryV5) Stop()
• type DiscoveryV5Option
  • func DefaultOptions() []DiscoveryV5Option
  • func WithAdvertiseAddr(addr []multiaddr.Multiaddr) DiscoveryV5Option
  • func WithAutoFindPeers(find bool) DiscoveryV5Option
  • func WithAutoUpdate(autoUpdate bool) DiscoveryV5Option
  • func WithBootnodes(bootnodes []*enode.Node) DiscoveryV5Option
  • func WithPredicate(predicate func(*enode.Node) bool) DiscoveryV5Option
  • func WithUDPPort(port uint) DiscoveryV5Option
• type Metrics
• type PeerConnector
• type Predicate
  • func FilterCapabilities(flags wenr.WakuEnrBitfield) Predicate
  • func FilterPredicate(predicate func(*enode.Node) bool) Predicate
  • func FilterShard(cluster, index uint16) Predicate
• type TestPeerDiscoverer
  • 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)

Variables

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

Types

type DiscoveryV5

type DiscoveryV5 struct {
	NAT nat.Interface

	*service.CommonDiscoveryService
	// contains filtered or unexported fields
}

func NewDiscoveryV5

func NewDiscoveryV5(priv *ecdsa.PrivateKey, localnode *enode.LocalNode, peerConnector PeerConnector, reg prometheus.Registerer, log *zap.Logger, opts ...DiscoveryV5Option) (*DiscoveryV5, error)

NewDiscoveryV5 returns a new instance of a DiscoveryV5 struct

func (*DiscoveryV5) DefaultPredicate

func (d *DiscoveryV5) DefaultPredicate() Predicate

DefaultPredicate contains the conditions to be applied when filtering peers discovered via discv5

func (*DiscoveryV5) Iterate

func (d *DiscoveryV5) Iterate(ctx context.Context, iterator enode.Iterator, onNode func(*enode.Node, peer.AddrInfo) error)

func (*DiscoveryV5) Node

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

func (*DiscoveryV5) PeerIterator

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

PeerIterator gets random nodes from DHT via discv5 listener. Used for caching enr address in peerExchange Used for connecting to peers in discovery_connector

func (*DiscoveryV5) SetBootnodes

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

SetBootnodes is used to setup the bootstrap nodes to use for discovering new peers

func (*DiscoveryV5) SetHost

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

Sets the host to be able to mount or consume a protocol

func (*DiscoveryV5) Start

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

only works if the discovery v5 hasn't been started yet.

func (*DiscoveryV5) Stop

func (d *DiscoveryV5) Stop()

Stop is a function that stops the execution of DiscV5. only works if the discovery v5 is in running state so we can assume that cancel method is set

type DiscoveryV5Option

type DiscoveryV5Option func(*discV5Parameters)

func DefaultOptions

func DefaultOptions() []DiscoveryV5Option

DefaultOptions contains the default list of options used when setting up DiscoveryV5

func WithAdvertiseAddr

func WithAdvertiseAddr(addr []multiaddr.Multiaddr) DiscoveryV5Option

func WithAutoFindPeers

func WithAutoFindPeers(find bool) DiscoveryV5Option

func WithAutoUpdate

func WithAutoUpdate(autoUpdate bool) DiscoveryV5Option

func WithBootnodes

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

WithBootnodes is an option used to specify the bootstrap nodes to use with DiscV5

func WithPredicate

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

func WithUDPPort

func WithUDPPort(port uint) DiscoveryV5Option

type Metrics

type Metrics interface {
	RecordError(err metricsErrCategory)
}

Metrics exposes the functions required to update prometheus metrics for discv5 protocol

type PeerConnector

type PeerConnector interface {
	Subscribe(context.Context, <-chan service.PeerData)
}

PeerConnector will subscribe to a channel containing the information for all peers found by this discovery protocol

type Predicate

type Predicate func(enode.Iterator) enode.Iterator

Predicate is a function that is applied to an iterator to filter the nodes to be retrieved according to some logic

func FilterCapabilities

func FilterCapabilities(flags wenr.WakuEnrBitfield) Predicate

FilterCapabilities creates a Predicate to filter nodes that support specific protocols

func FilterPredicate

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

FilterPredicate is to create a Predicate using a custom function

func FilterShard

func FilterShard(cluster, index uint16) Predicate

FilterShard creates a Predicate that filters nodes that belong to a specific shard

type TestPeerDiscoverer

type TestPeerDiscoverer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TestPeerDiscoverer is mock peer discoverer for testing

func NewTestPeerDiscoverer

func NewTestPeerDiscoverer() *TestPeerDiscoverer

NewTestPeerDiscoverer is a constructor for TestPeerDiscoverer

func (*TestPeerDiscoverer) Clear

func (t *TestPeerDiscoverer) Clear()

Clear is for clearing the peer discoverer

func (*TestPeerDiscoverer) HasPeer

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

HasPeer is for checking if a peer is present in peer discoverer

func (*TestPeerDiscoverer) PeerCount

func (t *TestPeerDiscoverer) PeerCount() int

PeerCount is for getting the number of peers in peer discoverer

func (*TestPeerDiscoverer) Subscribe

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

Subscribe is for subscribing to peer discoverer