discv5

Documentation

Index

• Variables
• type DiscoveryV5
  • func NewDiscoveryV5(host host.Host, priv *ecdsa.PrivateKey, localnode *enode.LocalNode, ...) (*DiscoveryV5, error)
  • func (d *DiscoveryV5) IsStarted() bool
  • func (d *DiscoveryV5) Iterator() (enode.Iterator, error)
  • 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 DefaultOptions() []DiscoveryV5Option
  • func WithAdvertiseAddr(addr []multiaddr.Multiaddr) DiscoveryV5Option
  • func WithAutoUpdate(autoUpdate bool) DiscoveryV5Option
  • func WithBootnodes(bootnodes []*enode.Node) DiscoveryV5Option
  • func WithUDPPort(port uint) DiscoveryV5Option
• type PeerConnector

Variables

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

Types

type DiscoveryV5

type DiscoveryV5 struct {
	sync.RWMutex

	NAT nat.Interface
	// contains filtered or unexported fields
}

func NewDiscoveryV5

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

func (*DiscoveryV5) IsStarted

func (d *DiscoveryV5) IsStarted() bool

func (*DiscoveryV5) Iterator

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

func (*DiscoveryV5) Node

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

func (*DiscoveryV5) SetBootnodes

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

func (*DiscoveryV5) Start

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

func (*DiscoveryV5) Stop

func (d *DiscoveryV5) Stop()

type DiscoveryV5Option

type DiscoveryV5Option func(*discV5Parameters)

func DefaultOptions

func DefaultOptions() []DiscoveryV5Option

func WithAdvertiseAddr

func WithAdvertiseAddr(addr []multiaddr.Multiaddr) DiscoveryV5Option

func WithAutoUpdate

func WithAutoUpdate(autoUpdate bool) DiscoveryV5Option

func WithBootnodes

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

func WithUDPPort

func WithUDPPort(port uint) DiscoveryV5Option

type PeerConnector

type PeerConnector interface {
	PeerChannel() chan<- peer.AddrInfo
}