From 613fd5fd3e7641732c54e21f771cbc2d6cc2651e Mon Sep 17 00:00:00 2001
From: Evgeny Zinoviev <me@ch1p.io>
Date: Fri, 5 Mar 2021 03:01:06 +0300
Subject: jobd: add set-target-concurrency request

---
 src/lib/worker.js | 11 +++++++++++
 1 file changed, 11 insertions(+)

(limited to 'src/lib')

diff --git a/src/lib/worker.js b/src/lib/worker.js
index beba7f9..e53d03f 100644
--- a/src/lib/worker.js
+++ b/src/lib/worker.js
@@ -72,6 +72,17 @@ class Worker extends EventEmitter {
         }
     }
 
+    /**
+     * @param {string} target
+     * @param {number} concurrency
+     */
+    setTargetConcurrency(target, concurrency) {
+        if (!(target in this.targets))
+            throw new Error(`target '${target}' not found`)
+
+        this.targets[target].queue.concurrency = concurrency
+    }
+
     /**
      * Stop queues associated with specified targets.
      *
-- 
cgit v1.2.3