worker

Documentation

Index

• type Worker
  • func NewWorker(ctx context.Context, workerpool *workerpool.WorkerPool, ...) Worker
• type WorkerImpl
  • func (w *WorkerImpl) Start(ticker *time.Ticker) error

Types

type Worker

type Worker interface {
	Start(ticker *time.Ticker) error
}

func NewWorker

func NewWorker(ctx context.Context, workerpool *workerpool.WorkerPool, config config.ConfigClient, dotlanClient dotlan.DotlanDbClient, dbClient database.DatabaseClient, publisher message.Publisher, workitemLock workitemLock.WorkItemLock) Worker

type WorkerImpl

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

func (*WorkerImpl) Start

func (w *WorkerImpl) Start(ticker *time.Ticker) error