2
0
mirror of https://github.com/hibiken/asynq.git synced 2025-06-06 23:02:57 +08:00

Commit Graph

  • 49d6ab5df0 Clean up rdb package Ken Hibino 2019-12-28 10:51:37 -08:00
  • 4ceb49cfd1 Minor improvements Ken Hibino 2019-12-27 20:37:15 -08:00
  • 2e91c49c3f [ci skip] Update readme Ken Hibino 2019-12-27 16:26:11 -08:00
  • 190d671546 Add kill and killall command to asynqmon Ken Hibino 2019-12-27 06:48:56 -08:00
  • 8d3d30da8f Add KillAllRetryTasks and KillAllScheduledTasks method to RDB Ken Hibino 2019-12-27 06:22:33 -08:00
  • aaa813dfdc Critical fix Ken Hibino 2019-12-26 21:40:04 -08:00
  • 5b98b8eb62 Add KillRetryTask, KillScheduledTask methods to RDB Ken Hibino 2019-12-26 07:17:26 -08:00
  • d222dfd749
    Merge pull request #29 from hibiken/feature/github_tmpl Ken Hibino 2019-12-27 10:46:47 -08:00
  • 0c6ee9cf5e Update issue templates Ken Hibino 2019-12-27 10:45:45 -08:00
  • f3d7d020a4
    Merge pull request #25 from hibiken/feature/stats Ken Hibino 2019-12-26 06:10:13 -08:00
  • fb24d158ae fix: CurrentState without processed/failed data Ken Hibino 2019-12-25 21:29:20 -08:00
  • 9b87f7c1f1 Show processed/failed count and error rate in asynqmon stats command Ken Hibino 2019-12-25 20:29:58 -08:00
  • cde9d41580 Add processed and failed count to Stats Ken Hibino 2019-12-25 20:17:00 -08:00
  • 6491f46955 Minor cleanup Ken Hibino 2019-12-25 20:04:29 -08:00
  • 698fdcfcb2 fix: Change max dead tasks count to 100 Ken Hibino 2019-12-25 19:57:23 -08:00
  • b2161a481d Record processed and failure daily count Ken Hibino 2019-12-23 05:33:48 -08:00
  • 24481cd2c7
    Merge pull request #24 from hibiken/feature/redisinfo Ken Hibino 2019-12-22 17:18:38 -08:00
  • ee7a22adef Display redis info in stats command Ken Hibino 2019-12-22 09:27:22 -08:00
  • eea919d117 Add RedisInfo method to RDB Ken Hibino 2019-12-22 09:09:57 -08:00
  • 0f8f266632
    Merge pull request #22 from hibiken/refactor/basepkg Ken Hibino 2019-12-22 07:45:13 -08:00
  • 3fd248615b Create base internal package Ken Hibino 2019-12-22 07:15:45 -08:00
  • 5de314400d
    Merge pull request #21 from hibiken/feature/retrycount Ken Hibino 2019-12-21 10:05:42 -08:00
  • f5b7e0cccd Document options precedence Ken Hibino 2019-12-21 10:02:03 -08:00
  • 4229073a24 Allow user to define a max retry count for a task Ken Hibino 2019-12-21 07:42:32 -08:00
  • fc66aaa47f Update CLI description Ken Hibino 2019-12-21 07:01:03 -08:00
  • 6df302689c
    Merge pull request #18 from hibiken/feature/payload Ken Hibino 2019-12-20 20:21:54 -08:00
  • 324a785233 Add Hash method to Payload Ken Hibino 2019-12-20 20:14:40 -08:00
  • 14ac5f6674 Add Get* methods to Payload type Ken Hibino 2019-12-19 07:13:43 -08:00
  • 3fd096a90a [ci skip] Update todos Ken Hibino 2019-12-18 21:18:13 -08:00
  • bc7991c757
    Merge pull request #17 from hibiken/feature/stop Ken Hibino 2019-12-18 20:43:40 -08:00
  • 8b98b6e5a0 Rename channel name Ken Hibino 2019-12-18 18:57:48 -08:00
  • 33e9da953d Log warning and info messages when unfinished tasks get aborted Ken Hibino 2019-12-18 18:55:08 -08:00
  • b2bc0ef91c [ci skip] Update todos Ken Hibino 2019-12-17 20:37:54 -08:00
  • 69b46a7f0d Use sync.Once Ken Hibino 2019-12-17 20:34:56 -08:00
  • c40e779fdb Modify poller to wait for Time.After channel instead of time.Sleep Ken Hibino 2019-12-17 20:13:41 -08:00
  • 5ddba8ca98 Unblock processor shutdown process if processor is waiting for semaphore token Ken Hibino 2019-12-17 20:07:17 -08:00
  • 24dd78b31c Stop processing more tasks from the queue once TSTP signal is received Ken Hibino 2019-12-17 06:18:22 -08:00
  • 3e30c5916b Trap and handle TSTP signal Ken Hibino 2019-12-17 05:32:31 -08:00
  • 911e600c41 Terminate background upon receiving SIGTERM or SIGINT Ken Hibino 2019-12-16 20:19:05 -08:00
  • 12fc336889
    Merge pull request #16 from hibiken/feature/signals Ken Hibino 2019-12-16 06:54:06 -08:00
  • bcaccf1174 [ci skip] Update todos Ken Hibino 2019-12-16 06:41:15 -08:00
  • eb3216d354 Fix: Use buffered channel of size 1 to avoid goroutine leaks Ken Hibino 2019-12-16 06:40:52 -08:00
  • 989b2b6d55 Add timeout to worker goroutines when TERM signal is received Ken Hibino 2019-12-15 21:00:09 -08:00
  • e5686894d3 Fix: Do not use lua cjson library to encode task to json Ken Hibino 2019-12-15 20:05:56 -08:00
  • 442b33a6d2 Remove (*RDB).RetryLater in favor of Retry method Ken Hibino 2019-12-15 17:18:43 -08:00
  • d84e8c0ff2 Modify (*RDB).Kill method to atomically move task from in_progress to dead queue Ken Hibino 2019-12-15 17:16:13 -08:00
  • 1b1662bb12 Add Retry method to *RDB Ken Hibino 2019-12-15 16:15:07 -08:00
  • 1857d12cea
    Merge pull request #15 from hibiken/refactor/testing Ken Hibino 2019-12-14 13:58:33 -08:00
  • 04836194f9 Clean up rdb package tests Ken Hibino 2019-12-12 19:49:41 -08:00
  • 9410a65338 Rename randomTask test helper to newTaskMessage Ken Hibino 2019-12-12 19:45:03 -08:00
  • d2eeaf6ab1 [ci skip] Update todos Ken Hibino 2019-12-12 19:05:25 -08:00
  • 0620f2f0f7
    Merge pull request #14 from hibiken/feature/delall Ken Hibino 2019-12-12 19:03:17 -08:00
  • b7870548d3 Add delall command to asynqmon CLI Ken Hibino 2019-12-12 07:02:14 -08:00
  • ca31cbf843 Add DeleteAll* methods to rdb Ken Hibino 2019-12-12 06:38:01 -08:00
  • 9d79861ac0
    Merge pull request #13 from hibiken/feature/del Ken Hibino 2019-12-11 21:14:02 -08:00
  • 1a687bbf84 Add del command to asynqmon CLI Ken Hibino 2019-12-11 21:03:47 -08:00
  • be746d01a5 Add delete methods to rdb Ken Hibino 2019-12-11 19:56:19 -08:00
  • 193d27d93d
    Merge pull request #12 from hibiken/feature/shorter_id Ken Hibino 2019-12-11 07:49:59 -08:00
  • edcd70b221 Replace google/uuid package with rs/xid for more compact id Ken Hibino 2019-12-11 07:38:24 -08:00
  • 8b6e3172ce [ci skip] Update todos Ken Hibino 2019-12-11 07:13:04 -08:00
  • 542b7867d8
    Merge pull request #11 from hibiken/feature/enqall Ken Hibino 2019-12-10 22:01:54 -08:00
  • ef562e2efa Minor improvement Ken Hibino 2019-12-10 21:48:19 -08:00
  • a96719413c Add enqall command to asynqmon CLI Ken Hibino 2019-12-10 21:38:25 -08:00
  • 0d74c518bf Add methods to rdb to enqueue all tasks from dead, retry and scheduled queue Ken Hibino 2019-12-10 20:28:31 -08:00
  • c0185061eb
    Merge pull request #10 from hibiken/feature/enq Ken Hibino 2019-12-09 20:43:17 -08:00
  • ea28d3cac1 Minor improvement Ken Hibino 2019-12-09 20:37:30 -08:00
  • 8830d23388 Rename rdb methods to enqueue scheduled, retry, and dead tasks Ken Hibino 2019-12-09 19:33:07 -08:00
  • b766de4f18 [ci skip] Update documentations for enq command Ken Hibino 2019-12-09 06:58:34 -08:00
  • 764edc35e3 [ci skip] Update todos Ken Hibino 2019-12-09 06:52:43 -08:00
  • 8932ca41b3 Minor improvement Ken Hibino 2019-12-09 06:22:08 -08:00
  • 4179c72c05 Add enq command to asynqmon Ken Hibino 2019-12-08 16:36:08 -08:00
  • 39c4904dae
    Merge pull request #9 from hibiken/feature/rescue Ken Hibino 2019-12-08 14:18:37 -08:00
  • bbd8fb901f [ci skip] Fix typos Ken Hibino 2019-12-08 14:17:57 -08:00
  • 680a2cf3df Add methods to rdb.RDB to enqueues a task from scheduled, retry, dead queues Ken Hibino 2019-12-08 06:46:04 -08:00
  • 8e2c4e5716 Update todos Ken Hibino 2019-12-07 20:25:46 -08:00
  • b8e456742f
    Merge pull request #8 from hibiken/feature/tools Ken Hibino 2019-12-07 20:03:26 -08:00
  • 9941c9e303 Minor fixes Ken Hibino 2019-12-07 19:59:12 -08:00
  • 2951cc355f Remove cobra comments Ken Hibino 2019-12-07 09:15:46 -08:00
  • 0382fc1d08 Fix readme Ken Hibino 2019-12-07 08:47:17 -08:00
  • ad01341c73 Add ls command to asynqmon Ken Hibino 2019-12-07 07:48:11 -08:00
  • c1d0497182 Remove debug log Ken Hibino 2019-12-06 22:29:40 -08:00
  • 62fb3cf7d9 Add flags to stats command Ken Hibino 2019-12-06 07:36:08 -08:00
  • b749d8bd34 Use cobra for tools Ken Hibino 2019-12-06 06:51:55 -08:00
  • 5c2cb917e1 Change cmd dir to tools Ken Hibino 2019-12-06 06:19:53 -08:00
  • e658f04648
    Merge pull request #7 from hibiken/feature/doc Ken Hibino 2019-12-06 22:04:21 -08:00
  • aa8a3b8aaa Update exported package API docs Ken Hibino 2019-12-06 22:00:09 -08:00
  • 46e84769b5 Add doc.go for package documentation Ken Hibino 2019-12-06 06:12:44 -08:00
  • 20ad6daa6e Update todos Ken Hibino 2019-12-05 17:28:05 -08:00
  • 3d72ca5a74
    Merge pull request #6 from hibiken/refactor/internalpkg Ken Hibino 2019-12-05 17:18:01 -08:00
  • 5626670007 Update asynqmon Ken Hibino 2019-12-05 17:14:35 -08:00
  • f3b9745228 Add tests for rdb list methods Ken Hibino 2019-12-04 20:30:37 -08:00
  • 437fb03bb3 Unexport redis key name constants from rdb package Ken Hibino 2019-12-04 17:23:11 -08:00
  • 918f33d37d Implement all "list tasks" methods in rdb Ken Hibino 2019-12-04 17:10:39 -08:00
  • afacc31990 Minor improvements Ken Hibino 2019-12-04 16:56:10 -08:00
  • 998e761660 Use different redis db for each package tests origin/feature/inspector Ken Hibino 2019-12-04 07:38:55 -08:00
  • 28bfb6d83a Rename to CheckAndEnqueue Ken Hibino 2019-12-04 07:28:57 -08:00
  • af1dcf5044 Fix monitor command Ken Hibino 2019-12-04 07:18:15 -08:00
  • 4684f961c0 Refactor forwarding of scheduled tasks Ken Hibino 2019-12-04 07:14:37 -08:00
  • 318b24b3b8 Rename MoveAll to RestoreUnfinished Ken Hibino 2019-12-04 06:50:52 -08:00
  • 4531e90b9d Define Schedule and RetryLater method for RDB Ken Hibino 2019-12-04 06:45:30 -08:00