New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
provide a response description for supervisor status api #15031
provide a response description for supervisor status api #15031
Conversation
@@ -1311,6 +1311,29 @@ Host: http://ROUTER_IP:ROUTER_PORT | |||
``` | |||
</details> | |||
|
|||
#### Response Description | |||
The response `payload` contains the following structure: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The response `payload` contains the following structure: | |
The response `payload` contains the following properties: |
|Property|Type|Description| | ||
|---|---|---| | ||
|`dataSource`|String|The target datasource.| | ||
|`stream`|String|Name of the topic or stream that the ingestion is reading from.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`stream`|String|Name of the topic or stream that the ingestion is reading from.| | |
|`stream`|String|The name of the topic or stream that the ingestion is reading from.| |
|---|---|---| | ||
|`dataSource`|String|The target datasource.| | ||
|`stream`|String|Name of the topic or stream that the ingestion is reading from.| | ||
|`partitions`|Integer|Number of partitions in the source stream.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`partitions`|Integer|Number of partitions in the source stream.| | |
|`partitions`|Integer|The number of partitions in the source stream.| |
|`dataSource`|String|The target datasource.| | ||
|`stream`|String|Name of the topic or stream that the ingestion is reading from.| | ||
|`partitions`|Integer|Number of partitions in the source stream.| | ||
|`replicas`|Integer|Number of replicas being used per task for high availability where 1 means no redundancy.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`replicas`|Integer|Number of replicas being used per task for high availability where 1 means no redundancy.| | |
|`replicas`|Integer|The number of replicas being used per task for high availability where 1 means no redundancy.| |
|`stream`|String|Name of the topic or stream that the ingestion is reading from.| | ||
|`partitions`|Integer|Number of partitions in the source stream.| | ||
|`replicas`|Integer|Number of replicas being used per task for high availability where 1 means no redundancy.| | ||
|`durationSeconds`|Integer|Seconds that each task spends reading before moving to a publishing state.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`durationSeconds`|Integer|Seconds that each task spends reading before moving to a publishing state.| | |
|`durationSeconds`|Integer|The number of seconds that each task spends reading before moving to a publishing state.| |
|`replicas`|Integer|Number of replicas being used per task for high availability where 1 means no redundancy.| | ||
|`durationSeconds`|Integer|Seconds that each task spends reading before moving to a publishing state.| | ||
|`activeTasks`|Array of Object|Lists the tasks that are reading from the stream, each with: <table><tbody><tr><td>`startTime`</td><td>String</td><td>Task start time.</td></tr><tr><td>`remainingTime`</td><td>Integer</td><td>The time remaining in the reading state</td><tr><tr><td>`currentOffsets`</td><td>Map < String , Integer ></td><td>The list of partitions that the task is reading from with the latest offset consumed from each.</td></tr><tr><td>`lag`</td><td>Map < String , Integer ></td><td>The number of messages pending to read from each partition.</td></tr></tbody></table> | | ||
|`publishingTasks`|Array of Object|Lists the tasks that are publishing segments to Deep Storage and awaiting handoff confirmation. For detailed structure see `activeTasks` above.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`publishingTasks`|Array of Object|Lists the tasks that are publishing segments to Deep Storage and awaiting handoff confirmation. For detailed structure see `activeTasks` above.| | |
|`publishingTasks`|Array of objects|Lists the tasks that are publishing segments to Deep Storage and awaiting handoff confirmation. For detailed structure see `activeTasks` above.| |
|`activeTasks`|Array of Object|Lists the tasks that are reading from the stream, each with: <table><tbody><tr><td>`startTime`</td><td>String</td><td>Task start time.</td></tr><tr><td>`remainingTime`</td><td>Integer</td><td>The time remaining in the reading state</td><tr><tr><td>`currentOffsets`</td><td>Map < String , Integer ></td><td>The list of partitions that the task is reading from with the latest offset consumed from each.</td></tr><tr><td>`lag`</td><td>Map < String , Integer ></td><td>The number of messages pending to read from each partition.</td></tr></tbody></table> | | ||
|`publishingTasks`|Array of Object|Lists the tasks that are publishing segments to Deep Storage and awaiting handoff confirmation. For detailed structure see `activeTasks` above.| | ||
|`latestOffsets`|Map < String, Integer >|The lastest offset consumed from the stream by partition.| | ||
|`minimumLag`|Map < String, Integer >|The number of messages pending to read from stream by partition.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`minimumLag`|Map < String, Integer >|The number of messages pending to read from stream by partition.| | |
|`minimumLag`|`Map < String, Integer >`|The number of messages pending to read from the stream by partition.| |
Should the Map interface be in code font?
|`latestOffsets`|Map < String, Integer >|The lastest offset consumed from the stream by partition.| | ||
|`minimumLag`|Map < String, Integer >|The number of messages pending to read from stream by partition.| | ||
|`aggregateLag`|Integer|The sum of minimum lags (see above) across all partitions.| | ||
|`offsetLastUpdated`|String|Contains the timestamp of when the stream offsets were last inspected.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`offsetLastUpdated`|String|Contains the timestamp of when the stream offsets were last inspected.| | |
|`offsetLastUpdated`|String|The timestamp of when the stream offsets were last inspected.| |
|`minimumLag`|Map < String, Integer >|The number of messages pending to read from stream by partition.| | ||
|`aggregateLag`|Integer|The sum of minimum lags (see above) across all partitions.| | ||
|`offsetLastUpdated`|String|Contains the timestamp of when the stream offsets were last inspected.| | ||
|`suspended`|Boolean|True if the supervisor is in a SUSPENDED state.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`suspended`|Boolean|True if the supervisor is in a SUSPENDED state.| | |
|`suspended`|Boolean|True if the supervisor is in a `SUSPENDED` state.| |
|`suspended`|Boolean|True if the supervisor is in a SUSPENDED state.| | ||
|`healthy`|Boolean|True if the supervisor and its tasks are currently healthy.| | ||
|`state`|String|Overall state of the supervisor. | | ||
|`detailedState`|String|Current stage of processing for the supervisor.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`detailedState`|String|Current stage of processing for the supervisor.| | |
|`detailedState`|String|Current stage of processing for the supervisor.| |
Should this say "state" instead of "stage"?
|`healthy`|Boolean|True if the supervisor and its tasks are currently healthy.| | ||
|`state`|String|Overall state of the supervisor. | | ||
|`detailedState`|String|Current stage of processing for the supervisor.| | ||
|`recentErrors`|Array of String|Errors reported recently by supervisor managed tasks.| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|`recentErrors`|Array of String|Errors reported recently by supervisor managed tasks.| | |
|`recentErrors`|Array of strings|Errors reported recently by supervisor managed tasks.| |
|`partitions`|Integer|Number of partitions in the source stream.| | ||
|`replicas`|Integer|Number of replicas being used per task for high availability where 1 means no redundancy.| | ||
|`durationSeconds`|Integer|Seconds that each task spends reading before moving to a publishing state.| | ||
|`activeTasks`|Array of Object|Lists the tasks that are reading from the stream, each with: <table><tbody><tr><td>`startTime`</td><td>String</td><td>Task start time.</td></tr><tr><td>`remainingTime`</td><td>Integer</td><td>The time remaining in the reading state</td><tr><tr><td>`currentOffsets`</td><td>Map < String , Integer ></td><td>The list of partitions that the task is reading from with the latest offset consumed from each.</td></tr><tr><td>`lag`</td><td>Map < String , Integer ></td><td>The number of messages pending to read from each partition.</td></tr></tbody></table> | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Instead of a nested table, consider creating a separate table for activeTasks
properties.
Also, the Map interface should probably be in code font.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Left some suggestions. Also, I think "array of objects" reads better than "array of object". Unless "array of object" is the correct way of referring to array values.
This pull request has been marked as stale due to 60 days of inactivity. |
This pull request/issue has been closed due to lack of activity. If you think that |
Description
Provides a description for the response to the supervisor status API.
This PR has: