fetcher

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config, pool *worker.Pool, store *psql.Store, ...) (*Manager, error)
  • func (m *Manager) Run() error
• type Worker
  • func NewWorker(cfg *config.Config, client figmentclient.Client, dl *datalake.DataLake) *Worker
  • func (w *Worker) Run() error

Types

type Manager

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

Manager represents a fetcher manager

func NewManager

func NewManager(cfg *config.Config, pool *worker.Pool, store *psql.Store, client figmentclient.Client) (*Manager, error)

NewManager creates a fetcher manager

func (*Manager) Run

func (m *Manager) Run() error

Run starts the fetcher manager

type Worker

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

Worker represents a fetcher worker

func NewWorker

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

NewWorker creates a fetcher worker

func (*Worker) Run

func (w *Worker) Run() error

Run starts the fetcher worker