dataflow  v1b3
worker_message.h
1 // Copyright 2010 Google Inc.
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License"); you may not
4 // use this file except in compliance with the License. You may obtain a copy of
5 // the License at
6 //
7 // http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
11 // WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
12 // License for the specific language governing permissions and limitations under
13 // the License.
14 
15 // This code was generated by google-apis-code-generator 1.5.1
16 // Build date: 2018-10-08 17:45:39 UTC
17 // on: 2020-03-19, 02:23:49 UTC
18 // C++ generator version: 0.1.4
19 
20 // ----------------------------------------------------------------------------
21 // NOTE: This file is generated from Google APIs Discovery Service.
22 // Service:
23 // Dataflow API (dataflow/v1b3)
24 // Generated from:
25 // Version: v1b3
26 // Revision: 302
27 // Generated by:
28 // Tool: google-apis-code-generator 1.5.1
29 // C++: 0.1.4
30 #ifndef GOOGLE_DATAFLOW_API_WORKER_MESSAGE_H_
31 #define GOOGLE_DATAFLOW_API_WORKER_MESSAGE_H_
32 
33 #include <string>
34 #include "googleapis/base/macros.h"
35 #include "googleapis/client/data/jsoncpp_data.h"
36 #include "googleapis/strings/stringpiece.h"
37 
38 #include "google/dataflow_api/resource_utilization_report.h"
39 #include "google/dataflow_api/worker_health_report.h"
40 #include "google/dataflow_api/worker_lifecycle_event.h"
41 #include "google/dataflow_api/worker_message_code.h"
42 #include "google/dataflow_api/worker_shutdown_notice.h"
43 
44 namespace Json {
45 class Value;
46 } // namespace Json
47 
48 namespace google_dataflow_api {
49 using namespace googleapis;
50 
56 class WorkerMessage : public client::JsonCppData {
57  public:
63  static WorkerMessage* New();
64 
70  explicit WorkerMessage(const Json::Value& storage);
71 
77  explicit WorkerMessage(Json::Value* storage);
78 
82  virtual ~WorkerMessage();
83 
89  const StringPiece GetTypeName() const {
90  return StringPiece("google_dataflow_api::WorkerMessage");
91  }
92 
98  bool has_labels() const {
99  return Storage().isMember("labels");
100  }
101 
105  void clear_labels() {
106  MutableStorage()->removeMember("labels");
107  }
108 
109 
113  const client::JsonCppAssociativeArray<string > get_labels() const {
114  const Json::Value& storage = Storage("labels");
115  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
116  }
117 
139  client::JsonCppAssociativeArray<string > mutable_labels() {
140  Json::Value* storage = MutableStorage("labels");
141  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
142  }
143 
149  bool has_time() const {
150  return Storage().isMember("time");
151  }
152 
156  void clear_time() {
157  MutableStorage()->removeMember("time");
158  }
159 
160 
164  const StringPiece get_time() const {
165  const Json::Value& v = Storage("time");
166  if (v == Json::Value::null) return StringPiece("");
167  return StringPiece(v.asCString());
168  }
169 
177  void set_time(const StringPiece& value) {
178  *MutableStorage("time") = value.data();
179  }
180 
187  return Storage().isMember("workerHealthReport");
188  }
189 
194  MutableStorage()->removeMember("workerHealthReport");
195  }
196 
197 
202  const WorkerHealthReport get_worker_health_report() const;
203 
212  WorkerHealthReport mutable_workerHealthReport();
213 
220  return Storage().isMember("workerLifecycleEvent");
221  }
222 
227  MutableStorage()->removeMember("workerLifecycleEvent");
228  }
229 
230 
235  const WorkerLifecycleEvent get_worker_lifecycle_event() const;
236 
245  WorkerLifecycleEvent mutable_workerLifecycleEvent();
246 
252  bool has_worker_message_code() const {
253  return Storage().isMember("workerMessageCode");
254  }
255 
260  MutableStorage()->removeMember("workerMessageCode");
261  }
262 
263 
268  const WorkerMessageCode get_worker_message_code() const;
269 
278  WorkerMessageCode mutable_workerMessageCode();
279 
285  bool has_worker_metrics() const {
286  return Storage().isMember("workerMetrics");
287  }
288 
293  MutableStorage()->removeMember("workerMetrics");
294  }
295 
296 
300  const ResourceUtilizationReport get_worker_metrics() const;
301 
310  ResourceUtilizationReport mutable_workerMetrics();
311 
318  return Storage().isMember("workerShutdownNotice");
319  }
320 
325  MutableStorage()->removeMember("workerShutdownNotice");
326  }
327 
328 
333  const WorkerShutdownNotice get_worker_shutdown_notice() const;
334 
343  WorkerShutdownNotice mutable_workerShutdownNotice();
344 
345  private:
346  void operator=(const WorkerMessage&);
347 }; // WorkerMessage
348 } // namespace google_dataflow_api
349 #endif // GOOGLE_DATAFLOW_API_WORKER_MESSAGE_H_
bool has_labels() const
Definition: worker_message.h:98
Definition: worker_message_code.h:58
const StringPiece GetTypeName() const
Definition: worker_message.h:89
bool has_worker_shutdown_notice() const
Definition: worker_message.h:317
bool has_worker_message_code() const
Definition: worker_message.h:252
Definition: resource_utilization_report.h:55
bool has_time() const
Definition: worker_message.h:149
void clear_worker_metrics()
Definition: worker_message.h:292
Definition: worker_message.h:56
void set_time(const StringPiece &value)
Definition: worker_message.h:177
const StringPiece get_time() const
Definition: worker_message.h:164
bool has_worker_lifecycle_event() const
Definition: worker_message.h:219
void clear_worker_message_code()
Definition: worker_message.h:259
void clear_worker_health_report()
Definition: worker_message.h:193
void clear_worker_lifecycle_event()
Definition: worker_message.h:226
Definition: approximate_progress.h:40
Definition: worker_health_report.h:53
const client::JsonCppAssociativeArray< string > get_labels() const
Definition: worker_message.h:113
bool has_worker_health_report() const
Definition: worker_message.h:186
Definition: worker_shutdown_notice.h:52
Definition: worker_lifecycle_event.h:55
bool has_worker_metrics() const
Definition: worker_message.h:285
client::JsonCppAssociativeArray< string > mutable_labels()
Definition: worker_message.h:139
Definition: approximate_progress.cc:42
void clear_time()
Definition: worker_message.h:156
void clear_labels()
Definition: worker_message.h:105
void clear_worker_shutdown_notice()
Definition: worker_message.h:324