rain

package module

Go to main page

Versions in this module

v0

v0.4.5

Jan 3, 2023

Changes in this version

type OptionFunc

+ func WithOutpath(outpath string) OptionFunc

v0.4.4

Dec 31, 2022

v0.4.3

Dec 31, 2022

v0.4.2

Dec 30, 2022

v0.4.1

Dec 30, 2022

Changes in this version

type RainControl

+ func (rc *RainControl) Status() Status

v0.4.0

Dec 30, 2022

Changes in this version

+ const COPY_BUFFER_SIZE

+ const STATUS_NOTSTART

+ func SetProxy(p func(*http.Request) (*url.URL, error), h ...http.Header) error

type Config

+ func (cfg *Config) Clone() *Config

+ type MultiReadable struct

+ func NewMultiReadable(reader io.Reader) *MultiReadable

+ func (mr *MultiReadable) Close() error

+ func (mr *MultiReadable) Read(p []byte) (int, error)

+ func (mr *MultiReadable) Reset() error

type OptionFunc

+ func WithDebug(d bool) OptionFunc

type Rain

+ func (rain *Rain) SetProxy(p func(*http.Request) (*url.URL, error), h ...http.Header) error

type RainControl

+ func (rc *RainControl) WaitChan() <-chan error

type Status

+ func (s Status) Is(ss ...Status) bool

v0.3.0

Dec 27, 2022

Changes in this version

+ func AddOptions(opt ...OptionFunc)

+ func SetOptions(opts []OptionFunc)

type Rain

+ func (rain *Rain) AddOptions(opt ...OptionFunc)

+ func (rain *Rain) SetOptions(opt []OptionFunc)

type RainControl

+ func (rc *RainControl) SetSpeedLimit(d int)

v0.2.0

Dec 27, 2022

Changes in this version

+ const STATUS_CLOSE

+ const STATUS_ERROR

type Bar

+ func (bar *Bar) Close(stat *EventExtend)

+ func (bar *Bar) Error(stat *EventExtend)

+ func (bar *Bar) Finish(stat *EventExtend)

+ type EventExtend struct

+ DownloadSpeed int64

+ EstimatedTime time.Duration

+ func (se *EventExtend) AddEvent(e ...ProgressEventExtend)

+ func (se *EventExtend) Change(stat *Stat)

type OptionFunc

+ func WithBar(bars ...*Bar) OptionFunc

+ func WithEventExtend(e ...ProgressEventExtend) OptionFunc

type ProgressEvent

+ func NewEventExtend(e ...ProgressEventExtend) ProgressEvent

+ type ProgressEventExtend interface

+ Change func(stat *EventExtend)

+ Close func(stat *EventExtend)

+ Error func(stat *EventExtend)

+ Finish func(stat *EventExtend)

v0.1.0

Dec 24, 2022

Changes in this version

+ const Inf

+ const InfDuration

+ const STATUS_BEGIN

+ const STATUS_FINISH

+ const STATUS_RUNNING

+ func ReplaceHeader(h http.Header)

+ func SetAllowOverwrite(d bool)

+ func SetAutoFileRenaming(d bool)

+ func SetBody(d io.Reader)

+ func SetBreakpointExt(d string)

+ func SetBreakpointResume(d bool)

+ func SetClient(d *http.Client)

+ func SetCreateDir(d bool)

+ func SetDiskCache(d int)

+ func SetHeader(k, v string)

+ func SetMethod(d string)

+ func SetOutdir(d string)

+ func SetPerm(d fs.FileMode)

+ func SetRetryNumber(d int)

+ func SetRetryTime(d time.Duration)

+ func SetRoutineCount(d int)

+ func SetRoutineSize(d int64)

+ func SetSpeedLimit(d int)

+ func SetTimeout(d time.Duration)

+ type Bar struct

+ FinishHide bool

+ FriendlyFormat bool

+ Hide bool

+ Stdout io.Writer

+ Template *BarTemplate

+ func NewBar() *Bar

+ func (bar *Bar) Change(stat *Stat)

+ type BarStatString struct

+ CompletedLength string

+ DownloadSpeed string

+ EstimatedTime string

+ Progress string

+ Saucer string

+ TotalLength string

+ type BarTemplate struct

+ BarEnd string

+ BarStart string

+ BarWidth int

+ NoSizeTemplate *template.Template

+ Saucer string

+ SaucerHead string

+ SaucerPadding string

+ Template *template.Template

+ type Block struct

+ End int64

+ Start int64

+ type Breakpoint struct

+ Etag string

+ Filesize int64

+ Position int64

+ Tasks []*Block

+ type Config struct

+ AllowOverwrite bool

+ AutoFileRenaming bool

+ AutoFilterFilename bool

+ AutoSaveTnterval time.Duration

+ BreakpointExt string

+ BreakpointResume bool

+ CreateDir bool

+ DiskCache int

+ RetryNumber int

+ RetryTime time.Duration

+ RoutineCount int

+ RoutineSize int64

+ SpeedLimit int

+ Timeout time.Duration

+ func NewConfig() *Config

+ func (cfg *Config) Copy() *Config

+ type Limit float64

+ func Every(interval time.Duration) Limit

+ type Limiter struct

+ func NewLimiter(r Limit, b int) *Limiter

+ func (lim *Limiter) Allow() bool

+ func (lim *Limiter) AllowN(now time.Time, n int) bool

+ func (lim *Limiter) Burst() int

+ func (lim *Limiter) Limit() Limit

+ func (lim *Limiter) Reserve() *Reservation

+ func (lim *Limiter) ReserveN(now time.Time, n int) *Reservation

+ func (lim *Limiter) SetBurst(newBurst int)

+ func (lim *Limiter) SetBurstAt(now time.Time, newBurst int)

+ func (lim *Limiter) SetLimit(newLimit Limit)

+ func (lim *Limiter) SetLimitAt(now time.Time, newLimit Limit)

+ func (lim *Limiter) Wait(ctx context.Context) (err error)

+ func (lim *Limiter) WaitN(ctx context.Context, n int) (err error)

+ type OptionFunc func(ctl *control)

+ func WithAllowOverwrite(d bool) OptionFunc

+ func WithAutoFileRenaming(d bool) OptionFunc

+ func WithAutoFilterFilename(d bool) OptionFunc

+ func WithBody(d io.Reader) OptionFunc

+ func WithBreakpointExt(d string) OptionFunc

+ func WithBreakpointResume(d bool) OptionFunc

+ func WithClient(d *http.Client) OptionFunc

+ func WithCreateDir(d bool) OptionFunc

+ func WithDiskCache(d int) OptionFunc

+ func WithEvent(e ...ProgressEvent) OptionFunc

+ func WithHeader(d func(h http.Header)) OptionFunc

+ func WithMethod(d string) OptionFunc

+ func WithOutdir(outdir string) OptionFunc

+ func WithOutname(outname string) OptionFunc

+ func WithPerm(d fs.FileMode) OptionFunc

+ func WithRetryNumber(d int) OptionFunc

+ func WithRetryTime(d time.Duration) OptionFunc

+ func WithRoutineCount(d int) OptionFunc

+ func WithRoutineSize(d int64) OptionFunc

+ func WithSpeedLimit(d int) OptionFunc

+ func WithTimeout(d time.Duration) OptionFunc

+ type ProgressEvent interface

+ Change func(stat *Stat)

+ type Rain struct

+ func NewRain() *Rain

+ func (rain *Rain) New(uri string, opts ...OptionFunc) *RainControl

+ func (rain *Rain) ReplaceHeader(h http.Header)

+ func (rain *Rain) SetAllowOverwrite(d bool)

+ func (rain *Rain) SetAutoFileRenaming(d bool)

+ func (rain *Rain) SetAutoFilterFilename(d bool)

+ func (rain *Rain) SetBody(d io.Reader)

+ func (rain *Rain) SetBreakpointExt(d string)

+ func (rain *Rain) SetBreakpointResume(d bool)

+ func (rain *Rain) SetClient(d *http.Client)

+ func (rain *Rain) SetCreateDir(d bool)

+ func (rain *Rain) SetDiskCache(d int)

+ func (rain *Rain) SetHeader(k, v string)

+ func (rain *Rain) SetMethod(d string)

+ func (rain *Rain) SetOutdir(d string)

+ func (rain *Rain) SetPerm(d fs.FileMode)

+ func (rain *Rain) SetRetryNumber(d int)

+ func (rain *Rain) SetRetryTime(d time.Duration)

+ func (rain *Rain) SetRoutineCount(d int)

+ func (rain *Rain) SetRoutineSize(d int64)

+ func (rain *Rain) SetSpeedLimit(d int)

+ func (rain *Rain) SetTimeout(d time.Duration)

+ type RainControl struct

+ func New(uri string, opts ...OptionFunc) *RainControl

+ func (rc *RainControl) Close()

+ func (rc *RainControl) Error() error

+ func (rc *RainControl) Outpath() string

+ func (rc *RainControl) Run() <-chan error

+ func (rc *RainControl) RunContext(ctx context.Context) <-chan error

+ func (rc *RainControl) Start() error

+ func (rc *RainControl) StartContext(ctx context.Context) error

+ func (rc *RainControl) Wait() <-chan error

+ type Reservation struct

+ func (r *Reservation) Cancel()

+ func (r *Reservation) CancelAt(now time.Time)

+ func (r *Reservation) Delay() time.Duration

+ func (r *Reservation) DelayFrom(now time.Time) time.Duration

+ func (r *Reservation) OK() bool

+ type Stat struct

+ CompletedLength int64

+ DownloadSpeed int64

+ Error error

+ EstimatedTime time.Duration

+ Outpath string

+ Progress int

+ Status Status

+ TotalLength int64

+ type Status int

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