9 Commits

Author	SHA1	Message	Date
Ken Hibino	7b1770da96	Minor code cleanup	2020-06-29 06:11:47 -07:00
Ken Hibino	9699d196e5	Add recoverer	2020-06-29 06:11:47 -07:00
Ken Hibino	65e17a3469	Update processor to adapt for deadlines set change ... - Processor dequeues tasks only when it's available to process - Processor retries a task when its context's Done channel is closed	2020-06-29 06:11:47 -07:00
Ken Hibino	4ea58052f8	Update RDB.Dequeue to return message and deadline	2020-06-29 06:11:47 -07:00
Ken Hibino	7f30fa2bb6	Fix requeue logic in processor	2020-06-13 06:22:32 -07:00
Ken Hibino	06c4a1c7f8	Limit the number of tasks moved by CheckAndEnqueue to prevent a long ... running script	2020-06-08 06:06:18 -07:00
Ken Hibino	a38f628f3b	Refactor server state management	2020-05-31 06:41:19 -07:00
Ken Hibino	7c7f8e5f30	Move Broker interface to base package	2020-04-19 08:51:17 -07:00
Ken Hibino	46ab4417dd	Add test to simulate situation where redis is down	2020-04-19 08:51:17 -07:00