273 Commits

Author	SHA1	Message	Date
Ken Hibino	970cb7a606	v0.19.1	2021-12-12 06:16:13 -08:00
Ken Hibino	157e97e72e	Update changelog	2021-12-11 10:29:43 -08:00
Ken Hibino	22e6c9d297	Delete "pending_since" under task-key when state changes to active	2021-12-11 10:29:43 -08:00
Ken Hibino	99a6750656	Add Latency field to QueueInfo	2021-12-11 10:29:43 -08:00
Ken Hibino	e7c1c3ad6f	Use clock in RDB	2021-12-11 10:29:43 -08:00
Ken Hibino	c9183374c5	Add internal timeutil package	2021-12-11 10:29:43 -08:00
Ken Hibino	6e7106c8f2	Record time when task moved to pending state	2021-12-11 10:29:43 -08:00
Ken Hibino	9f2c321e98	Add EnqueueContext method to Client	2021-11-15 16:34:26 -08:00
Ken Hibino	413afc2ab6	v0.19.0	2021-11-06 15:20:09 -07:00
Ken Hibino	f4ddac4dcc	Introduce Task Results ... * Added Retention Option to specify retention TTL for tasks * Added ResultWriter as a client interface to write result data for the associated task	2021-11-06 15:18:42 -07:00
Ken Hibino	4638405cbd	Fix flaky test	2021-11-06 15:18:42 -07:00
Ken Hibino	dbdd9c6d5f	Update RDB Enqueue and Schedule methods to check for task ID conflict	2021-11-06 15:18:42 -07:00
Ken Hibino	2261c7c9a0	Change TaskMessage.ID type from uuid.UUID to string	2021-11-06 15:18:42 -07:00
Ajat Prabha	23c522dc9f	Add asynq/x/rate package ... - Added a directory /x for external, experimental packeges - Added a `rate` package to enable rate limiting across multiple asynq worker servers	2021-11-03 15:55:23 -07:00
Ken Hibino	d612a8a9e4	v0.18.6	2021-10-03 05:55:49 -07:00
Jason White	b3ef9e91a9	Upgrade go-redis/redis to version 8	2021-09-02 05:56:02 -07:00
Ken Hibino	05534c6f24	v0.18.5	2021-09-01 06:02:49 -07:00
Ken Hibino	f0db219f6a	Add IsFailure to Config ... With this IsFailure config, users can provide a predicate function to determine whether the error returned from Handler counts as a failure.	2021-09-01 06:00:54 -07:00
Ken Hibino	421dc584ff	v0.18.4	2021-08-17 17:12:33 -07:00
Ken Hibino	c197902dc0	v0.18.3	2021-08-09 08:59:35 -07:00
Ken Hibino	e6355bf3f5	Use approximate memory usage for QueueInfo	2021-08-09 08:58:44 -07:00
Ken Hibino	684a7e0c98	v0.18.2	2021-07-15 06:56:53 -07:00
Ken Hibino	46b23d6495	Allow upper case characters in queue name	2021-07-15 06:55:47 -07:00
Ken Hibino	c0ae62499f	v0.18.1	2021-07-04 06:39:54 -07:00
Ken Hibino	d02b722d8a	v0.18.0	2021-06-29 16:36:52 -07:00
Ken Hibino	99c7ebeef2	Add migration command in CLI	2021-06-29 16:34:21 -07:00
Ken Hibino	e01c6379c8	Fix lua script for redis-cluster mode	2021-06-29 16:34:21 -07:00
Ken Hibino	a0df047f71	Use md5 to generate checksum for unique key	2021-06-29 16:34:21 -07:00
Ken Hibino	68dd6d9a9d	(fix): Clear unique lock when task is deleted via Inspector	2021-06-29 16:34:21 -07:00
Ken Hibino	6cce31a134	Fix recoverer test	2021-06-29 16:34:21 -07:00
Ken Hibino	68839dc9d3	Fix lua scripts for redis cluster	2021-06-29 16:34:21 -07:00
Ken Hibino	8922d2423a	Define RDB.GetTaskInfo	2021-06-29 16:34:21 -07:00
Ken Hibino	87264b66f3	Record last_failed_at time on Retry or Archive event	2021-06-29 16:34:21 -07:00
Ken Hibino	62168b8d0d	Add LastFailedAt field to TaskMessage	2021-06-29 16:34:21 -07:00
Ken Hibino	456edb6b71	Replace RunTaskByKey with RunTask in Inspector	2021-06-29 16:34:21 -07:00
Ken Hibino	b9c2572203	Refactor redis keys and store messages in protobuf ... Changes: - Task messages are stored under "asynq:{<qname>}:t:<task_id>" key in redis, value is a HASH type and message are stored under "msg" key in the hash. The hash also stores "deadline", "timeout". - Redis LIST and ZSET stores task message IDs - Task messages are serialized using protocol buffer	2021-06-29 16:34:21 -07:00
Ken Hibino	0bf767cf21	Add TaskState type to base package	2021-06-29 16:34:21 -07:00
Ken Hibino	4af65d5fa5	Update RDB methods with new errors package	2021-06-29 16:34:21 -07:00
Ken Hibino	a19ad19382	Update RDB.Dequeue with new errors package	2021-06-29 16:34:21 -07:00
Ken Hibino	8117ce8972	Minor fixes	2021-06-29 16:34:21 -07:00
Ken Hibino	d98ecdebb4	Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors	2021-06-29 16:34:21 -07:00
Ken Hibino	ffe9aa74b3	Add errors.RedisCommandError type	2021-06-29 16:34:21 -07:00
Ken Hibino	d2d4029aba	Update RDB.CurrentStats and RDB.HistoricalStats with specific errors	2021-06-29 16:34:21 -07:00
Ken Hibino	76bd865ebc	Update RDB.RemoveQueue with specific error types	2021-06-29 16:34:21 -07:00
Ken Hibino	136d1c9ea9	Update rdb.List* methods with specific errors	2021-06-29 16:34:21 -07:00
Ken Hibino	52e04355d3	Return QueueNotFoundError from DeleteAll* methods	2021-06-29 16:34:21 -07:00
Ken Hibino	cde3e57c6c	Update RDB.RunAll* methods with task state	2021-06-29 16:34:21 -07:00
Ken Hibino	dd66acef1b	Return QueueNotFoundError from ArchiveAll* methods	2021-06-29 16:34:21 -07:00
Ken Hibino	30a3d9641a	Update tests for RDB.DeleteTask and RDB.ArchiveTask	2021-06-29 16:34:21 -07:00
Ken Hibino	961582cba6	Update RDB.RunTask with more specific errors	2021-06-29 16:34:21 -07:00