worker

Documentation

Index

• type Dispatcher
  • func NewDispatcher(maxWorkers int) *Dispatcher
  • func (d *Dispatcher) Run(queues int) chan Job
  • func (d *Dispatcher) Stop()
• type Job
• type Worker
  • func NewWorker(workerPool chan chan Job) Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Types

type Dispatcher

type Dispatcher struct {
	MaxWorkers int
	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan Job
	Workers    []Worker
}

func NewDispatcher

func NewDispatcher(maxWorkers int) *Dispatcher

func (*Dispatcher) Run

func (d *Dispatcher) Run(queues int) chan Job

func (*Dispatcher) Stop

func (d *Dispatcher) Stop()

type Job

type Job interface {
	String() string
	Process() error
	Result(error)
}

Job interface

type Worker

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}

Worker represents the worker that executes the job

func NewWorker

func NewWorker(workerPool chan chan Job) Worker

func (Worker) Start

func (w Worker) Start()

Start method starts the run loop for the worker, listening for a quit channel in case we need to stop it

func (Worker) Stop

func (w Worker) Stop()

Stop signals the worker to stop listening for work requests.