worker

Documentation

Index

• Variables
• func ResolveScript(dir, name string) (string, error)
• func RetrieveLogFile(id, name, base string) (*os.File, error)
• func Run(work *model.WorkRequest) error
• func StartDispatcher(nworkers int)
• type ChanWriter
  • func (c *ChanWriter) Write(p []byte) (int, error)
• type Worker
  • func NewWorker(id int, workerQueue chan chan model.WorkRequest) Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Variables

var WorkQueue = make(chan model.WorkRequest, 100)

WorkQueue is the global queue of work to dispatch

var WorkerQueue chan chan model.WorkRequest

WorkerQueue is the global queue of Workers

Functions

func ResolveScript

func ResolveScript(dir, name string) (string, error)

ResolveScript is resolving the target script.

func RetrieveLogFile

func RetrieveLogFile(id, name, base string) (*os.File, error)

RetrieveLogFile retrieve work log with its name and id

func Run

func Run(work *model.WorkRequest) error

Run work request

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 Worker

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

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

func NewWorker

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

NewWorker creates, and returns a new Worker object.

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.