bootnode

Documentation

Index

• type BootNodes
• type Container
  • func NewContainer(base boson.Address) *Container
  • func (c *Container) Connected(ctx context.Context, peer p2p.Peer)
  • func (c *Container) Count() int
  • func (c *Container) Disconnected(peer p2p.Peer)
  • func (c *Container) EachPeer(pf model.EachPeerFunc) error
  • func (c *Container) Metrics() []prometheus.Collector
  • func (c *Container) PeerInfo() model.BinInfo
  • func (c *Container) RandomPeer(not boson.Address) (boson.Address, error)

Types

type BootNodes

type BootNodes interface {
	Connected(context.Context, p2p.Peer)
	Disconnected(p2p.Peer)
	Count() int
	RandomPeer(boson.Address) (boson.Address, error)
	EachPeer(pf model.EachPeerFunc) error
}

type Container

type Container struct {
	// contains filtered or unexported fields
}

func NewContainer

func NewContainer(base boson.Address) *Container

func (*Container) Connected

func (c *Container) Connected(ctx context.Context, peer p2p.Peer)

func (*Container) Count

func (c *Container) Count() int

func (*Container) Disconnected

func (c *Container) Disconnected(peer p2p.Peer)

func (*Container) EachPeer

func (c *Container) EachPeer(pf model.EachPeerFunc) error

func (*Container) Metrics

func (c *Container) Metrics() []prometheus.Collector

Metrics returns set of prometheus collectors.

func (*Container) PeerInfo

func (c *Container) PeerInfo() model.BinInfo

func (*Container) RandomPeer

func (c *Container) RandomPeer(not boson.Address) (boson.Address, error)