dial

type ConnectionRequest struct {
	Service  *api.ServiceAddress
	PeerID   peer.ID
	PeerAddr multiaddr.Multiaddr
}

type Connector interface {
	Connect(context.Context, *ConnectionRequest) (message.Stream, error)
}

type DiscoveredLocal func(context.Context) (message.Stream, error)

type DiscoveredPeers <-chan peer.AddrInfo

type Discoverer interface {
	Discover(context.Context, *DiscoveryRequest) (DiscoveryResponse, error)
}

type DiscoveryRequest struct {
	Network string
	Service *api.ServiceAddress
	Limit   int
	Timeout time.Duration
}

type DiscoveryResponse interface {
	// contains filtered or unexported methods
}

type Option interface {
	// contains filtered or unexported methods
}

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

type PersistentTrackerOptions struct {
	Network          string
	Filename         string
	Host             Connector
	Peers            Discoverer
	PersistFrequency time.Duration
	ScanFrequency    time.Duration
}

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

type Tracker interface {
	Mark(peer peer.ID, service multiaddr.Multiaddr, status api.KnownPeerStatus)
	Status(peer peer.ID, service multiaddr.Multiaddr) api.KnownPeerStatus
	Next(service multiaddr.Multiaddr, status api.KnownPeerStatus) (peer.ID, bool)
	All(service multiaddr.Multiaddr, status api.KnownPeerStatus) []peer.ID
}