discovery

Documentation

Index

• type Discovery
  • func NewDiscovery(h host.Host, d core.Discovery, peersLimit uint, ...) *Discovery
  • func (d *Discovery) Advertise(ctx context.Context)
  • func (d *Discovery) EnsurePeers(ctx context.Context)

Types

type Discovery

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

Discovery combines advertise and discover services and allows to store discovered nodes.

func NewDiscovery

func NewDiscovery(
	h host.Host,
	d core.Discovery,
	peersLimit uint,
	discInterval,
	advertiseInterval time.Duration,
) *Discovery

NewDiscovery constructs a new discovery.

func (*Discovery) Advertise

func (d *Discovery) Advertise(ctx context.Context)

Advertise is a utility function that persistently advertises a service through an Advertiser.

func (*Discovery) EnsurePeers

func (d *Discovery) EnsurePeers(ctx context.Context)

EnsurePeers ensures we always have 'peerLimit' connected peers. It starts peer discovery every 30 seconds until peer cache reaches peersLimit. Discovery is restarted if any previously connected peers disconnect.