fetcher

Jul 20, 2021

Changes in this version

+ type Manager struct

+ func NewManager(cfg *config.Config, pool *worker.Pool, store store.Jobs, ...) (*Manager, error)

+ func (m *Manager) Run() error

+ type Worker struct

+ func NewWorker(cfg *config.Config, client figmentclient.Client, dl *datalake.DataLake) *Worker

+ func (w *Worker) Run() error