consumer

Documentation

Index

• type Worker
  • func NewWorker(logger *zap.Logger, db database.Database, hn hn.Client) *Worker
  • func (w *Worker) Run(ctx context.Context, message <-chan *queue.Message, wg *sync.WaitGroup)

Types

type Worker

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

Worker is responsible for fetching items and inserting the items in the database

func NewWorker

func NewWorker(logger *zap.Logger, db database.Database, hn hn.Client) *Worker

NewWorker creates a new worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context, message <-chan *queue.Message, wg *sync.WaitGroup)

Run is responsible for processing messages