worker

Documentation

Index

• Variables
• func StartDispatcher(nworkers int)
• type ChanWriter
  • func (c *ChanWriter) Write(p []byte) (int, error)
• type WorkRequest
• type Worker
  • func NewWorker(id int, workerQueue chan chan WorkRequest) Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Variables

var WorkQueue = make(chan WorkRequest, 100)

var WorkerQueue chan chan WorkRequest

Functions

func StartDispatcher

func StartDispatcher(nworkers int)

StartDispatcher is charged to start n workers.

Types

type ChanWriter

type ChanWriter struct {
	ByteChan chan []byte
}

ChanWriter is a simple writer to a channel of byte.

func (*ChanWriter) Write

func (c *ChanWriter) Write(p []byte) (int, error)

type WorkRequest

type WorkRequest struct {
	Name        string
	Script      string
	Payload     string
	Args        []string
	MessageChan chan []byte
}

WorkRequest is a request of work for a worker

type Worker

type Worker struct {
	ID          int
	Work        chan WorkRequest
	WorkerQueue chan chan WorkRequest
	QuitChan    chan bool
}

Worker is a go routine in charge of executing a work.

func NewWorker

func NewWorker(id int, workerQueue chan chan WorkRequest) Worker

NewWorker creates, and returns a new Worker object. Its only argument is a channel that the worker can add itself to whenever it is done its work.

func (Worker) Start

func (w Worker) Start()

Start is the function to starts the worker by starting a goroutine. That is an infinite "for-select" loop.

func (Worker) Stop

func (w Worker) Stop()

Stop tells the worker to stop listening for work requests. Note that the worker will only stop *after* it has finished its work.