downloader

Mar 9, 2024

Changes in this version

+ func IsValid(f *slack.File) bool

Sep 28, 2022

Changes in this version

+ var ErrNoFS = errors.New("fs adapter not initialised")

+ type FilenameFunc func(*slack.File) string

type Option

+ func WithNameFunc(fn FilenameFunc) Option

Jul 3, 2022

Changes in this version

type Option

+ func Logger(l logger.Interface) Option

Jun 11, 2022

Changes in this version

+ var ErrNotStarted = errors.New("downloader not started")

+ func Filename(f *slack.File) string

+ type Client struct

+ func New(client Downloader, fs fsadapter.FS, opts ...Option) *Client

+ func (c *Client) AsyncDownloader(ctx context.Context, dir string, fileDlQueue <-chan *slack.File) (chan struct{}, error)

+ func (c *Client) DownloadFile(dir string, f slack.File) (string, error)

+ func (c *Client) SaveFile(ctx context.Context, dir string, f *slack.File) (int64, error)

+ func (c *Client) Start(ctx context.Context)

+ func (c *Client) Stop()

+ type Downloader interface

+ GetFile func(downloadURL string, writer io.Writer) error

+ type FileRequest struct

+ Directory string

+ File *slack.File

+ type Option func(*Client)

+ func Limiter(l *rate.Limiter) Option

+ func Retries(n int) Option

+ func Workers(n int) Option