|
2115 | 2115 | ] |
2116 | 2116 | } |
2117 | 2117 | }, |
2118 | | - "/api/v1/namespaces/{namespace}/worker-heartbeat": { |
2119 | | - "post": { |
2120 | | - "summary": "WorkerHeartbeat receive heartbeat request from the worker.", |
2121 | | - "operationId": "WorkerHeartbeat2", |
2122 | | - "responses": { |
2123 | | - "200": { |
2124 | | - "description": "A successful response.", |
2125 | | - "schema": { |
2126 | | - "$ref": "#/definitions/v1WorkerHeartbeatResponse" |
2127 | | - } |
2128 | | - }, |
2129 | | - "default": { |
2130 | | - "description": "An unexpected error response.", |
2131 | | - "schema": { |
2132 | | - "$ref": "#/definitions/rpcStatus" |
2133 | | - } |
2134 | | - } |
2135 | | - }, |
2136 | | - "parameters": [ |
2137 | | - { |
2138 | | - "name": "namespace", |
2139 | | - "description": "Namespace of the workflow which scheduled this activity.", |
2140 | | - "in": "path", |
2141 | | - "required": true, |
2142 | | - "type": "string" |
2143 | | - }, |
2144 | | - { |
2145 | | - "name": "body", |
2146 | | - "in": "body", |
2147 | | - "required": true, |
2148 | | - "schema": { |
2149 | | - "$ref": "#/definitions/WorkflowServiceWorkerHeartbeatBody" |
2150 | | - } |
2151 | | - } |
2152 | | - ], |
2153 | | - "tags": [ |
2154 | | - "WorkflowService" |
2155 | | - ] |
2156 | | - } |
2157 | | - }, |
2158 | 2118 | "/api/v1/namespaces/{namespace}/worker-task-reachability": { |
2159 | 2119 | "get": { |
2160 | 2120 | "summary": "Deprecated. Use `DescribeTaskQueue`.", |
|
2226 | 2186 | }, |
2227 | 2187 | "/api/v1/namespaces/{namespace}/workers": { |
2228 | 2188 | "get": { |
2229 | | - "summary": "ListWorkerStatus is a visibility API to list worker status information in a specific namespace.", |
2230 | | - "operationId": "ListWorkerStatus2", |
| 2189 | + "summary": "ListWorkers is a visibility API to list worker status information in a specific namespace.", |
| 2190 | + "operationId": "ListWorkers2", |
2231 | 2191 | "responses": { |
2232 | 2192 | "200": { |
2233 | 2193 | "description": "A successful response.", |
2234 | 2194 | "schema": { |
2235 | | - "$ref": "#/definitions/v1ListWorkerStatusResponse" |
| 2195 | + "$ref": "#/definitions/v1ListWorkersResponse" |
2236 | 2196 | } |
2237 | 2197 | }, |
2238 | 2198 | "default": { |
|
2275 | 2235 | ] |
2276 | 2236 | } |
2277 | 2237 | }, |
| 2238 | + "/api/v1/namespaces/{namespace}/workers/heartbeat": { |
| 2239 | + "post": { |
| 2240 | + "summary": "WorkerHeartbeat receive heartbeat request from the worker.", |
| 2241 | + "operationId": "RecordWorkerHeartbeat2", |
| 2242 | + "responses": { |
| 2243 | + "200": { |
| 2244 | + "description": "A successful response.", |
| 2245 | + "schema": { |
| 2246 | + "$ref": "#/definitions/v1RecordWorkerHeartbeatResponse" |
| 2247 | + } |
| 2248 | + }, |
| 2249 | + "default": { |
| 2250 | + "description": "An unexpected error response.", |
| 2251 | + "schema": { |
| 2252 | + "$ref": "#/definitions/rpcStatus" |
| 2253 | + } |
| 2254 | + } |
| 2255 | + }, |
| 2256 | + "parameters": [ |
| 2257 | + { |
| 2258 | + "name": "namespace", |
| 2259 | + "description": "Namespace of the workflow which scheduled this activity.", |
| 2260 | + "in": "path", |
| 2261 | + "required": true, |
| 2262 | + "type": "string" |
| 2263 | + }, |
| 2264 | + { |
| 2265 | + "name": "body", |
| 2266 | + "in": "body", |
| 2267 | + "required": true, |
| 2268 | + "schema": { |
| 2269 | + "$ref": "#/definitions/WorkflowServiceRecordWorkerHeartbeatBody" |
| 2270 | + } |
| 2271 | + } |
| 2272 | + ], |
| 2273 | + "tags": [ |
| 2274 | + "WorkflowService" |
| 2275 | + ] |
| 2276 | + } |
| 2277 | + }, |
2278 | 2278 | "/api/v1/namespaces/{namespace}/workflow-count": { |
2279 | 2279 | "get": { |
2280 | 2280 | "summary": "CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.", |
|
5718 | 5718 | "/namespaces/{namespace}/worker-heartbeat": { |
5719 | 5719 | "post": { |
5720 | 5720 | "summary": "WorkerHeartbeat receive heartbeat request from the worker.", |
5721 | | - "operationId": "WorkerHeartbeat", |
| 5721 | + "operationId": "RecordWorkerHeartbeat", |
5722 | 5722 | "responses": { |
5723 | 5723 | "200": { |
5724 | 5724 | "description": "A successful response.", |
5725 | 5725 | "schema": { |
5726 | | - "$ref": "#/definitions/v1WorkerHeartbeatResponse" |
| 5726 | + "$ref": "#/definitions/v1RecordWorkerHeartbeatResponse" |
5727 | 5727 | } |
5728 | 5728 | }, |
5729 | 5729 | "default": { |
|
5746 | 5746 | "in": "body", |
5747 | 5747 | "required": true, |
5748 | 5748 | "schema": { |
5749 | | - "$ref": "#/definitions/WorkflowServiceWorkerHeartbeatBody" |
| 5749 | + "$ref": "#/definitions/WorkflowServiceRecordWorkerHeartbeatBody" |
5750 | 5750 | } |
5751 | 5751 | } |
5752 | 5752 | ], |
|
5826 | 5826 | }, |
5827 | 5827 | "/namespaces/{namespace}/workers": { |
5828 | 5828 | "get": { |
5829 | | - "summary": "ListWorkerStatus is a visibility API to list worker status information in a specific namespace.", |
5830 | | - "operationId": "ListWorkerStatus", |
| 5829 | + "summary": "ListWorkers is a visibility API to list worker status information in a specific namespace.", |
| 5830 | + "operationId": "ListWorkers", |
5831 | 5831 | "responses": { |
5832 | 5832 | "200": { |
5833 | 5833 | "description": "A successful response.", |
5834 | 5834 | "schema": { |
5835 | | - "$ref": "#/definitions/v1ListWorkerStatusResponse" |
| 5835 | + "$ref": "#/definitions/v1ListWorkersResponse" |
5836 | 5836 | } |
5837 | 5837 | }, |
5838 | 5838 | "default": { |
|
7567 | 7567 | } |
7568 | 7568 | } |
7569 | 7569 | }, |
| 7570 | + "WorkflowServiceRecordWorkerHeartbeatBody": { |
| 7571 | + "type": "object", |
| 7572 | + "properties": { |
| 7573 | + "identity": { |
| 7574 | + "type": "string", |
| 7575 | + "description": "The identity of the client who initiated this request." |
| 7576 | + }, |
| 7577 | + "workerStatus": { |
| 7578 | + "$ref": "#/definitions/v1WorkerStatus" |
| 7579 | + } |
| 7580 | + } |
| 7581 | + }, |
7570 | 7582 | "WorkflowServiceRequestCancelWorkflowExecutionBody": { |
7571 | 7583 | "type": "object", |
7572 | 7584 | "properties": { |
|
8531 | 8543 | }, |
8532 | 8544 | "description": "Keep the parameters in sync with:\n - temporal.api.batch.v1.BatchOperationUpdateWorkflowExecutionOptions.\n - temporal.api.workflow.v1.PostResetOperation.UpdateWorkflowOptions." |
8533 | 8545 | }, |
8534 | | - "WorkflowServiceWorkerHeartbeatBody": { |
8535 | | - "type": "object", |
8536 | | - "properties": { |
8537 | | - "identity": { |
8538 | | - "type": "string", |
8539 | | - "description": "The identity of the client who initiated this request." |
8540 | | - }, |
8541 | | - "workerStatus": { |
8542 | | - "$ref": "#/definitions/v1WorkerStatus" |
8543 | | - } |
8544 | | - } |
8545 | | - }, |
8546 | 8546 | "apicommonv1Link": { |
8547 | 8547 | "type": "object", |
8548 | 8548 | "properties": { |
|
11361 | 11361 | } |
11362 | 11362 | } |
11363 | 11363 | }, |
11364 | | - "v1ListWorkerStatusResponse": { |
| 11364 | + "v1ListWorkersResponse": { |
11365 | 11365 | "type": "object", |
11366 | 11366 | "properties": { |
11367 | 11367 | "workerStatus": { |
|
12711 | 12711 | } |
12712 | 12712 | } |
12713 | 12713 | }, |
| 12714 | + "v1RecordWorkerHeartbeatResponse": { |
| 12715 | + "type": "object" |
| 12716 | + }, |
12714 | 12717 | "v1RegisterNamespaceRequest": { |
12715 | 12718 | "type": "object", |
12716 | 12719 | "properties": { |
@@ -15257,43 +15260,53 @@ |
15257 | 15260 | "default": "WORKER_DEPLOYMENT_VERSION_STATUS_UNSPECIFIED", |
15258 | 15261 | "description": "Specify the status of a Worker Deployment Version.\nExperimental. Worker Deployments are experimental and might significantly change in the future.\n\n - WORKER_DEPLOYMENT_VERSION_STATUS_INACTIVE: The Worker Deployment Version has been created inside the Worker Deployment but is not used by any\nworkflow executions. These Versions can still have workflows if they have an explicit Versioning Override targeting\nthis Version. Such Versioning Override could be set at workflow start time, or at a later time via `UpdateWorkflowExecutionOptions`.\n - WORKER_DEPLOYMENT_VERSION_STATUS_CURRENT: The Worker Deployment Version is the current version of the Worker Deployment. All new workflow executions \nand tasks of existing unversioned or AutoUpgrade workflows are routed to this version.\n - WORKER_DEPLOYMENT_VERSION_STATUS_RAMPING: The Worker Deployment Version is the ramping version of the Worker Deployment. A subset of new Pinned workflow executions are \nrouted to this version. Moreover, a portion of existing unversioned or AutoUpgrade workflow executions are also routed to this version.\n - WORKER_DEPLOYMENT_VERSION_STATUS_DRAINING: The Worker Deployment Version is not used by new workflows but is still used by\nopen pinned workflows. The version cannot be decommissioned safely.\n - WORKER_DEPLOYMENT_VERSION_STATUS_DRAINED: The Worker Deployment Version is not used by new or open workflows, but might be still needed by\nQueries sent to closed workflows. The version can be decommissioned safely if user does\nnot query closed workflows. If the user does query closed workflows for some time x after\nworkflows are closed, they should decommission the version after it has been drained for that duration." |
15259 | 15262 | }, |
15260 | | - "v1WorkerHeartbeatResponse": { |
15261 | | - "type": "object" |
| 15263 | + "v1WorkerHostInfo": { |
| 15264 | + "type": "object", |
| 15265 | + "properties": { |
| 15266 | + "hostId": { |
| 15267 | + "type": "string", |
| 15268 | + "description": "worker host identifier, should be unique for the namespace." |
| 15269 | + }, |
| 15270 | + "processId": { |
| 15271 | + "type": "string", |
| 15272 | + "description": "worker process identifier, should be unique for the host." |
| 15273 | + }, |
| 15274 | + "hostContext": { |
| 15275 | + "type": "string", |
| 15276 | + "title": "freeform (e.g. \"k8s container abc123\", etc.)" |
| 15277 | + }, |
| 15278 | + "workerIdentity": { |
| 15279 | + "type": "string", |
| 15280 | + "description": "Worker identity, set by the worker, may not be unique." |
| 15281 | + } |
| 15282 | + }, |
| 15283 | + "title": "Holds everything needed to identify the host/process context" |
15262 | 15284 | }, |
15263 | 15285 | "v1WorkerStatus": { |
15264 | 15286 | "type": "object", |
15265 | 15287 | "properties": { |
15266 | | - "namespaceId": { |
15267 | | - "type": "string" |
15268 | | - }, |
15269 | 15288 | "workerId": { |
15270 | | - "type": "string" |
| 15289 | + "type": "string", |
| 15290 | + "description": "Worker identifier, should be unique for the namespace. Required." |
15271 | 15291 | }, |
15272 | | - "hostId": { |
15273 | | - "type": "string" |
| 15292 | + "hostInfo": { |
| 15293 | + "$ref": "#/definitions/v1WorkerHostInfo", |
| 15294 | + "description": "Worker host information. Required." |
15274 | 15295 | }, |
15275 | 15296 | "taskQueue": { |
15276 | | - "type": "string" |
15277 | | - }, |
15278 | | - "deploymentName": { |
15279 | | - "type": "string" |
| 15297 | + "type": "string", |
| 15298 | + "description": "Task queue this worker is polling for tasks. Required." |
15280 | 15299 | }, |
15281 | | - "buildId": { |
15282 | | - "type": "string" |
| 15300 | + "deploymentVersion": { |
| 15301 | + "$ref": "#/definitions/v1WorkerDeploymentVersion", |
| 15302 | + "description": "Required." |
15283 | 15303 | }, |
15284 | 15304 | "sdkName": { |
15285 | 15305 | "type": "string" |
15286 | 15306 | }, |
15287 | 15307 | "sdkVersion": { |
15288 | 15308 | "type": "string" |
15289 | 15309 | }, |
15290 | | - "workerIdentity": { |
15291 | | - "type": "string" |
15292 | | - }, |
15293 | | - "workerStatus": { |
15294 | | - "type": "integer", |
15295 | | - "format": "int32" |
15296 | | - }, |
15297 | 15310 | "uptime": { |
15298 | 15311 | "type": "string" |
15299 | 15312 | }, |
|
15322 | 15335 | "type": "number", |
15323 | 15336 | "format": "float" |
15324 | 15337 | }, |
15325 | | - "cacheSize": { |
| 15338 | + "maxCacheSize": { |
| 15339 | + "type": "number", |
| 15340 | + "format": "float" |
| 15341 | + }, |
| 15342 | + "availableCacheSize": { |
15326 | 15343 | "type": "number", |
15327 | 15344 | "format": "float" |
15328 | 15345 | } |
|
0 commit comments