301 Commits

Author	SHA1	Message	Date
Ken Hibino	c04fd41653	v0.22.1	2022-02-20 06:22:55 -08:00
Ken Hibino	7e5efb0e30	Drop GT option from RDB.ExtendLease ... GT option in ZAdd is supported for redis v6.2.0 or above. This Change fixes redis version compatibility (currently v4.0+)	2022-02-20 06:20:38 -08:00
Ken Hibino	a19909f5f4	v0.22.0	2022-02-19 06:20:05 -08:00
Ken Hibino	de25201d9f	Make timeutil.SimulatedClock concurrency safe	2022-02-19 06:15:44 -08:00
Ken Hibino	d4006894ad	Remove base.DeadlinesKey	2022-02-19 06:15:44 -08:00
Ken Hibino	59927509d8	Remove timeout and deadline fields under task key	2022-02-19 06:15:44 -08:00
Ken Hibino	d7169cd445	Update heartbeat to extend lease of active workers	2022-02-19 06:15:44 -08:00
Ken Hibino	dfae8638e1	Update RDB methods to work with lease	2022-02-19 06:15:44 -08:00
Ken Hibino	b9943de2ab	Add Lease type to base package	2022-02-19 06:15:44 -08:00
Ken Hibino	871474f220	Update heartbeat goroutine to call ExtendLease on active tasks	2022-02-19 06:15:44 -08:00
Ken Hibino	87dc392c7f	Add RDB.ExtendLease method	2022-02-19 06:15:44 -08:00
Ken Hibino	dabcb120d5	Update recoverer to use ListLeaseExpired	2022-02-19 06:15:44 -08:00
Ken Hibino	bc2f1986d7	Update ListDeadlineExceeded to ListLeaseExpired	2022-02-19 06:15:44 -08:00
Ken Hibino	b8cb579407	Update RDB methods to use lease instead of deadlines set	2022-02-19 06:15:44 -08:00
Ken Hibino	d865d89900	Update RDB.Dequeue to insert task ID to lease set	2022-02-19 06:15:44 -08:00
Ken Hibino	852af7abd1	Add base.LeaseKey helper function	2022-02-19 06:15:44 -08:00
Ken Hibino	5490d2c625	Fix tests	2022-02-16 07:08:01 -08:00
Binaek Sarkar	ebd7a32c0f	conventions	2022-02-16 06:43:08 -08:00
Binaek Sarkar	55d0610a03	test and changelog	2022-02-16 06:43:08 -08:00
Binaek Sarkar	ab8a4f5b1e	review corrections	2022-02-16 06:43:08 -08:00
Binaek Sarkar	d7ceb0c090	first cut	2022-02-16 06:43:08 -08:00
Ken Hibino	dff2e3a336	v0.21.0	2022-01-22 06:15:29 -08:00
Ken Hibino	25832e5e95	Fix bug related to concurrently executing server state changes	2022-01-12 09:10:56 -08:00
Ken Hibino	aa26f3819e	Fix flaky tests	2022-01-05 09:07:42 -08:00
Ken Hibino	8dfabfccb3	Fix build	2021-12-19 07:06:37 -08:00
Ken Hibino	5f20edcbd1	v0.20.0	2021-12-19 07:00:21 -08:00
Ken Hibino	1ddb2f7bce	Use math.MaxInt64 instead of custom const	2021-12-19 06:58:12 -08:00
Ken Hibino	82d18e3d91	Record total tasks processed/failed	2021-12-16 16:53:02 -08:00
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