DecodePendingQueue decodes an object from PendingQueue.Encode().

DecodeQueueState decodes an object from QueueState.Encode().

DecodeRateTracker loads an encoded RateTracker.

DecodeRunningQueue decodes an object from RunningQueue.Encode().

DecodeTaskDeque inverts TaskDeque.Encode(), converting a serializable object back into a linked list deque.

DeserializeQueueStateMux reads a file written by QueueStateMux.Serialize().

NewQueueState creates empty queues with the given task timeout.

NewQueueStateMux creates a QueueStateMux with the given task timeout.

NewRateTracker creates a RateTracker which keeps event counts up to historySize seconds in the past.

ReadQueueStateMux is like DeserializeQueueStateMux(), but reads from a local file instead of an arbitrary reader.

Default history time used for RateTracker.

QueueState maintains two queues of tasks: a pending queue and a running queue.

QueueStateMux manages multiple (named) QueueStates.

A RateTracker keeps a sliding window of event counts over the last N seconds.