moulin
moulin copied to clipboard
A reliable queue for batch processing written in Go and backed by Redis.
Use case: There are 5 queues with some failed tasks. You want to combine all these into one new queue.
Issue #20 is a generalized variant of this feature, though that focusses on changing the phase of individual tasks. This feature request would include an easy way to move all...
For example, change a task in "expired" to "failed", or "failed" to "incoming"
Instead of merely appending, allow to insert new tasks at the head of the queue, or even more generalized at arbitrary indexes in the queue
See title. needs investigation
Possibly make it a subcommand of `inspect`? `moulin inspect q1 incoming` (phase of the queue) `moulin inspect q1` (all)
Sometimes a task can be faulty; and we want to delete it. It would also be a cool feature if a a task is actually stopped on the worker when...
When the server is shortly unavailable during a heartbeat, the client currently panics and quits. Instead it should retry for up to some time (the task timeout duration) and only...
This should add a retry policy on heartbeat, complete, fail and some other tasks. So that a server reboot cannot do much harm. closes #7