33 Commits

Author	SHA1	Message	Date
Ken Hibino	97b5516183	Update RedisConnOpt interface	2021-01-31 06:09:40 -08:00
Ken Hibino	eba7c4e085	Record deadline within WorkerInfo	2021-01-31 06:09:40 -08:00
Ken Hibino	ccb682853e	Export DefaultRetryDelayFunc	2021-01-14 06:43:44 -08:00
Ken Hibino	00a25ca570	Rename DeadTask to ArchivedTask and action "kill" to "archive"	2021-01-14 06:43:44 -08:00
Ken Hibino	7235041128	Add SkipRetry error to be used as a return value from Handler	2021-01-14 06:43:44 -08:00
Ken Hibino	50e7f38365	Add Scheduler ... - Renamed previously called scheduler to forwarder to resolve name conflicts	2020-10-13 06:31:47 -07:00
Ken Hibino	a2d4ead989	Fix comments in Config	2020-09-14 21:48:05 -07:00
Ken Hibino	8e23b865e9	Update recoverer	2020-09-12 12:59:03 -07:00
Ken Hibino	e0a8f1252a	Update scheduler to check and enqueue for only the specified queues.	2020-09-12 12:59:03 -07:00
Ken Hibino	a913e6d73f	Add healthchecker to check broker connection	2020-07-28 22:45:57 -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
Ken Hibino	feee87adda	Add recoverer	2020-07-06 05:48:31 -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	4492ed9255	Change internal constructor signatures. ... Created "params" type to avoid positional arguments. Personally it feels more explicit and reads better.	2020-05-17 13:25:24 -07:00
Ken Hibino	210b026b01	Add log messages around Server.Quiet	2020-05-16 07:12:08 -07:00
Ken Hibino	0289bc7a10	Clean up log messages ... Moved development purpose log messages to DEBUG level.	2020-05-11 20:28:49 -07:00
Ken Hibino	ae942c93e5	Change default log level to info	2020-05-11 20:28:49 -07:00
Ken Hibino	73d62844e6	Change LogLevel to satisfy flag.Value interface	2020-05-11 06:22:43 -07:00
Ken Hibino	00b82904c6	Allow setting minimum log level for logger	2020-05-11 06:22:43 -07:00
Ken Hibino	a866369866	Simplify Logger interface	2020-05-11 06:22:43 -07:00
Ken Hibino	a0865df33c	Change default concurrency to the number of CPUs	2020-04-19 08:51:17 -07:00
Ken Hibino	7c7f8e5f30	Move Broker interface to base package	2020-04-19 08:51:17 -07:00
Ken Hibino	f8a94fb839	Define broker interface	2020-04-19 08:51:17 -07:00
Ken Hibino	45933eb6b0	Reword doc comments	2020-04-19 08:51:17 -07:00
Ken Hibino	4df372b369	Allow user to configure shutdown timeout	2020-04-19 08:51:17 -07:00
Ken Hibino	eef2f5f3cb	Add test cases for server error	2020-04-19 08:51:17 -07:00
Ken Hibino	239ef27a6e	Update doc comments	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
Ken Hibino	779065c269	Export Start, Stop and Quiet method on Server type	2020-04-19 08:51:17 -07:00
Ken Hibino	f9842ba914	Rename Background to Server	2020-04-19 08:51:17 -07:00