Skip to content

Commit 0c5d813

Browse files
feat(dataflow): update the api
#### dataflow:v1b3 The following keys were added: - schemas.StreamingScalingReport (Total Keys: 14) - schemas.WorkerMessage.properties.streamingScalingReport.$ref (Total Keys: 1)
1 parent 2be21be commit 0c5d813

File tree

3 files changed

+58
-1
lines changed

3 files changed

+58
-1
lines changed

docs/dyn/dataflow_v1b3.projects.html

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,14 @@ <h3>Method Details</h3>
154154
&quot;labels&quot;: { # Labels are used to group WorkerMessages. For example, a worker_message about a particular container might have the labels: { &quot;JOB_ID&quot;: &quot;2015-04-22&quot;, &quot;WORKER_ID&quot;: &quot;wordcount-vm-2015…&quot; &quot;CONTAINER_TYPE&quot;: &quot;worker&quot;, &quot;CONTAINER_ID&quot;: &quot;ac1234def&quot;} Label tags typically correspond to Label enum values. However, for ease of development other strings can be used as tags. LABEL_UNSPECIFIED should not be used here.
155155
&quot;a_key&quot;: &quot;A String&quot;,
156156
},
157+
&quot;streamingScalingReport&quot;: { # Contains per-user worker telemetry used in streaming autoscaling. # Contains per-user worker telemetry used in streaming autoscaling.
158+
&quot;activeBundleCount&quot;: 42, # Current acive bundle count.
159+
&quot;activeThreadCount&quot;: 42, # Current acive thread count.
160+
&quot;maximumBundleCount&quot;: 42, # Maximum bundle count limit.
161+
&quot;maximumBytesCount&quot;: 42, # Maximum bytes count limit.
162+
&quot;maximumThreadCount&quot;: 42, # Maximum thread count limit.
163+
&quot;outstandingBytesCount&quot;: 42, # Current outstanding bytes count.
164+
},
157165
&quot;time&quot;: &quot;A String&quot;, # The timestamp of the worker_message.
158166
&quot;workerHealthReport&quot;: { # WorkerHealthReport contains information about the health of a worker. The VM should be identified by the labels attached to the WorkerMessage that this health ping belongs to. # The health of a worker.
159167
&quot;msg&quot;: &quot;A String&quot;, # Message describing any unusual health reports.

docs/dyn/dataflow_v1b3.projects.locations.html

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -132,6 +132,14 @@ <h3>Method Details</h3>
132132
&quot;labels&quot;: { # Labels are used to group WorkerMessages. For example, a worker_message about a particular container might have the labels: { &quot;JOB_ID&quot;: &quot;2015-04-22&quot;, &quot;WORKER_ID&quot;: &quot;wordcount-vm-2015…&quot; &quot;CONTAINER_TYPE&quot;: &quot;worker&quot;, &quot;CONTAINER_ID&quot;: &quot;ac1234def&quot;} Label tags typically correspond to Label enum values. However, for ease of development other strings can be used as tags. LABEL_UNSPECIFIED should not be used here.
133133
&quot;a_key&quot;: &quot;A String&quot;,
134134
},
135+
&quot;streamingScalingReport&quot;: { # Contains per-user worker telemetry used in streaming autoscaling. # Contains per-user worker telemetry used in streaming autoscaling.
136+
&quot;activeBundleCount&quot;: 42, # Current acive bundle count.
137+
&quot;activeThreadCount&quot;: 42, # Current acive thread count.
138+
&quot;maximumBundleCount&quot;: 42, # Maximum bundle count limit.
139+
&quot;maximumBytesCount&quot;: 42, # Maximum bytes count limit.
140+
&quot;maximumThreadCount&quot;: 42, # Maximum thread count limit.
141+
&quot;outstandingBytesCount&quot;: 42, # Current outstanding bytes count.
142+
},
135143
&quot;time&quot;: &quot;A String&quot;, # The timestamp of the worker_message.
136144
&quot;workerHealthReport&quot;: { # WorkerHealthReport contains information about the health of a worker. The VM should be identified by the labels attached to the WorkerMessage that this health ping belongs to. # The health of a worker.
137145
&quot;msg&quot;: &quot;A String&quot;, # Message describing any unusual health reports.

googleapiclient/discovery_cache/documents/dataflow.v1b3.json

Lines changed: 42 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2221,7 +2221,7 @@
22212221
}
22222222
}
22232223
},
2224-
"revision": "20231130",
2224+
"revision": "20231203",
22252225
"rootUrl": "https://dataflow.googleapis.com/",
22262226
"schemas": {
22272227
"ApproximateProgress": {
@@ -6503,6 +6503,43 @@
65036503
},
65046504
"type": "object"
65056505
},
6506+
"StreamingScalingReport": {
6507+
"description": "Contains per-user worker telemetry used in streaming autoscaling.",
6508+
"id": "StreamingScalingReport",
6509+
"properties": {
6510+
"activeBundleCount": {
6511+
"description": "Current acive bundle count.",
6512+
"format": "int32",
6513+
"type": "integer"
6514+
},
6515+
"activeThreadCount": {
6516+
"description": "Current acive thread count.",
6517+
"format": "int32",
6518+
"type": "integer"
6519+
},
6520+
"maximumBundleCount": {
6521+
"description": "Maximum bundle count limit.",
6522+
"format": "int32",
6523+
"type": "integer"
6524+
},
6525+
"maximumBytesCount": {
6526+
"description": "Maximum bytes count limit.",
6527+
"format": "int32",
6528+
"type": "integer"
6529+
},
6530+
"maximumThreadCount": {
6531+
"description": "Maximum thread count limit.",
6532+
"format": "int32",
6533+
"type": "integer"
6534+
},
6535+
"outstandingBytesCount": {
6536+
"description": "Current outstanding bytes count.",
6537+
"format": "int32",
6538+
"type": "integer"
6539+
}
6540+
},
6541+
"type": "object"
6542+
},
65066543
"StreamingSetupTask": {
65076544
"description": "A task which initializes part of a streaming Dataflow job.",
65086545
"id": "StreamingSetupTask",
@@ -7236,6 +7273,10 @@
72367273
"description": "Labels are used to group WorkerMessages. For example, a worker_message about a particular container might have the labels: { \"JOB_ID\": \"2015-04-22\", \"WORKER_ID\": \"wordcount-vm-2015\u2026\" \"CONTAINER_TYPE\": \"worker\", \"CONTAINER_ID\": \"ac1234def\"} Label tags typically correspond to Label enum values. However, for ease of development other strings can be used as tags. LABEL_UNSPECIFIED should not be used here.",
72377274
"type": "object"
72387275
},
7276+
"streamingScalingReport": {
7277+
"$ref": "StreamingScalingReport",
7278+
"description": "Contains per-user worker telemetry used in streaming autoscaling."
7279+
},
72397280
"time": {
72407281
"description": "The timestamp of the worker_message.",
72417282
"format": "google-datetime",

0 commit comments

Comments
 (0)