worker

Documentation

Overview

Package worker synchronizes data between API and DB.

It queries the API at a specified interval and merges the results into the DB.

Index

• type Worker
  • func New(api *client.Client, db *db.Client, cfg *config.Config, logger *log.Logger) (*Worker, error)
  • func (w *Worker) Run(interval time.Duration, stop <-chan struct{})

Types

type Worker

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

Worker coordinates communication between API and DB.

func New

func New(api *client.Client, db *db.Client, cfg *config.Config, logger *log.Logger) (*Worker, error)

New creates a new Worker instance.

func (*Worker) Run

func (w *Worker) Run(interval time.Duration, stop <-chan struct{})

Run schedules a new sync job at the specified interval. It is blocking.