torrent2

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

type AnnounceProps struct {
	SupportAnnounceList   bool
	SupportHttpAnnounce   bool
	SupportUdpAnnounce    bool
	AnnounceToAllTiers    bool
	AnnounceToAllTrackers bool
}

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

type Peers interface {
	Seeders() int32
	Leechers() int32
	AddPeer(update SwarmUpdateRequest)
	Reset()
}

type Speeds interface {
	UploadSpeed() (bps int64)
	SetUploadSpeed(bps int64)
	Reset()
}

type Stats interface {
	Uploaded() int64
	Downloaded() int64
	Left() int64
	Corrupted() int64
	AddUploaded(int64)
	AddDownloaded(int64)
	Reset()
}

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

type Torrent interface {
	Start(props AnnounceProps, announceQueue *AnnounceQueue, dispatcher bandwidth.SpeedDispatcher)
	Stop(ctx context.Context)
	InfoHash() torrent.InfoHash
	Path() string
	ChangePath(path string)
	MoveTo(directory string) error
	// AddDataFor add interval second worth of upload to Stats.Uploaded
	AddDataFor(interval time.Duration)
}

type Tracker interface {
	Url() url.URL
	CanAnnounce(now time.Time) bool
	IsWorking() bool
	Succeed(announceHistory AnnounceHistory)
	Failed(announceHistory AnnounceHistory, backoffRatio int, retryInterval int)
	Reset()
}