worker

Documentation

Index

• type TaskHandler
• type Worker
  • func NewWorker(events <-chan event.ProcessedEvent, th TaskHandler) *Worker
  • func (w *Worker) Run(done <-chan bool, wg *sync.WaitGroup) error

Types

type TaskHandler

type TaskHandler interface {
	HandleTask(ctx context.Context, newEvent event.ProcessedEvent) error
}

type Worker

type Worker struct {
	TaskHandler   TaskHandler
	EventsChannel <-chan event.ProcessedEvent
}

func NewWorker

func NewWorker(events <-chan event.ProcessedEvent, th TaskHandler) *Worker

func (*Worker) Run

func (w *Worker) Run(done <-chan bool, wg *sync.WaitGroup) error