diff options
| -rw-r--r-- | src/MasterClient.php | 9 | ||||
| -rw-r--r-- | src/WorkerClient.php | 4 |
2 files changed, 11 insertions, 2 deletions
diff --git a/src/MasterClient.php b/src/MasterClient.php index 6a7902b..d2a8712 100644 --- a/src/MasterClient.php +++ b/src/MasterClient.php @@ -4,6 +4,10 @@ namespace jobd; class MasterClient extends Client { + public function __construct(int $port = Client::MASTER_PORT, ...$args) { + parent::__construct($port, ...$args); + } + /** * @param array $targets * @return ResponseMessage @@ -17,13 +21,14 @@ class MasterClient extends Client { } /** + * @param bool $poll_workers * @return ResponseMessage * @throws \Exception */ - public function status(): ResponseMessage + public function status(bool $poll_workers = false): ResponseMessage { return $this->recv( - $this->sendRequest(new RequestMessage('status')) + $this->sendRequest(new RequestMessage('status', ['poll_workers' => $poll_workers])) ); } diff --git a/src/WorkerClient.php b/src/WorkerClient.php index 4e221df..dbf0f78 100644 --- a/src/WorkerClient.php +++ b/src/WorkerClient.php @@ -4,6 +4,10 @@ namespace jobd; class WorkerClient extends Client { + public function __construct(int $port = Client::WORKER_PORT, ...$args) { + parent::__construct($port, ...$args); + } + /** * @return ResponseMessage * @throws \Exception |