package
0.0.0-20170927090418-fc15ddb28967
Repository: https://github.com/iamduo/workq.git
Documentation: pkg.go.dev
# Functions
New Empty Job returns an Job with its created time initiliazed.
Returns an empty but intiialized run record.
NewWorkQueue returns an initialized WorkQueue.
Valid time is in UTC, and greater or equal to current time.
Valid TTL is 2^64 - 1, non zero, and non-negative.
A valid TTR is 2^32 - 1, non zero, and non-negative.
# Constants
1 MiB = 1,024 KiB = 1,048,576 bytes.
Max timeout for wait related cmds (lease).
30 days in ms.
24 hours in ms.
# Structs
Inspector allows for deeper inspection of a WorkQueue.
Queue controller owns/manages all queues.
Registry holds all Job Run Records.
Run Record encapsulates the meta for the execution of jobs.
RunResult is sent over the Wait channel.
Stats represents job controller specific stats.
Timer container encapsulates the original time.Timer with support for Cancellation.
WorkQueue encapsulates 3 separate queues for a single type of job.