From b2cef5900b6e251bed4bc0a02161fd90646d37f0 Mon Sep 17 00:00:00 2001 From: Dan Engelbrecht Date: Wed, 13 Sep 2023 16:13:30 -0400 Subject: job queue and async oplog-import/export (#395) - Feature: New http endpoint for background jobs `/admin/jobs/status` which will return a response listing the currently active background jobs and their status - Feature: New http endpoint for background jobs information `/admin/jobs/status/{jobid}` which will return a response detailing status, pending messages and progress status - GET will return a response detailing status, pending messages and progress status - DELETE will mark the job for cancelling and return without waiting for completion - If status returned is "Complete" or "Aborted" the jobid will be removed from the server and can not be queried again - Feature: New zen command `jobs` to list, get info about and cancel background jobs - If no options are given it will display a list of active background jobs - `--jobid` accepts an id (returned from for example `oplog-export` with `--async`) and will return a response detailing status, pending messages and progress status for that job - `--cancel` can be added when `--jobid` is given which will request zenserver to cancel the background job - Feature: oplog import and export http rpc requests are now async operations that will run in the background - Feature: `oplog-export` and `oplog-import` now reports progress to the console as work progress by default - Feature: `oplog-export` and `oplog-import` can now be cancelled using Ctrl+C - Feature: `oplog-export` and `oplog-import` has a new option `--async` which will only trigger the work and report a background job id back --- src/zencore/zencore.cpp | 2 ++ 1 file changed, 2 insertions(+) (limited to 'src/zencore/zencore.cpp') diff --git a/src/zencore/zencore.cpp b/src/zencore/zencore.cpp index 83e6ea772..84ffee45b 100644 --- a/src/zencore/zencore.cpp +++ b/src/zencore/zencore.cpp @@ -20,6 +20,7 @@ #include #include #include +#include #include #include #include @@ -115,6 +116,7 @@ zencore_forcelinktests() zen::compress_forcelink(); zen::crypto_forcelink(); zen::filesystem_forcelink(); + zen::jobqueue_forcelink(); zen::intmath_forcelink(); zen::iobuffer_forcelink(); zen::logging_forcelink(); -- cgit v1.2.3