discovery

Documentation

Index

• type AddrList
  • func (al *AddrList) Set(value string) error
  • func (al *AddrList) String() string
• type DHT
  • func NewDHT(d ...dht.Option) *DHT
  • func (d *DHT) FindClosePeers(ll log.StandardLogger, onlyStaticRelays bool, static ...string) func(ctx context.Context, numPeers int) <-chan peer.AddrInfo
  • func (d *DHT) Option(ctx context.Context) func(c *libp2p.Config) error
  • func (d *DHT) Rendezvous() string
  • func (d *DHT) Run(c log.StandardLogger, ctx context.Context, host host.Host) error
• type MDNS
  • func (d *MDNS) Option(ctx context.Context) func(c *libp2p.Config) error
  • func (d *MDNS) Run(l log.StandardLogger, ctx context.Context, host host.Host) error
• type Ring
  • func (r *Ring) Add(s string)

Types

type AddrList

type AddrList []maddr.Multiaddr

A new type we need for writing a custom flag parser

func (*AddrList) Set

func (al *AddrList) Set(value string) error

func (*AddrList) String

func (al *AddrList) String() string

type DHT

type DHT struct {
	OTPKey           string
	OTPInterval      int
	KeyLength        int
	RendezvousString string
	BootstrapPeers   AddrList

	RefreshDiscoveryTime time.Duration
	*dht.IpfsDHT
	// contains filtered or unexported fields
}

func NewDHT

func NewDHT(d ...dht.Option) *DHT

func (*DHT) FindClosePeers

func (d *DHT) FindClosePeers(ll log.StandardLogger, onlyStaticRelays bool, static ...string) func(ctx context.Context, numPeers int) <-chan peer.AddrInfo

func (*DHT) Option

func (d *DHT) Option(ctx context.Context) func(c *libp2p.Config) error

func (*DHT) Rendezvous

func (d *DHT) Rendezvous() string

func (*DHT) Run

func (d *DHT) Run(c log.StandardLogger, ctx context.Context, host host.Host) error

type MDNS

type MDNS struct {
	DiscoveryServiceTag string
}

func (*MDNS) Option

func (d *MDNS) Option(ctx context.Context) func(c *libp2p.Config) error

func (*MDNS) Run

func (d *MDNS) Run(l log.StandardLogger, ctx context.Context, host host.Host) error

type Ring

type Ring struct {
	Data   []string
	Length int
}

func (*Ring) Add

func (r *Ring) Add(s string)