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

Commit Graph

  • c62833540c Add license comment to all src files Ken Hibino 2020-01-02 18:13:16 -0800
  • 9c0233c388 Update todos Ken Hibino 2020-01-02 18:04:36 -0800
  • fc5b65ddae Add a function to return a list of queues to query Ken Hibino 2020-01-01 18:19:55 -0800
  • 6de80f9f04 Change dequeue method to use lua script Ken Hibino 2020-01-01 14:57:31 -0800
  • 5c42bdc4c4 Change (*RDB).Dequeue to query multiple queues in order Ken Hibino 2020-01-01 13:42:24 -0800
  • eb191c07d1 Export (High|Low)PriorityQueue constant from base pkg Ken Hibino 2020-01-01 12:12:49 -0800
  • 2e95166f39 Remove Queue field and Priority field to base.TaskMessage Ken Hibino 2020-01-01 07:48:21 -0800
  • 31a18d783e Add Priority type in base package Ken Hibino 2020-01-01 07:41:22 -0800
  • 09ee8df5a0 Add end-to-end benchmark tests Ken Hibino 2019-12-31 12:36:46 -0800
  • 1dd875adb9 Add end-to-end benchmark tests Ken Hibino 2019-12-31 12:36:46 -0800
  • 4376dc1e9d Add benchmark tests for rdb Ken Hibino 2019-12-30 20:10:34 -0800
  • b7c0c5d3aa Handle mutated task in RDB's Done, Retry, Kill methods Ken Hibino 2019-12-30 09:22:25 -0800
  • b793827adc Add benchmark tests for rdb Ken Hibino 2019-12-30 20:10:34 -0800
  • 52559ff26e Handle mutated task in RDB's Done, Retry, Kill methods Ken Hibino 2019-12-30 09:22:25 -0800
  • ade97befbc Minor cleanup Ken Hibino 2019-12-30 07:10:13 -0800
  • 22b21df884 Allow user to specify retry delay duration Ken Hibino 2019-12-29 17:43:19 -0800
  • 9af14d9a6d Add Config type to configure background processing behavior Ken Hibino 2019-12-29 16:55:51 -0800
  • ede0b1880d Minor cleanup Ken Hibino 2019-12-30 07:10:13 -0800
  • 7aa482bf17 Allow user to specify retry delay duration Ken Hibino 2019-12-29 17:43:19 -0800
  • 17834bdbb8 Add Config type to configure background processing behavior Ken Hibino 2019-12-29 16:55:51 -0800
  • fc71857c7c Change NewBackground API to take *redis.Client Ken Hibino 2019-12-29 14:50:46 -0800
  • 62624cb0d8 Change NewClient API to take *redis.Client Ken Hibino 2019-12-29 13:42:49 -0800
  • f765045171 Change NewBackground API to take *redis.Client Ken Hibino 2019-12-29 14:50:46 -0800
  • e99a4307a1 Change NewClient API to take *redis.Client Ken Hibino 2019-12-29 13:42:49 -0800
  • ae0c2f9ca5 Use asynqtest helpers in asynq package tests Ken Hibino 2019-12-29 09:41:00 -0800
  • 807729d36a Create internal asynqtest package for test helpers Ken Hibino 2019-12-28 20:12:14 -0800
  • fef5ae6d3f Rename poller to scheduler Ken Hibino 2019-12-28 13:33:24 -0800
  • 49d6ab5df0 Clean up rdb package Ken Hibino 2019-12-28 10:51:37 -0800
  • 99466d653f Use asynqtest helpers in asynq package tests Ken Hibino 2019-12-29 09:41:00 -0800
  • 2a0fad1ba7 Create internal asynqtest package for test helpers Ken Hibino 2019-12-28 20:12:14 -0800
  • 931a4460d2 Rename poller to scheduler Ken Hibino 2019-12-28 13:33:24 -0800
  • 80d417a607 Clean up rdb package Ken Hibino 2019-12-28 10:51:37 -0800
  • 4ceb49cfd1 Minor improvements Ken Hibino 2019-12-27 20:37:15 -0800
  • 2e91c49c3f [ci skip] Update readme Ken Hibino 2019-12-27 16:26:11 -0800
  • de9af2aaf2 [ci skip] Update readme Ken Hibino 2019-12-27 16:26:11 -0800
  • 190d671546 Add kill and killall command to asynqmon Ken Hibino 2019-12-27 06:48:56 -0800
  • 8d3d30da8f Add KillAllRetryTasks and KillAllScheduledTasks method to RDB Ken Hibino 2019-12-27 06:22:33 -0800
  • aaa813dfdc Critical fix Ken Hibino 2019-12-26 21:40:04 -0800
  • 5b98b8eb62 Add KillRetryTask, KillScheduledTask methods to RDB Ken Hibino 2019-12-26 07:17:26 -0800
  • d222dfd749
         Merge pull request #29 from hibiken/feature/github_tmpl Ken Hibino 2019-12-27 10:46:47 -0800
  • 0c6ee9cf5e Update issue templates Ken Hibino 2019-12-27 10:45:45 -0800
  • 7f44079711 Add kill and killall command to asynqmon Ken Hibino 2019-12-27 06:48:56 -0800
  • f5612dedab Add KillAllRetryTasks and KillAllScheduledTasks method to RDB Ken Hibino 2019-12-27 06:22:33 -0800
  • 92c202db55 Critical fix Ken Hibino 2019-12-26 21:40:04 -0800
  • 8cee1daee7 Add KillRetryTask, KillScheduledTask methods to RDB Ken Hibino 2019-12-26 07:17:26 -0800
  • f3d7d020a4
         Merge pull request #25 from hibiken/feature/stats Ken Hibino 2019-12-26 06:10:13 -0800
  • fb24d158ae fix: CurrentState without processed/failed data Ken Hibino 2019-12-25 21:29:20 -0800
  • 9b87f7c1f1 Show processed/failed count and error rate in asynqmon stats command Ken Hibino 2019-12-25 20:29:58 -0800
  • cde9d41580 Add processed and failed count to Stats Ken Hibino 2019-12-25 20:17:00 -0800
  • 6491f46955 Minor cleanup Ken Hibino 2019-12-25 20:04:29 -0800
  • 698fdcfcb2 fix: Change max dead tasks count to 100 Ken Hibino 2019-12-25 19:57:23 -0800
  • b2161a481d Record processed and failure daily count Ken Hibino 2019-12-23 05:33:48 -0800
  • 24481cd2c7
         Merge pull request #24 from hibiken/feature/redisinfo Ken Hibino 2019-12-22 17:18:38 -0800
  • ee7a22adef Display redis info in stats command Ken Hibino 2019-12-22 09:27:22 -0800
  • eea919d117 Add RedisInfo method to RDB Ken Hibino 2019-12-22 09:09:57 -0800
  • 0f8f266632
         Merge pull request #22 from hibiken/refactor/basepkg Ken Hibino 2019-12-22 07:45:13 -0800
  • 3fd248615b Create base internal package Ken Hibino 2019-12-22 07:15:45 -0800
  • 5de314400d
         Merge pull request #21 from hibiken/feature/retrycount Ken Hibino 2019-12-21 10:05:42 -0800
  • f5b7e0cccd Document options precedence Ken Hibino 2019-12-21 10:02:03 -0800
  • 4229073a24 Allow user to define a max retry count for a task Ken Hibino 2019-12-21 07:42:32 -0800
  • fc66aaa47f Update CLI description Ken Hibino 2019-12-21 07:01:03 -0800
  • 6df302689c
         Merge pull request #18 from hibiken/feature/payload Ken Hibino 2019-12-20 20:21:54 -0800
  • 324a785233 Add Hash method to Payload Ken Hibino 2019-12-20 20:14:40 -0800
  • 14ac5f6674 Add Get* methods to Payload type Ken Hibino 2019-12-19 07:13:43 -0800
  • 3fd096a90a [ci skip] Update todos Ken Hibino 2019-12-18 21:18:13 -0800
  • bc7991c757
         Merge pull request #17 from hibiken/feature/stop Ken Hibino 2019-12-18 20:43:40 -0800
  • 8b98b6e5a0 Rename channel name Ken Hibino 2019-12-18 18:57:48 -0800
  • 33e9da953d Log warning and info messages when unfinished tasks get aborted Ken Hibino 2019-12-18 18:55:08 -0800
  • b2bc0ef91c [ci skip] Update todos Ken Hibino 2019-12-17 20:37:54 -0800
  • 69b46a7f0d Use sync.Once Ken Hibino 2019-12-17 20:34:56 -0800
  • c40e779fdb Modify poller to wait for Time.After channel instead of time.Sleep Ken Hibino 2019-12-17 20:13:41 -0800
  • 5ddba8ca98 Unblock processor shutdown process if processor is waiting for semaphore token Ken Hibino 2019-12-17 20:07:17 -0800
  • 24dd78b31c Stop processing more tasks from the queue once TSTP signal is received Ken Hibino 2019-12-17 06:18:22 -0800
  • 3e30c5916b Trap and handle TSTP signal Ken Hibino 2019-12-17 05:32:31 -0800
  • 911e600c41 Terminate background upon receiving SIGTERM or SIGINT Ken Hibino 2019-12-16 20:19:05 -0800
  • 12fc336889
         Merge pull request #16 from hibiken/feature/signals Ken Hibino 2019-12-16 06:54:06 -0800
  • bcaccf1174 [ci skip] Update todos Ken Hibino 2019-12-16 06:41:15 -0800
  • eb3216d354 Fix: Use buffered channel of size 1 to avoid goroutine leaks Ken Hibino 2019-12-16 06:40:52 -0800
  • 989b2b6d55 Add timeout to worker goroutines when TERM signal is received Ken Hibino 2019-12-15 21:00:09 -0800
  • e5686894d3 Fix: Do not use lua cjson library to encode task to json Ken Hibino 2019-12-15 20:05:56 -0800
  • 442b33a6d2 Remove (*RDB).RetryLater in favor of Retry method Ken Hibino 2019-12-15 17:18:43 -0800
  • d84e8c0ff2 Modify (*RDB).Kill method to atomically move task from in_progress to dead queue Ken Hibino 2019-12-15 17:16:13 -0800
  • 1b1662bb12 Add Retry method to *RDB Ken Hibino 2019-12-15 16:15:07 -0800
  • 1857d12cea
         Merge pull request #15 from hibiken/refactor/testing Ken Hibino 2019-12-14 13:58:33 -0800
  • 04836194f9 Clean up rdb package tests Ken Hibino 2019-12-12 19:49:41 -0800
  • 9410a65338 Rename randomTask test helper to newTaskMessage Ken Hibino 2019-12-12 19:45:03 -0800
  • d2eeaf6ab1 [ci skip] Update todos Ken Hibino 2019-12-12 19:05:25 -0800
  • 0620f2f0f7
         Merge pull request #14 from hibiken/feature/delall Ken Hibino 2019-12-12 19:03:17 -0800
  • b7870548d3 Add delall command to asynqmon CLI Ken Hibino 2019-12-12 07:02:14 -0800
  • ca31cbf843 Add DeleteAll* methods to rdb Ken Hibino 2019-12-12 06:38:01 -0800
  • 9d79861ac0
         Merge pull request #13 from hibiken/feature/del Ken Hibino 2019-12-11 21:14:02 -0800
  • 1a687bbf84 Add del command to asynqmon CLI Ken Hibino 2019-12-11 21:03:47 -0800
  • be746d01a5 Add delete methods to rdb Ken Hibino 2019-12-11 19:56:19 -0800
  • 193d27d93d
         Merge pull request #12 from hibiken/feature/shorter_id Ken Hibino 2019-12-11 07:49:59 -0800
  • edcd70b221 Replace google/uuid package with rs/xid for more compact id Ken Hibino 2019-12-11 07:38:24 -0800
  • 8b6e3172ce [ci skip] Update todos Ken Hibino 2019-12-11 07:13:04 -0800
  • 542b7867d8
         Merge pull request #11 from hibiken/feature/enqall Ken Hibino 2019-12-10 22:01:54 -0800
  • ef562e2efa Minor improvement Ken Hibino 2019-12-10 21:48:19 -0800
  • a96719413c Add enqall command to asynqmon CLI Ken Hibino 2019-12-10 21:38:25 -0800
  • 0d74c518bf Add methods to rdb to enqueue all tasks from dead, retry and scheduled queue Ken Hibino 2019-12-10 20:28:31 -0800