Prepare to release 2.16.0

composer.json

@@ -83,7 +83,8 @@
     "suggest": {
         "ext-grpc": "For Client calls",
         "ext-protobuf": "For better performance",
-        "buggregator/trap": "For better debugging"
+        "buggregator/trap": "For better debugging",
+        "roadrunner/psr-logger": "RoadRunner PSR-3 logger integration"
     },
     "scripts": {
         "get:binaries": [

src/Client/GRPC/ServiceClient.php

@@ -1371,4 +1371,62 @@ public function TriggerWorkflowRule(V1\TriggerWorkflowRuleRequest $arg, ?Context
     {
         return $this->invoke("TriggerWorkflowRule", $arg, $ctx);
     }
+
+    /**
+     * WorkerHeartbeat receive heartbeat request from the worker.
+     *
+     * @throws ServiceClientException
+     */
+    public function RecordWorkerHeartbeat(V1\RecordWorkerHeartbeatRequest $arg, ?ContextInterface $ctx = null): V1\RecordWorkerHeartbeatResponse
+    {
+        return $this->invoke("RecordWorkerHeartbeat", $arg, $ctx);
+    }
+
+    /**
+     * ListWorkers is a visibility API to list worker status information in a specific
+     * namespace.
+     *
+     * @throws ServiceClientException
+     */
+    public function ListWorkers(V1\ListWorkersRequest $arg, ?ContextInterface $ctx = null): V1\ListWorkersResponse
+    {
+        return $this->invoke("ListWorkers", $arg, $ctx);
+    }
+
+    /**
+     * Updates task queue configuration.
+     * For the overall queue rate limit: the rate limit set by this api overrides the
+     * worker-set rate limit,
+     * which uncouples the rate limit from the worker lifecycle.
+     * If the overall queue rate limit is unset, the worker-set rate limit takes
+     * effect.
+     *
+     * @throws ServiceClientException
+     */
+    public function UpdateTaskQueueConfig(V1\UpdateTaskQueueConfigRequest $arg, ?ContextInterface $ctx = null): V1\UpdateTaskQueueConfigResponse
+    {
+        return $this->invoke("UpdateTaskQueueConfig", $arg, $ctx);
+    }
+
+    /**
+     * FetchWorkerConfig returns the worker configuration for a specific worker.
+     *
+     * @throws ServiceClientException
+     */
+    public function FetchWorkerConfig(V1\FetchWorkerConfigRequest $arg, ?ContextInterface $ctx = null): V1\FetchWorkerConfigResponse
+    {
+        return $this->invoke("FetchWorkerConfig", $arg, $ctx);
+    }
+
+    /**
+     * UpdateWorkerConfig updates the worker configuration of one or more workers.
+     * Can be used to partially update the worker configuration.
+     * Can be used to update the configuration of multiple workers.
+     *
+     * @throws ServiceClientException
+     */
+    public function UpdateWorkerConfig(V1\UpdateWorkerConfigRequest $arg, ?ContextInterface $ctx = null): V1\UpdateWorkerConfigResponse
+    {
+        return $this->invoke("UpdateWorkerConfig", $arg, $ctx);
+    }
 }

src/Client/GRPC/ServiceClientInterface.php

@@ -1121,6 +1121,49 @@ public function ListWorkflowRules(V1\ListWorkflowRulesRequest $arg, ?ContextInte
      */
     public function TriggerWorkflowRule(V1\TriggerWorkflowRuleRequest $arg, ?ContextInterface $ctx = null): V1\TriggerWorkflowRuleResponse;
 
+    /**
+     * WorkerHeartbeat receive heartbeat request from the worker.
+     *
+     * @throws ServiceClientException
+     */
+    public function RecordWorkerHeartbeat(V1\RecordWorkerHeartbeatRequest $arg, ?ContextInterface $ctx = null): V1\RecordWorkerHeartbeatResponse;
+
+    /**
+     * ListWorkers is a visibility API to list worker status information in a specific
+     * namespace.
+     *
+     * @throws ServiceClientException
+     */
+    public function ListWorkers(V1\ListWorkersRequest $arg, ?ContextInterface $ctx = null): V1\ListWorkersResponse;
+
+    /**
+     * Updates task queue configuration.
+     * For the overall queue rate limit: the rate limit set by this api overrides the
+     * worker-set rate limit,
+     * which uncouples the rate limit from the worker lifecycle.
+     * If the overall queue rate limit is unset, the worker-set rate limit takes
+     * effect.
+     *
+     * @throws ServiceClientException
+     */
+    public function UpdateTaskQueueConfig(V1\UpdateTaskQueueConfigRequest $arg, ?ContextInterface $ctx = null): V1\UpdateTaskQueueConfigResponse;
+
+    /**
+     * FetchWorkerConfig returns the worker configuration for a specific worker.
+     *
+     * @throws ServiceClientException
+     */
+    public function FetchWorkerConfig(V1\FetchWorkerConfigRequest $arg, ?ContextInterface $ctx = null): V1\FetchWorkerConfigResponse;
+
+    /**
+     * UpdateWorkerConfig updates the worker configuration of one or more workers.
+     * Can be used to partially update the worker configuration.
+     * Can be used to update the configuration of multiple workers.
+     *
+     * @throws ServiceClientException
+     */
+    public function UpdateWorkerConfig(V1\UpdateWorkerConfigRequest $arg, ?ContextInterface $ctx = null): V1\UpdateWorkerConfigResponse;
+
     /**
      * Close the communication channel associated with this stub.
      */