lightnode

Documentation

Index

• type Container
  • func NewContainer(base cluster.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 topology.EachPeerFunc) error
  • func (c *Container) Metrics() []prometheus.Collector
  • func (c *Container) PeerInfo() topology.BinInfo
  • func (c *Container) RandomPeer(not cluster.Address) (cluster.Address, error)

Types

type Container

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

func NewContainer

func NewContainer(base cluster.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 topology.EachPeerFunc) error

func (*Container) Metrics

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

Metrics returns set of prometheus collectors.

func (*Container) PeerInfo

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

func (*Container) RandomPeer

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