worker

Documentation

Index

• Variables
• func StartDispatcher(nworkers int)
• type ChanWriter
  • func (c *ChanWriter) Write(p []byte) (int, error)
• type WorkRequest
  • func NewWorkRequest(name, script, payload string, args []string, timeout int) *WorkRequest
  • func (wr *WorkRequest) IsTerminated() bool
  • func (wr *WorkRequest) Terminate()
• 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 {
	ID          uint64
	Name        string
	Script      string
	Payload     string
	Args        []string
	MessageChan chan []byte
	Timeout     int
	Terminated  bool
	// contains filtered or unexported fields
}

WorkRequest is a request of work for a worker

func NewWorkRequest

func NewWorkRequest(name, script, payload string, args []string, timeout int) *WorkRequest

NewWorkRequest creats new work request

func (*WorkRequest) IsTerminated

func (wr *WorkRequest) IsTerminated() bool

IsTerminated ask if the work request is terminated

func (*WorkRequest) Terminate

func (wr *WorkRequest) Terminate()

Terminate set work request as terminated

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.