1 files changed, 36 insertions, 3 deletions

diff --git a/src/MasterClient.php b/src/MasterClient.php
index d85e454..2fed338 100644
--- a/src/MasterClient.php
+++ b/src/MasterClient.php
@@ -2,6 +2,10 @@
 
 namespace jobd;
 
+use jobd\exceptions\JobdException;
+use jobd\messages\RequestMessage;
+use jobd\messages\ResponseMessage;
+
 class MasterClient extends Client {
 
     public function __construct(int $port = Client::MASTER_PORT, ...$args)
@@ -12,7 +16,7 @@ class MasterClient extends Client {
     /**
      * @param array $targets
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function poke(array $targets): ResponseMessage
     {
@@ -24,7 +28,7 @@ class MasterClient extends Client {
     /**
      * @param bool $poll_workers
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function status(bool $poll_workers = false): ResponseMessage
     {
@@ -36,7 +40,7 @@ class MasterClient extends Client {
     /**
      * @param array[] $jobs
      * @return ResponseMessage
-     * @throws Exception
+     * @throws JobdException
      */
     public function runManual(array $jobs): ResponseMessage
     {
@@ -45,4 +49,33 @@ class MasterClient extends Client {
         );
     }
 
+    /**
+     * @param int $job_id
+     * @param int $signal
+     * @param string $target
+     * @return ResponseMessage
+     * @throws JobdException
+     */
+    public function sendSignal(int $job_id, int $signal, string $target): ResponseMessage
+    {
+        return $this->sendSignals([
+            [
+                'id' => $job_id,
+                'signal' => $signal,
+                'target' => $target
+            ]
+        ]);
+    }
+
+    /**
+     * @param array $data
+     * @return ResponseMessage
+     * @throws JobdException
+     */
+    public function sendSignals(array $data): ResponseMessage {
+        return $this->recv(
+            $this->sendRequest(new RequestMessage('send-signal', ['jobs' => $data]))
+        );
+    }
+
 }
\ No newline at end of file