blob: 0a4d6b7ca73aeccd755611df8d5ace7170150bb8 [file] [log] [blame]
Nathaniel Manista4f877e52015-06-15 16:44:50 +00001<html><body>
2<style>
3
4body, h1, h2, h3, div, span, p, pre, a {
5 margin: 0;
6 padding: 0;
7 border: 0;
8 font-weight: inherit;
9 font-style: inherit;
10 font-size: 100%;
11 font-family: inherit;
12 vertical-align: baseline;
13}
14
15body {
16 font-size: 13px;
17 padding: 1em;
18}
19
20h1 {
21 font-size: 26px;
22 margin-bottom: 1em;
23}
24
25h2 {
26 font-size: 24px;
27 margin-bottom: 1em;
28}
29
30h3 {
31 font-size: 20px;
32 margin-bottom: 1em;
33 margin-top: 1em;
34}
35
36pre, code {
37 line-height: 1.5;
38 font-family: Monaco, 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', 'Lucida Console', monospace;
39}
40
41pre {
42 margin-top: 0.5em;
43}
44
45h1, h2, h3, p {
46 font-family: Arial, sans serif;
47}
48
49h1, h2, h3 {
50 border-bottom: solid #CCC 1px;
51}
52
53.toc_element {
54 margin-top: 0.5em;
55}
56
57.firstline {
58 margin-left: 2 em;
59}
60
61.method {
62 margin-top: 1em;
63 border: solid 1px #CCC;
64 padding: 1em;
65 background: #EEE;
66}
67
68.details {
69 font-weight: bold;
70 font-size: 14px;
71}
72
73</style>
74
75<h1><a href="dataflow_v1b3.html">Google Dataflow API</a> . <a href="dataflow_v1b3.projects.html">projects</a></h1>
76<h2>Instance Methods</h2>
77<p class="toc_element">
78 <code><a href="dataflow_v1b3.projects.jobs.html">jobs()</a></code>
79</p>
80<p class="firstline">Returns the jobs Resource.</p>
81
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -080082<p class="toc_element">
Jon Wayne Parrott692617a2017-01-06 09:58:29 -080083 <code><a href="dataflow_v1b3.projects.locations.html">locations()</a></code>
84</p>
85<p class="firstline">Returns the locations Resource.</p>
86
87<p class="toc_element">
Jon Wayne Parrott7d5badb2016-08-16 12:44:29 -070088 <code><a href="dataflow_v1b3.projects.templates.html">templates()</a></code>
89</p>
90<p class="firstline">Returns the templates Resource.</p>
91
92<p class="toc_element">
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -080093 <code><a href="#workerMessages">workerMessages(projectId, body, x__xgafv=None)</a></code></p>
94<p class="firstline">Send a worker_message to the service.</p>
95<h3>Method Details</h3>
96<div class="method">
97 <code class="details" id="workerMessages">workerMessages(projectId, body, x__xgafv=None)</code>
98 <pre>Send a worker_message to the service.
99
100Args:
101 projectId: string, The project to send the WorkerMessages to. (required)
102 body: object, The request body. (required)
103 The object takes the form of:
104
105{ # A request for sending worker messages to the service.
106 "workerMessages": [ # The WorkerMessages to send.
107 { # WorkerMessage provides information to the backend about a worker.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400108 "workerHealthReport": { # WorkerHealthReport contains information about the health of a worker. # The health of a worker.
109 #
110 # The VM should be identified by the labels attached to the WorkerMessage that
111 # this health ping belongs to.
Sai Cheemalapati4ba8c232017-06-06 18:46:08 -0400112 "vmStartupTime": "A String", # The time the VM was booted.
113 "reportInterval": "A String", # The interval at which the worker is sending health reports.
114 # The default value of 0 should be interpreted as the field is not being
115 # explicitly set by the worker.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400116 "pods": [ # The pods running on the worker. See:
117 # http://kubernetes.io/v1.1/docs/api-reference/v1/definitions.html#_v1_pod
118 #
119 # This field is used by the worker to send the status of the indvidual
120 # containers running on each worker.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800121 {
122 "a_key": "", # Properties of the object.
123 },
124 ],
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800125 "vmIsHealthy": True or False, # Whether the VM is healthy.
126 },
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400127 "labels": { # Labels are used to group WorkerMessages.
128 # For example, a worker_message about a particular container
129 # might have the labels:
130 # { "JOB_ID": "2015-04-22",
131 # "WORKER_ID": "wordcount-vm-2015…"
132 # "CONTAINER_TYPE": "worker",
133 # "CONTAINER_ID": "ac1234def"}
134 # Label tags typically correspond to Label enum values. However, for ease
135 # of development other strings can be used as tags. LABEL_UNSPECIFIED should
136 # not be used here.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800137 "a_key": "A String",
138 },
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400139 "workerMetrics": { # Worker metrics exported from workers. This contains resource utilization # Resource metrics reported by workers.
140 # metrics accumulated from a variety of sources. For more information, see
141 # go/df-resource-signals.
142 "cpuTime": [ # CPU utilization samples.
143 { # Modeled after information exposed by /proc/stat.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400144 "totalMs": "A String", # Total active CPU time across all cores (ie., non-idle) in milliseconds
145 # since start-up.
Sai Cheemalapati4ba8c232017-06-06 18:46:08 -0400146 "rate": 3.14, # Average CPU utilization rate (% non-idle cpu / second) since previous
147 # sample.
148 "timestamp": "A String", # Timestamp of the measurement.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400149 },
150 ],
151 },
152 "workerMessageCode": { # A message code is used to report status and error messages to the service. # A worker message code.
153 # The message codes are intended to be machine readable. The service will
154 # take care of translating these into user understandable messages if
155 # necessary.
156 #
157 # Example use cases:
158 # 1. Worker processes reporting successful startup.
159 # 2. Worker processes reporting specific errors (e.g. package staging
160 # failure).
161 "code": "A String", # The code is a string intended for consumption by a machine that identifies
162 # the type of message being sent.
163 # Examples:
164 # 1. "HARNESS_STARTED" might be used to indicate the worker harness has
165 # started.
166 # 2. "GCS_DOWNLOAD_ERROR" might be used to indicate an error downloading
167 # a GCS file as part of the boot process of one of the worker containers.
168 #
169 # This is a string and not an enum to make it easy to add new codes without
170 # waiting for an API change.
171 "parameters": { # Parameters contains specific information about the code.
172 #
173 # This is a struct to allow parameters of different types.
174 #
175 # Examples:
176 # 1. For a "HARNESS_STARTED" message parameters might provide the name
177 # of the worker and additional data like timing information.
178 # 2. For a "GCS_DOWNLOAD_ERROR" parameters might contain fields listing
179 # the GCS objects being downloaded and fields containing errors.
180 #
181 # In general complex data structures should be avoided. If a worker
182 # needs to send a specific and complicated data structure then please
183 # consider defining a new proto and adding it to the data oneof in
184 # WorkerMessageResponse.
185 #
186 # Conventions:
187 # Parameters should only be used for information that isn't typically passed
188 # as a label.
189 # hostname and other worker identifiers should almost always be passed
190 # as labels since they will be included on most messages.
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800191 "a_key": "", # Properties of the object.
192 },
193 },
194 "time": "A String", # The timestamp of the worker_message.
195 },
196 ],
Sai Cheemalapati4ba8c232017-06-06 18:46:08 -0400197 "location": "A String", # The location which contains the job
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800198 }
199
200 x__xgafv: string, V1 error format.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400201 Allowed values
202 1 - v1 error format
203 2 - v2 error format
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800204
205Returns:
206 An object of the form:
207
208 { # The response to the worker messages.
209 "workerMessageResponses": [ # The servers response to the worker messages.
Sai Cheemalapatic30d2b52017-03-13 12:12:03 -0400210 { # A worker_message response allows the server to pass information to the
211 # sender.
212 "workerHealthReportResponse": { # WorkerHealthReportResponse contains information returned to the worker # The service's response to a worker's health report.
213 # in response to a health ping.
214 "reportInterval": "A String", # A positive value indicates the worker should change its reporting interval
215 # to the specified value.
216 #
217 # The default value of zero means no change in report rate is requested by
218 # the server.
219 },
220 "workerMetricsResponse": { # Service-side response to WorkerMessage reporting resource utilization. # Service's response to reporting worker metrics (currently empty).
Jon Wayne Parrott36e41bc2016-02-19 16:02:29 -0800221 },
222 },
223 ],
224 }</pre>
225</div>
226
Nathaniel Manista4f877e52015-06-15 16:44:50 +0000227</body></html>