discovery

Documentation

Index

• func RunForever(ctx context.Context, srv Service, params Params)
• type AddrParser
• type AddressBook
• type AnnounceFunc
• type FindFunc
• type Params
• type PollingDiscovery
  • func (s *PollingDiscovery) Run(ctx context.Context, params Params) error
• type Service
• type TransportAddr

Functions

func RunForever

func RunForever(ctx context.Context, srv Service, params Params)

Types

type AddrParser

type AddrParser = p2p.AddrParser[TransportAddr]

type AddressBook

type AddressBook interface {
	SetAddrs(x inet256.Addr, addrs []TransportAddr)
	ListPeers() []inet256.Addr
}

type AnnounceFunc

type AnnounceFunc = func(ctx context.Context, privateKey inet256.PrivateKey, addrs []string, ttl time.Duration) error

type FindFunc

type FindFunc = func(ctx context.Context, x inet256.Addr) ([]string, error)

type Params

type Params struct {
	// Announcing
	PrivateKey    inet256.PrivateKey
	LocalID       inet256.Addr
	GetLocalAddrs func() []TransportAddr

	// Finding
	AddressBook AddressBook
	AddrParser  p2p.AddrParser[TransportAddr]
}

type PollingDiscovery

type PollingDiscovery struct {
	Period   time.Duration
	Announce AnnounceFunc
	Find     FindFunc
}

func (*PollingDiscovery) Run

func (s *PollingDiscovery) Run(ctx context.Context, params Params) error

type Service

type Service interface {
	Run(ctx context.Context, params Params) error
}

type TransportAddr

type TransportAddr = multiswarm.Addr