resourcedownloader

Oct 17, 2024

Changes in this version

+ type Interface interface

+ Schedule func(source string, target string, document string) error

+ func New(workerCount int, failFast bool, wg *sync.WaitGroup, ...) (Interface, taskqueue.QueueController, error)

+ type ResourceDownloadWorker struct

+ func NewDownloader(registry registry.Interface, writer writers.Writer) (*ResourceDownloadWorker, error)

+ func (d *ResourceDownloadWorker) Download(ctx context.Context, source string, target string, document string) error