worker

Documentation

Index

• type Worker
  • func New(id int, cache interfaces.CacheLoader, mappers interfaces.Mappers, ...) *Worker
  • func (w *Worker) PublishResult(ctx context.Context, result dto.Result)
  • func (w *Worker) PublishStatistics(ctx context.Context, count int64)
  • func (w *Worker) Start(ctx context.Context)

Types

type Worker

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

func New

func New(
	id int,
	cache interfaces.CacheLoader,
	mappers interfaces.Mappers,
	logger *slog.Logger,
	wg *sync.WaitGroup,
	jobCh chan *dto.Job,
	errorCh chan error,
	publishCh chan *publisher.Publishing,
	stats *atomic.Int64,
	cfg *config.RabbitMQ,
) *Worker

func (*Worker) PublishResult

func (w *Worker) PublishResult(ctx context.Context, result dto.Result)

func (*Worker) PublishStatistics

func (w *Worker) PublishStatistics(ctx context.Context, count int64)

func (*Worker) Start

func (w *Worker) Start(ctx context.Context)