135 Commits

Author	SHA1	Message	Date
Ken Hibino	0b3732718f	Add test flags to run tests using redis cluster	2020-09-02 06:35:27 -07:00
Ken Hibino	7ee1e27822	Fix done lua script ... If UniqueKey is an empty string, do not provide the key to Lua script because that will cause CROSSSLOT error in redis cluster (since it doesn't have any hash tag).	2020-09-02 06:35:26 -07:00
Ken Hibino	8daac4af0f	Fix dequeue Lua script to use a single hash tag	2020-09-02 06:35:26 -07:00
Ken Hibino	24f5908b44	Restructure CLI commands with subcommands	2020-09-02 06:35:26 -07:00
Ken Hibino	68ee8d40f9	Update RemoveQueue in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	6aa63857d2	Update ListServers and ListWorkers methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	4583e3822c	Update all delete methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	c06734408f	Update all kill methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	0ff192bb72	Update enqueue methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	0715f8defd	Update all list methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	a7d3f09b49	Update HistoricalStats method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	33919861d6	Update Pause and Unpause methods in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	d7c9508b4b	Update CurrentStats method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	859e2656d8	Add AllQueues method to RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	a37afc6062	Remove stale benchmark test	2020-09-02 06:35:26 -07:00
Ken Hibino	76a768ae7e	Update WriteServerState and ClearServerState in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	cc16910819	Minor fix	2020-09-02 06:35:26 -07:00
Ken Hibino	92c8a4dbbe	Update ListDeadlineExceeded in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	6515d4522b	Update CheckAndEnqueue method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	3795c42c98	Update Requeue method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	0ca14cb586	Update Kill method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	0e6d153572	Update Retry method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	f085296d70	Update Done method in RDB	2020-09-02 06:35:26 -07:00
Ken Hibino	62149e5a08	Update Dequeue command in rdb	2020-09-02 06:35:26 -07:00
Ken Hibino	faeeb2c820	Update Enqueue and Schedule commands in rdb	2020-09-02 06:35:26 -07:00
Ken Hibino	a913e6d73f	Add healthchecker to check broker connection	2020-07-28 22:45:57 -07:00
Ken Hibino	a28f61f313	Add Inspector type	2020-07-28 22:45:57 -07:00
Ken Hibino	8b60e6a268	Replace github.com/rs/xid with github.com/google/uuid	2020-07-06 05:48:31 -07:00
Ken Hibino	199bf4d66a	Minor code cleanup	2020-07-06 05:48:31 -07:00
Ken Hibino	7e942ec241	Use int64 type for Timeout and Deadline in TaskMessage	2020-07-06 05:48:31 -07:00
Ken Hibino	feee87adda	Add recoverer	2020-07-06 05:48:31 -07:00
Ken Hibino	7657f560ec	Add RDB.ListDeadlineExceeded	2020-07-06 05:48:31 -07:00
Ken Hibino	08b71672aa	Update RDB.Requeue to remove message from deadlines set	2020-07-06 05:48:31 -07:00
Ken Hibino	92af00f9fd	Update RDB.Dequeue to return deadline as time.Time	2020-07-06 05:48:31 -07:00
Ken Hibino	113451ce6a	Update RDB.Kill to remove message from deadlines set	2020-07-06 05:48:31 -07:00
Ken Hibino	9cd9f3d6b4	Update RDB.Retry to remove message from deadlines set	2020-07-06 05:48:31 -07:00
Ken Hibino	7b9119c703	Update RDB.Done to remove message from deadlines set	2020-07-06 05:48:31 -07:00
Ken Hibino	9b05dea394	Update RDB.Dequeue to return message and deadline	2020-07-06 05:48:31 -07:00
Ken Hibino	6cc5bafaba	Add task message to deadlines set on dequeue ... Updated dequeueCmd to decode the message and compute its deadline and add the message to the Deadline set.	2020-07-06 05:48:31 -07:00
Ken Hibino	7f30fa2bb6	Fix requeue logic in processor	2020-06-13 06:22:32 -07:00
Ken Hibino	a2abeedaa0	Fix JSON number ovewflow issue	2020-06-12 06:29:36 -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	4e800a7f68	Update stats command to show queue paused status	2020-06-08 06:06:18 -07:00
Ken Hibino	363cfedb49	Update Dequeue operation to skip paused queues	2020-06-08 06:06:18 -07:00
Ken Hibino	4595bd41c3	Add Pause and Unpause methods to rdb	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	239ef27a6e	Update doc comments	2020-04-19 08:51:17 -07:00
Ken Hibino	b086e88a47	Rename ps command to servers	2020-04-19 08:51:17 -07:00
Ken Hibino	aafd8a5b74	Rename internal ProcessState to ServerState	2020-04-19 08:51:17 -07:00
Ken Hibino	b14c73809e	Refactor server state	2020-04-19 08:51:17 -07:00