485 Commits

This Branch

This Branch

All Branches

Author	SHA1	Message	Date
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	43b87d236a	Add Queues method to Inspector	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	c054c0b5a0	Fix errors in inspector tests	2020-09-02 06:35:26 -07:00
Ken Hibino	530023334c	Fix client tests	2020-09-02 06:35:26 -07:00
Ken Hibino	34aa0b2277	Add more processor tests	2020-09-02 06:35:26 -07:00
Ken Hibino	bd52b3df3c	Fix test build errors	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	8555848c0a	Fix more build errors	2020-09-02 06:35:26 -07:00
Ken Hibino	a6c2ff00c1	Fix inspector build error	2020-09-02 06:35:26 -07:00
Ken Hibino	7929a1d6d3	Update Broker interface	2020-09-02 06:35:26 -07:00
Ken Hibino	093472da52	Update Inspector API	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	1bb9f10707	Update recoverer	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	281b80f4bb	Update scheduler to check and enqueue for only the specified queues.	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	87124993f8	Move unique key generator function to base	2020-09-02 06:35:26 -07:00
Ken Hibino	03ea601c05	Update base package to generate redis keys with hashtag	2020-09-02 06:35:26 -07:00
Ken Hibino	669c7995c4	Run CI builds using go v1.15.x	2020-09-02 06:34:58 -07:00
Ken Hibino	6d6a301379	v0.11.0 v0.11.0	2020-07-28 22:46:41 -07:00
Ken Hibino	53f9475582	Update changelog	2020-07-28 22:45:57 -07:00
Ken Hibino	e8fdbc5a72	Fix history command	2020-07-28 22:45:57 -07:00
Ken Hibino	5f06c308f0	Add Pause and Unpause queue methods to Inspector	2020-07-28 22:45:57 -07:00
Ken Hibino	a913e6d73f	Add healthchecker to check broker connection	2020-07-28 22:45:57 -07:00
Ken Hibino	6978e93080	Fix flaky test	2020-07-28 22:45:57 -07:00
Ken Hibino	92d77bbc6e	Minor comment fix	2020-07-28 22:45:57 -07:00
Ken Hibino	a28f61f313	Add Inspector type	2020-07-28 22:45:57 -07:00
Ken Hibino	9bd3d8e19e	v0.10.0 v0.10.0	2020-07-06 05:53:56 -07:00
Ken Hibino	7382e2aeb8	Do not start worker goroutine for task already exceeded its deadline	2020-07-06 05:48:31 -07:00
Ken Hibino	007fac8055	Invoke error handler when ctx.Done channel is closed	2020-07-06 05:48:31 -07:00
Ken Hibino	8d43fe407a	Change ErrorHandler function signature	2020-07-06 05:48:31 -07:00