package
0.0.0-20170526171120-935a35b36a29
Repository: https://github.com/vkuznet/workqueue.git
Documentation: pkg.go.dev

# Functions

Cleanup performs clean-up of WorkQueue.
GetWorkQueueElements returns list of request in WorkQueue.
InitCouch initializes connection to CouchDB.
InWorkQueue returns if given request name in WorkQueue.
NewDispatcher returns new instance of Dispatcher type.
NewWorker return a new instance of the Worker type.
Process given request.

# Variables

Client points to CouchDB client.
DB points to CouchDB.
JobQueue is a buffered channel that we can send work requests on.
WorkqueueMetrics defines various metrics about the agent work.

# Structs

BlockPolicy defines block policy.
Dispatcher implementation.
Job represents the job to be run with given request.
Mask data structure keeps track of run-lumi.
Metrics of the agent.
MonteCarloPolicy defines block policy.
ResubmitBlockPolicy defines block policy.
Worker represents the worker that executes the job.
WorkQueueElement structure.
WorkqueueStatus data type.

# Interfaces

Policy interface defines policy methods.