types

package

Go to main page

Versions in this module

v0

v0.10.0

Jun 21, 2026

Changes in this version

type Task

+ func (t *Task) GobDecode(data []byte) error

+ func (t *Task) GobEncode() ([]byte, error)

v0.9.0

Jun 15, 2026

Changes in this version

+ type ByteLimiter interface

+ WaitN func(ctx context.Context, n int64) error

type DownloadConfig

+ Limiter ByteLimiter

+ RateLimitBps int64

+ RateLimitSet bool

type DownloadEntry

+ RateLimit int64

+ RateLimitSet bool

type DownloadState

+ RateLimit int64

+ RateLimitSet bool

type DownloadStatus

+ RateLimit int64

+ RateLimitSet bool

type ProgressState

+ RateLimitBps int64

+ RateLimitSet bool

+ func (ps *ProgressState) GetRateLimit() (int64, bool)

+ func (ps *ProgressState) SetRateLimit(rate int64, explicit bool)

type RuntimeConfig

+ DefaultDownloadRateLimitBps int64

+ GlobalRateLimitBps int64

v0.8.7

Jun 3, 2026

Changes in this version

+ const DefaultUserAgent

+ const PerDownloadMax

type RuntimeConfig

+ MaxConnectionsPerDownload int

+ func DefaultRuntimeConfig() *RuntimeConfig

+ func (r *RuntimeConfig) GetMaxConnectionsPerDownload() int

v0.8.6

May 10, 2026

v0.8.5

May 1, 2026

v0.8.4

Apr 30, 2026

Changes in this version

+ var ErrActiveUpdate = errors.New("download is currently active, please pause it before updating the URL")

+ var ErrCompleted = errors.New("download already completed")

+ var ErrDestRequired = errors.New("destination path is required")

+ var ErrEngineNotInit = errors.New("engine not initialized")

+ var ErrIDExists = errors.New("download id already exists")

+ var ErrMaxRedirects = errors.New("stopped after 10 redirects")

+ var ErrNotFound = errors.New("download not found")

+ var ErrPausing = errors.New("download is still pausing, try again in a moment")

+ var ErrPoolNotInit = errors.New("worker pool not initialized")

+ var ErrQueuedUpdate = errors.New(...)

+ var ErrServiceUnavailable = errors.New("service unavailable")

+ var ErrURLRequired = errors.New("URL is required")

v0.8.3

Apr 24, 2026

Changes in this version

+ const PoolMaxConnsPerHost

+ const PoolMaxIdleConns

+ const PoolMaxIdleConnsPerHost

type ProgressState

+ func (ps *ProgressState) SessionReset()

v0.8.2

Apr 20, 2026

Changes in this version

+ const DialHedgeCount

type RuntimeConfig

+ DialHedgeCount int

+ func (r *RuntimeConfig) GetDialHedgeCount() int

v0.8.1

Apr 14, 2026

v0.8.0

Apr 11, 2026

Changes in this version

type RuntimeConfig

+ CustomDNS string

v0.7.8

Apr 4, 2026

Changes in this version

+ type CancelResult struct

+ Completed bool

+ DestPath string

+ Filename string

+ Found bool

+ WasQueued bool

v0.7.7

Apr 2, 2026

v0.7.6

Apr 2, 2026

Changes in this version

+ const AlignSize

+ const DefaultExpectContinueTimeout

+ const DefaultIdleConnTimeout

+ const DefaultMaxIdleConns

+ const DefaultResponseHeaderTimeout

+ const DefaultTLSHandshakeTimeout

+ const DialTimeout

+ const GB

+ const HealthCheckInterval

+ const IncompleteSuffix

+ const KB

+ const KeepAliveDuration

+ const MB

+ const MaxTaskRetries

+ const MinChunk

+ const PerHostMax

+ const ProbeTimeout

+ const ProgressChannelBuffer

+ const RetryBaseDelay

+ const SlowWorkerGrace

+ const SlowWorkerThreshold

+ const SpeedEMAAlpha

+ const StallTimeout

+ const WorkerBatchInterval

+ const WorkerBatchSize

+ const WorkerBuffer

+ var ErrPaused = errors.New("download paused")

+ type ChunkStatus int

+ const ChunkCompleted

+ const ChunkDownloading

+ const ChunkPending

+ type DownloadConfig struct

+ DestPath string

+ Filename string

+ Headers map[string]string

+ ID string

+ IsExplicitCategory bool

+ IsResume bool

+ Mirrors []string

+ OutputPath string

+ ProgressCh chan<- any

+ Runtime *RuntimeConfig

+ SavedState *DownloadState

+ State *ProgressState

+ SupportsRange bool

+ TotalSize int64

+ URL string

+ type DownloadEntry struct

+ AvgSpeed float64

+ CompletedAt int64

+ DestPath string

+ Downloaded int64

+ Filename string

+ ID string

+ Mirrors []string

+ Status string

+ TimeTaken int64

+ TotalSize int64

+ URL string

+ URLHash string

+ type DownloadState struct

+ ActualChunkSize int64

+ ChunkBitmap []byte

+ CreatedAt int64

+ DestPath string

+ Downloaded int64

+ Elapsed int64

+ FileHash string

+ Filename string

+ ID string

+ Mirrors []string

+ PausedAt int64

+ Tasks []Task

+ TotalSize int64

+ URL string

+ URLHash string

+ type DownloadStatus struct

+ AddedAt int64

+ AvgSpeed float64

+ Connections int

+ DestPath string

+ Downloaded int64

+ ETA int64

+ Error string

+ Filename string

+ ID string

+ Progress float64

+ Speed float64

+ Status string

+ TimeTaken int64

+ TotalSize int64

+ URL string

+ type MasterList struct

+ Downloads []DownloadEntry

+ type MirrorStatus struct

+ Active bool

+ Error bool

+ URL string

+ type ProgressState struct

+ ActiveWorkers atomic.Int32

+ ActualChunkSize int64

+ BitmapWidth int

+ ChunkBitmap []byte

+ ChunkProgress []int64

+ DestPath string

+ Done atomic.Bool

+ Downloaded atomic.Int64

+ Error atomic.Pointer[error]

+ Filename string

+ ID string

+ Mirrors []MirrorStatus

+ Paused atomic.Bool

+ Pausing atomic.Bool

+ SavedElapsed time.Duration

+ SessionStartBytes int64

+ StartTime time.Time

+ TotalSize int64

+ URL string

+ VerifiedProgress atomic.Int64

+ func NewProgressState(id string, totalSize int64) *ProgressState

+ func (ps *ProgressState) FinalizePauseSession(downloaded int64) time.Duration

+ func (ps *ProgressState) FinalizeSession(downloaded int64) (time.Duration, time.Duration)

+ func (ps *ProgressState) GetBitmap() ([]byte, int, int64, int64, []int64)

+ func (ps *ProgressState) GetBitmapSnapshot(includeProgress bool) ([]byte, int, int64, int64, []int64)

+ func (ps *ProgressState) GetChunkState(index int) ChunkStatus

+ func (ps *ProgressState) GetDestPath() string

+ func (ps *ProgressState) GetError() error

+ func (ps *ProgressState) GetFilename() string

+ func (ps *ProgressState) GetMirrors() []MirrorStatus

+ func (ps *ProgressState) GetProgress() (downloaded int64, total int64, totalElapsed time.Duration, ...)

+ func (ps *ProgressState) GetSavedElapsed() time.Duration

+ func (ps *ProgressState) GetURL() string

+ func (ps *ProgressState) InitBitmap(totalSize int64, chunkSize int64)

+ func (ps *ProgressState) IsPaused() bool

+ func (ps *ProgressState) IsPausing() bool

+ func (ps *ProgressState) Pause()

+ func (ps *ProgressState) RecalculateProgress(remainingTasks []Task)

+ func (ps *ProgressState) RestoreBitmap(bitmap []byte, actualChunkSize int64)

+ func (ps *ProgressState) Resume()

+ func (ps *ProgressState) SetCancelFunc(cancel context.CancelFunc)

+ func (ps *ProgressState) SetChunkProgress(progress []int64)

+ func (ps *ProgressState) SetChunkState(index int, status ChunkStatus)

+ func (ps *ProgressState) SetDestPath(path string)

+ func (ps *ProgressState) SetError(err error)

+ func (ps *ProgressState) SetFilename(filename string)

+ func (ps *ProgressState) SetMirrors(mirrors []MirrorStatus)

+ func (ps *ProgressState) SetPausing(pausing bool)

+ func (ps *ProgressState) SetSavedElapsed(d time.Duration)

+ func (ps *ProgressState) SetTotalSize(size int64)

+ func (ps *ProgressState) SetURL(url string)

+ func (ps *ProgressState) SyncSessionStart()

+ func (ps *ProgressState) UpdateChunkStatus(offset, length int64, status ChunkStatus)

+ type RuntimeConfig struct

+ MaxConnectionsPerHost int

+ MaxTaskRetries int

+ MinChunkSize int64

+ ProxyURL string

+ SequentialDownload bool

+ SlowWorkerGracePeriod time.Duration

+ SlowWorkerThreshold float64

+ SpeedEmaAlpha float64

+ StallTimeout time.Duration

+ UserAgent string

+ WorkerBufferSize int

+ func ConvertRuntimeConfig(rc *config.RuntimeConfig) *RuntimeConfig

+ func (r *RuntimeConfig) GetMaxConnectionsPerHost() int

+ func (r *RuntimeConfig) GetMaxTaskRetries() int

+ func (r *RuntimeConfig) GetMinChunkSize() int64

+ func (r *RuntimeConfig) GetSlowWorkerGracePeriod() time.Duration

+ func (r *RuntimeConfig) GetSlowWorkerThreshold() float64

+ func (r *RuntimeConfig) GetSpeedEmaAlpha() float64

+ func (r *RuntimeConfig) GetStallTimeout() time.Duration

+ func (r *RuntimeConfig) GetUserAgent() string

+ func (r *RuntimeConfig) GetWorkerBufferSize() int

+ type Task struct

+ Length int64

+ Offset int64

+ SharedMaxOffset *atomic.Int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL