mdns

Documentation

Index

• Variables
• type Advertiser
  • func NewAdvertiser(h host.Host) *Advertiser
  • func (a *Advertiser) Advertise(chanID int) error
  • func (p Advertiser) DiscoveryID(chanID int) string
  • func (a *Advertiser) Shutdown()
  • func (p Advertiser) TimeSlotStart() time.Time
• type Discoverer
  • func NewDiscoverer(h host.Host) *Discoverer
  • func (d *Discoverer) Discover(chanID int, handler func(info peer.AddrInfo)) error
  • func (p Discoverer) DiscoveryID(chanID int) string
  • func (d *Discoverer) SetOffset(offset time.Duration) *Discoverer
  • func (d *Discoverer) Shutdown()
  • func (p Discoverer) TimeSlotStart() time.Time

Variables

var (
	ConnThreshold    = 3
	TruncateDuration = 5 * time.Minute
)

ConnThreshold represents the minimum number of bootstrap peers we need a connection to.

Types

type Advertiser

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

func NewAdvertiser

func NewAdvertiser(h host.Host) *Advertiser

func (*Advertiser) Advertise

func (a *Advertiser) Advertise(chanID int) error

Advertise broadcasts that we're providing data for the given code.

TODO: NewMdnsService also polls for peers. This is quite chatty, so we could extract the server-only logic.

func (Advertiser) DiscoveryID

func (p Advertiser) DiscoveryID(chanID int) string

DiscoveryID returns the string, that we use to advertise via mDNS and the DHT. See chanID above for more information. Using UnixNano for testing.

func (*Advertiser) Shutdown

func (a *Advertiser) Shutdown()

func (Advertiser) TimeSlotStart

func (p Advertiser) TimeSlotStart() time.Time

TimeSlotStart returns the time when the current time slot started.f

type Discoverer

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

func NewDiscoverer

func NewDiscoverer(h host.Host) *Discoverer

func (*Discoverer) Discover

func (d *Discoverer) Discover(chanID int, handler func(info peer.AddrInfo)) error

func (Discoverer) DiscoveryID

func (p Discoverer) DiscoveryID(chanID int) string

DiscoveryID returns the string, that we use to advertise via mDNS and the DHT. See chanID above for more information. Using UnixNano for testing.

func (*Discoverer) SetOffset

func (d *Discoverer) SetOffset(offset time.Duration) *Discoverer

func (*Discoverer) Shutdown

func (d *Discoverer) Shutdown()

func (Discoverer) TimeSlotStart

func (p Discoverer) TimeSlotStart() time.Time

TimeSlotStart returns the time when the current time slot started.f