announcer

Jan 25, 2019

Changes in this version

+ type DHTAnnouncer struct

+ func NewDHTAnnouncer() *DHTAnnouncer

+ func (a *DHTAnnouncer) Close()

+ func (a *DHTAnnouncer) NeedMorePeers(val bool)

+ func (a *DHTAnnouncer) Run(announceFunc func(), interval, minInterval time.Duration, l logger.Logger)

+ type PeriodicalAnnouncer struct

+ HasAnnounced bool

+ Tracker tracker.Tracker

+ func NewPeriodicalAnnouncer(trk tracker.Tracker, numWant int, minInterval time.Duration, ...) *PeriodicalAnnouncer

+ func (a *PeriodicalAnnouncer) Close()

+ func (a *PeriodicalAnnouncer) NeedMorePeers(val bool)

+ func (a *PeriodicalAnnouncer) Run()

+ func (a *PeriodicalAnnouncer) Stats() Stats

+ type Request struct

+ Cancel chan struct{}

+ Response chan Response

+ type Response struct

+ Torrent tracker.Torrent

+ type Stats struct

+ Error error

+ Leechers int

+ Seeders int

+ Status Status

+ type Status int

+ const Contacting

+ const NotContactedYet

+ const NotWorking

+ const Working

+ type StopAnnouncer struct

+ func NewStopAnnouncer(trackers []tracker.Tracker, tra tracker.Torrent, timeout time.Duration, ...) *StopAnnouncer

+ func (a *StopAnnouncer) Close()

+ func (a *StopAnnouncer) Run()