go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-14 19:38:49 +08:00
Code Issues Projects Releases Wiki Activity

Commit Graph

  • 09c25742f9 Remove base.DeadlinesKey Ken Hibino 2022-02-16 06:27:08 -0800
  • 8bdaff188d Remove timeout and deadline fields under task key Ken Hibino 2022-02-16 06:17:08 -0800
  • a9082720e6 Update processor to create a lease and watch for expiration Ken Hibino 2022-02-15 06:58:54 -0800
  • a5d0206f33 Update heartbeat to extend lease of active workers Ken Hibino 2022-02-14 07:17:51 -0800
  • 53d8d0554a Update RDB methods to work with lease Ken Hibino 2022-02-13 14:34:38 -0800
  • 6f88c14bd2 Add Lease type to base package Ken Hibino 2022-02-13 14:06:26 -0800
  • 92eba47853 Update heartbeat goroutine to call ExtendLease on active tasks Ken Hibino 2022-02-12 09:48:07 -0800
  • 6974812027 Add RDB.ExtendLease method Ken Hibino 2022-02-12 06:49:53 -0800
  • 86ae8ecb4a Update recoverer to use ListLeaseExpired Ken Hibino 2022-02-11 06:18:27 -0800
  • 0fb0d4fe19 Update ListDeadlineExceeded to ListLeaseExpired Ken Hibino 2022-02-11 05:54:56 -0800
  • d48eac25df Update RDB methods to use lease instead of deadlines set Ken Hibino 2022-02-10 19:01:05 -0800
  • 01cff7ca64 Move task deadline compute logic to processor Ken Hibino 2022-02-09 06:21:39 -0800
  • d5ac1fb4d8 Update RDB.Dequeue to insert task ID to lease set Ken Hibino 2022-02-08 06:47:31 -0800
  • 87218f5899 Add base.LeaseKey helper function Ken Hibino 2022-02-08 05:53:42 -0800
  • 5490d2c625 Fix tests Ken Hibino 2022-02-16 06:51:09 -0800
  • 7a1e9b5870 Fix tests Ken Hibino 2022-02-16 06:51:09 -0800
  • ebd7a32c0f conventions Binaek Sarkar 2022-02-10 15:26:34 +0530
  • 55d0610a03 test and changelog Binaek Sarkar 2022-01-29 15:32:52 +0530
  • ab8a4f5b1e review corrections Binaek Sarkar 2022-01-28 21:21:34 +0530
  • d7ceb0c090 first cut Binaek Sarkar 2022-01-25 14:42:02 +0530
  • 70f9ba2db8
         conventions Binaek Sarkar 2022-02-10 15:26:34 +0530
  • 8bd70c6f84 (ci): Run go (build|test) commands for each module Ken Hibino 2022-02-01 06:32:26 -0800
  • cdaae96947 (ci): Run go (build|test) commands for each module Ken Hibino 2022-02-01 06:32:26 -0800
  • 10ab4e3745 Remove replace directives in go.mod Ken Hibino 2022-01-31 20:01:33 -0800
  • 6262427dbc Remove replace directives in go.mod Ken Hibino 2022-01-31 20:01:33 -0800
  • 349f4c50fb Add example for ResultWriter Ken Hibino 2022-01-31 07:03:39 -0800
  • b437d105b8 Add example for ResultWriter Ken Hibino 2022-01-31 07:03:39 -0800
  • 2499cd95a8 test and changelog Binaek Sarkar 2022-01-29 15:32:52 +0530
  • a5d42adaed
         review corrections Binaek Sarkar 2022-01-28 21:21:34 +0530
  • a18c0bc958 first cut Binaek Sarkar 2022-01-25 14:42:02 +0530
  • dff2e3a336 v0.21.0 v0.21.0 Ken Hibino 2022-01-22 06:15:29 -0800
  • 65040af7b5 Update changelog Ken Hibino 2022-01-22 06:14:24 -0800
  • 053fe2d1ee Create PeriodicTaskManager Ken Hibino 2022-01-15 16:46:12 -0800
  • d73b95c55e Create PeriodicTaskManager Ken Hibino 2022-01-15 16:46:12 -0800
  • 25832e5e95
         Fix bug related to concurrently executing server state changes Ken Hibino 2022-01-12 09:10:56 -0800
  • 092fac59eb Fix bug related to concurrently executing server state changing operations (e.g. Shutdown) Ken Hibino 2022-01-11 06:56:46 -0800
  • aa26f3819e
         Fix flaky tests Ken Hibino 2022-01-05 09:07:42 -0800
  • 1a97247841 Fix flaky tests Ken Hibino 2022-01-05 06:25:53 -0800
  • d94614bb9b
         Add CODE_OF_CONDUCT.md Ken Hibino 2022-01-04 06:17:48 -0800
  • ce46b07652
         Allow configuration of DelayedTaskCheckInterval Mahdi Dibaiee 2022-01-03 22:44:00 +0000
  • cb7768a964
         feat: allow configuration of DelayedTaskCheckInterval Mahdi Dibaiee 2022-01-02 19:28:58 +0000
  • 2d0170541c
         Add --json flag for asynq stats command Mahdi Dibaiee 2022-01-02 15:24:29 +0000
  • f160274ee0
         feat: --json flag for asynq stats command Mahdi Dibaiee 2021-12-31 21:18:04 +0000
  • c1f08106da
         fix: missing import statement in example code Andreas Thomas 2021-12-27 14:40:10 +0100
  • 312e11ba98 fix: missing import statement in example code chronark 2021-12-27 11:52:49 +0100
  • dd35acea05 fix: missing import statement in example code chronark 2021-12-27 11:30:59 +0100
  • 74cf804197
         Update readme Ken Hibino 2021-12-20 05:51:51 -0800
  • 8dfabfccb3 Fix build Ken Hibino 2021-12-19 07:06:37 -0800
  • 5f20edcbd1 v0.20.0 v0.20.0 Ken Hibino 2021-12-19 07:00:21 -0800
  • 1ddb2f7bce Use math.MaxInt64 instead of custom const Ken Hibino 2021-12-19 06:58:12 -0800
  • 82d18e3d91
         Record total tasks processed/failed Ken Hibino 2021-12-16 16:53:02 -0800
  • e711293588 Minor doc fix Ken Hibino 2021-12-16 16:49:00 -0800
  • 1b5e9e369e (x/metrics): Export total tasks processed/failed counter metrics Ken Hibino 2021-12-16 16:43:13 -0800
  • b6527672c4 Add ProcessedTotal and FailedTotal fields to QueueInfo Ken Hibino 2021-12-16 16:35:29 -0800
  • ff0ac4f4e1 Update rdb package to record total processed/failed counters Ken Hibino 2021-12-16 06:28:51 -0800
  • d9d42805b8 Add ProcessedTotalKey and FailedTotalKey to base package Ken Hibino 2021-12-16 06:11:26 -0800
  • 43cb4ddf19
         Add queue metrics exporter Ken Hibino 2021-12-16 06:01:01 -0800
  • ef7f3caafa Update changelog Ken Hibino 2021-12-16 05:56:23 -0800
  • c8c5afdf75 Update package godoc for x/metrics Ken Hibino 2021-12-16 05:54:13 -0800
  • 93db532e86 Update tools/metrics_exporter to use prometheus/collectors package Ken Hibino 2021-12-15 19:55:31 -0800
  • a355838bc3 Export queue memory usage from QueueMetricsCollector Ken Hibino 2021-12-14 07:01:02 -0800
  • 68ca0a4aa8 Export queue latency metrics from QueueMetricsCollector Ken Hibino 2021-12-12 06:00:22 -0800
  • 358e34cc5a Rename to QueueMetricsCollector Ken Hibino 2021-12-12 05:50:25 -0800
  • 90254fbcb1 Export queue size metrics Ken Hibino 2021-12-04 05:45:00 -0800
  • f06ac6e305 Create x/metrics package Ken Hibino 2021-11-25 06:35:06 -0800
  • 57a866a006 Fix flag Ken Hibino 2021-11-23 06:05:48 -0800
  • 75ecaa892e Add more metrics Ken Hibino 2021-11-21 06:47:53 -0800
  • 242dcfcc4c Read queue info from redis Ken Hibino 2021-11-21 06:29:25 -0800
  • f04f7eea93 Add command-line flags Ken Hibino 2021-11-19 06:59:29 -0800
  • 27fe6554d6 Create metrics_exporter tool Ken Hibino 2021-11-19 06:42:16 -0800
  • ddfc6747a1 Fix typo in Server doc Francisco Miamoto 2021-12-13 15:39:42 -0300
  • 62ad76365e Fix typo in Server doc Francisco Miamoto 2021-12-13 15:39:42 -0300
  • 970cb7a606 v0.19.1 v0.19.1 Ken Hibino 2021-12-12 06:16:13 -0800
  • 157e97e72e Update changelog Ken Hibino 2021-12-11 06:44:01 -0800
  • 22e6c9d297 Delete "pending_since" under task-key when state changes to active Ken Hibino 2021-12-11 06:42:47 -0800
  • 99a6750656 Add Latency field to QueueInfo Ken Hibino 2021-12-11 06:27:44 -0800
  • e7c1c3ad6f Use clock in RDB Ken Hibino 2021-12-10 09:07:41 -0800
  • c9183374c5 Add internal timeutil package Ken Hibino 2021-12-10 06:47:16 -0800
  • 6e7106c8f2 Record time when task moved to pending state Ken Hibino 2021-12-09 06:37:18 -0800
  • a19b9d084d Update changelog Ken Hibino 2021-12-11 06:44:01 -0800
  • f32cf3d614 Delete "pending_since" under task-key when state changes to active Ken Hibino 2021-12-11 06:42:47 -0800
  • 5d8aa9b105 Add Latency field to QueueInfo Ken Hibino 2021-12-11 06:27:44 -0800
  • 718fa2b31c Use clock in RDB Ken Hibino 2021-12-10 09:07:41 -0800
  • 7cb9dcc060 Add internal timeutil package Ken Hibino 2021-12-10 06:47:16 -0800
  • a91266847d Record time when task moved to pending state Ken Hibino 2021-12-09 06:37:18 -0800
  • 9f2c321e98
         Add EnqueueContext method to Client Ken Hibino 2021-11-15 16:34:26 -0800
  • 165b6dfa14 Fix test build Ken Hibino 2021-11-13 19:37:50 -0800
  • 5289efd52b Update changelog Ken Hibino 2021-11-13 14:58:46 -0800
  • e937f82f9c Add EnqueueContext method to Client Ken Hibino 2021-11-13 14:57:18 -0800
  • e2b61c9056 Return error if Unique TTL is less than 1s Ken Hibino 2021-11-09 15:53:48 -0800
  • 216762e3ac Return error if Unique TTL is less than 1s Ken Hibino 2021-11-09 15:53:48 -0800
  • 531d1ef089 Fix godoc around errors returned from Inspector Ken Hibino 2021-11-09 15:43:04 -0800
  • 9aa057e8e4 Fix godoc around errors returned from Inspector Ken Hibino 2021-11-09 15:43:04 -0800
  • 413afc2ab6 v0.19.0 v0.19.0 Ken Hibino 2021-11-06 15:20:09 -0700
  • 6bb4818509 Update readme Ken Hibino 2021-11-06 06:38:36 -0700
  • f4ddac4dcc Introduce Task Results Ken Hibino 2021-11-05 16:52:54 -0700
  • 4638405cbd Fix flaky test Ken Hibino 2021-09-12 16:56:22 -0700
  • 9e2f88c00d Add TaskID option to allow user to specify task id Ken Hibino 2021-09-11 21:11:04 -0700
  • dbdd9c6d5f Update RDB Enqueue and Schedule methods to check for task ID conflict Ken Hibino 2021-09-10 16:47:00 -0700
  • 2261c7c9a0 Change TaskMessage.ID type from uuid.UUID to string Ken Hibino 2021-09-10 06:29:37 -0700