2
0
mirror of https://github.com/hibiken/asynq.git synced 2026-06-30 23:33:19 +08:00

Commit Graph

  • 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
  • 985018e1b5 Rename rdb Remove to Done Ken Hibino 2019-12-04 06:33:05 -08:00
  • 39f177dabf Change rdb Dequeue signature Ken Hibino 2019-12-04 06:25:58 -08:00
  • d4e442d04f Extract rdb to internal package Ken Hibino 2019-12-03 21:01:26 -08:00
  • 593f2b0482 Add command "asynqmon" for monitoring Ken Hibino 2019-12-03 20:02:29 -08:00
  • 319d157d47 Change inspector's list methods to return specific task type for each queue Ken Hibino 2019-12-02 07:09:43 -08:00
  • 28dae0fdd3 Add task types specific to each queue Ken Hibino 2019-12-02 06:55:04 -08:00
  • 5446f877ce Add List* methods to Inspector Ken Hibino 2019-12-01 15:01:26 -08:00
  • 9c2d2a612d Create Inspector Ken Hibino 2019-12-01 07:59:52 -08:00
  • 57838600ef Rename to RedisConfig Ken Hibino 2019-12-03 19:43:01 -08:00
  • 4afb3a2401 Merge pull request #5 from hibiken/api/handler Ken Hibino 2019-12-02 20:49:43 -08:00
  • b0a54cd2b2 Change Background API to take Handler interface Ken Hibino 2019-12-02 20:42:21 -08:00
  • 1a996e0d40 Update readme Ken Hibino 2019-12-01 19:03:31 -08:00
  • 1a97d4ba98 Add MIT License Ken Hibino 2019-11-30 10:21:25 -08:00
  • b9cb95b1e1 Add readme Ken Hibino 2019-11-30 09:38:46 -08:00
  • d31532c8f5 Add .travis.yml Ken Hibino 2019-11-30 07:36:43 -08:00
  • 8eb6f04ef4 Move test helpers to asynq_test.go Ken Hibino 2019-11-29 20:53:29 -08:00
  • ad1291e0a1 Add test for background to verify no goroutine leaks Ken Hibino 2019-11-29 20:49:18 -08:00
  • 09662432c8 Update todos Ken Hibino 2019-11-29 20:16:39 -08:00
  • 634af38e3a Add test for client Ken Hibino 2019-11-29 17:40:31 -08:00
  • d53e5d3350 Add test for processor Ken Hibino 2019-11-29 12:48:54 -08:00
  • eed375b138 Add test for poller Ken Hibino 2019-11-29 08:00:43 -08:00
  • facdadd7b0 Change shutdown message to use info level logging Ken Hibino 2019-11-29 07:14:28 -08:00
  • bdbee31b86 Add test for retry task logic Ken Hibino 2019-11-28 11:22:42 -08:00
  • da0bfa1519 Add test for (*rdb).kill Ken Hibino 2019-11-28 07:47:12 -08:00
  • 481d3c6b77 Refactor rdb tests Ken Hibino 2019-11-28 07:17:07 -08:00
  • e5e3fee742 Add test for (*rdb).remove Ken Hibino 2019-11-28 06:50:05 -08:00
  • 1617278d86 Rename (*rdb).lrem to (*rdb).remove Ken Hibino 2019-11-27 20:05:31 -08:00
  • efaceb8a03 Clean up error messages from rdb methods Ken Hibino 2019-11-27 19:43:33 -08:00
  • c9a8f5fabd Minor cleanup Ken Hibino 2019-11-27 19:36:56 -08:00