queue

Documentation

Index

• Variables
• type Dispatcher
  • func NewDispatcher(maxWorkers int) *Dispatcher
  • func (d *Dispatcher) Run()
• type Queuable
• type Worker
  • func NewWorker(workerPool chan chan Queuable) Worker
  • func (w Worker) Start()

Variables

var JobQueue chan Queuable

JobQueue ... a buffered channel that we can send work requests on.

Types

type Dispatcher

type Dispatcher struct {
	WorkerPool chan chan Queuable
	Workers    []Worker
	// contains filtered or unexported fields
}

Dispatcher ... worker dispatcher

func NewDispatcher

func NewDispatcher(maxWorkers int) *Dispatcher

NewDispatcher ... creates new queue dispatcher

func (*Dispatcher) Run

func (d *Dispatcher) Run()

Run ... starts work of dispatcher and creates the workers

type Queuable

type Queuable interface {
	Handle() error
}

Queuable ... interface of Queuable Job

type Worker

type Worker struct {
	Name       string
	WorkerPool chan chan Queuable
	JobChannel chan Queuable
	// contains filtered or unexported fields
}

Worker … simple worker that handles queueable tasks

func NewWorker

func NewWorker(workerPool chan chan Queuable) Worker

NewWorker --

func (Worker) Start

func (w Worker) Start()

Start ... initiate worker to start listening for upcoming queueable jobs