tasks

Documentation

Index

• type Dispatcher
• type DispatcherImpl
  • func NewDispatcher(maxWorkers int, targetQueue chan Task) *DispatcherImpl
  • func (d *DispatcherImpl) Dispatch(job Task)
  • func (d *DispatcherImpl) Run() error
  • func (d *DispatcherImpl) Stop() error
• type Task
• type Worker
  • func NewWorker(workerPool chan chan Task) *Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Types

type Dispatcher

type Dispatcher interface {
	Dispatch(task Task)
}

type DispatcherImpl

type DispatcherImpl struct {
	sync.Mutex

	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan Task
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher(maxWorkers int, targetQueue chan Task) *DispatcherImpl

func (*DispatcherImpl) Dispatch

func (d *DispatcherImpl) Dispatch(job Task)

func (*DispatcherImpl) Run

func (d *DispatcherImpl) Run() error

func (*DispatcherImpl) Stop

func (d *DispatcherImpl) Stop() error

type Task

type Task interface {
	Perform() error
}

Job represents the job to be run

type Worker

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

Worker represents the worker that executes the job

func NewWorker

func NewWorker(workerPool chan chan Task) *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.