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.