From d0fa8d6f63003a6cb2f1897158bc587ab2344ea3 Mon Sep 17 00:00:00 2001
From: Evgeny Zinoviev <me@ch1p.io>
Date: Thu, 13 Apr 2023 02:14:53 +0300
Subject: 1.6.0: support signals

---
 src/WorkerClient.php | 22 +++++++++++++++++++---
 1 file changed, 19 insertions(+), 3 deletions(-)

(limited to 'src/WorkerClient.php')

diff --git a/src/WorkerClient.php b/src/WorkerClient.php
index 2773de5..16f8963 100644
--- a/src/WorkerClient.php
+++ b/src/WorkerClient.php
@@ -2,6 +2,10 @@
 
 namespace jobd;
 
+use jobd\exceptions\JobdException;
+use jobd\messages\RequestMessage;
+use jobd\messages\ResponseMessage;
+
 class WorkerClient extends Client {
 
     public function __construct(int $port = Client::WORKER_PORT, ...$args)
@@ -48,11 +52,23 @@ class WorkerClient extends Client {
         );
     }
 
+    /**
+     * @param array[] $jobs
+     * @return ResponseMessage
+     * @throws JobdException
+     */
+    public function sendSignal(array $jobs): ResponseMessage
+    {
+        return $this->recv(
+            $this->sendRequest(new RequestMessage('send-signal', ['jobs' => $jobs]))
+        );
+    }
+
     /**
      * @param string $target
      * @param int $concurrency
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function addTarget(string $target, int $concurrency): ResponseMessage
     {
@@ -67,7 +83,7 @@ class WorkerClient extends Client {
     /**
      * @param string $target
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function removeTarget(string $target): ResponseMessage
     {
@@ -82,7 +98,7 @@ class WorkerClient extends Client {
      * @param string $target
      * @param int $concurrency
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function setTargetConcurrency(string $target, int $concurrency): ResponseMessage
     {
-- 
cgit v1.2.3