concurrent

Jun 21, 2026

Changes in this version

type ActiveTask

+ SharedMaxOffsetMu sync.RWMutex

Jun 15, 2026

Changes in this version

type ActiveTask

+ WaitingOnLimiter atomic.Bool

type ConcurrentDownloader

+ Limiter types.ByteLimiter

+ RateLimitBps int64

+ RateLimitSet bool

Apr 24, 2026

Changes in this version

type ConcurrentDownloader

+ TotalSize int64

Apr 2, 2026

Changes in this version

+ type ActiveTask struct

+ Cancel context.CancelFunc

+ CurrentOffset atomic.Int64

+ Hedged atomic.Int32

+ LastActivity atomic.Int64

+ SharedMaxOffset *atomic.Int64

+ Speed float64

+ SpeedMu sync.Mutex

+ StartTime time.Time

+ StopAt atomic.Int64

+ Task types.Task

+ WindowBytes atomic.Int64

+ WindowStart time.Time

+ func (at *ActiveTask) GetSpeed() float64

+ func (at *ActiveTask) RemainingBytes() int64

+ func (at *ActiveTask) RemainingTask() *types.Task

+ type ConcurrentDownloader struct

+ DestPath string

+ Headers map[string]string

+ ID string

+ ProgressChan chan<- any

+ Runtime *types.RuntimeConfig

+ State *types.ProgressState

+ URL string

+ func NewConcurrentDownloader(id string, progressCh chan<- any, progState *types.ProgressState, ...) *ConcurrentDownloader

+ func (d *ConcurrentDownloader) Download(ctx context.Context, rawurl string, candidateMirrors []string, ...) error

+ func (d *ConcurrentDownloader) HedgeWork(queue *TaskQueue) bool

+ func (d *ConcurrentDownloader) ReportMirrorError(url string)

+ func (d *ConcurrentDownloader) StealWork(queue *TaskQueue) bool

+ type TaskQueue struct

+ func NewTaskQueue() *TaskQueue

+ func (q *TaskQueue) Close()

+ func (q *TaskQueue) DrainRemaining() []types.Task

+ func (q *TaskQueue) IdleWorkers() int64

+ func (q *TaskQueue) Len() int

+ func (q *TaskQueue) Pop() (types.Task, bool)

+ func (q *TaskQueue) Push(t types.Task)

+ func (q *TaskQueue) PushMultiple(tasks []types.Task)