downloader

type ArchiverAlgo string

type ChecksumEncoding string

type CompressionAlgo string

type DownloadTask struct {
	// Download destination path. Dest should be slash delimited.
	Dest string
	// Target url
	Url      *url.URL
	Validity Validity
}

type DownloadTaskState struct {
	State        State
	Downloaded   *atomic.Int64
	DownloadTask DownloadTask
	Err          error
	// contains filtered or unexported fields
}

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

type Requester interface {
	Request(ctx context.Context, target *url.URL) (io.ReadCloser, error)
}

type RequesterFunc func(ctx context.Context, target *url.URL) (io.ReadCloser, error)

type SafeWriteConfig struct {
	TempDir       string
	DirMask       fs.FileMode
	ForceDirMask  bool
	ForceFileMask bool
}

type State string

type StaticDownloadTaskState struct {
	State        State
	Downloaded   int64
	DownloadTask DownloadTask
	Err          error
}

type StaticTaskState struct {
	State             State
	Downloaded        int64
	Task              Task
	DownloadTaskState []StaticDownloadTaskState
	Err               error
}

type Task struct {
	// Download destination path. Dest should be slash delimited.
	Dest            string
	ArchiveAlgo     ArchiverAlgo
	CompressionAlgo CompressionAlgo
	Validity        Validity
	Tasks           []DownloadTask
}

type TaskState struct {
	State             State
	Downloaded        *atomic.Int64
	Task              Task
	DownloadTaskState []*DownloadTaskState
	Err               error
	// contains filtered or unexported fields
}

type Validity struct {
	Size             int
	Checksum         string
	ChecksumEncoding ChecksumEncoding
	ChecksumAlgo     crypto.Hash
}