30 #ifndef GOOGLE_DATAFLOW_API_WORKER_MESSAGE_H_ 31 #define GOOGLE_DATAFLOW_API_WORKER_MESSAGE_H_ 34 #include "googleapis/base/macros.h" 35 #include "googleapis/client/data/jsoncpp_data.h" 36 #include "googleapis/strings/stringpiece.h" 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" 90 return StringPiece(
"google_dataflow_api::WorkerMessage");
99 return Storage().isMember(
"labels");
106 MutableStorage()->removeMember(
"labels");
113 const client::JsonCppAssociativeArray<string >
get_labels()
const {
114 const Json::Value& storage = Storage(
"labels");
115 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
140 Json::Value* storage = MutableStorage(
"labels");
141 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
150 return Storage().isMember(
"time");
157 MutableStorage()->removeMember(
"time");
165 const Json::Value& v = Storage(
"time");
166 if (v == Json::Value::null)
return StringPiece(
"");
167 return StringPiece(v.asCString());
178 *MutableStorage(
"time") = value.data();
187 return Storage().isMember(
"workerHealthReport");
194 MutableStorage()->removeMember(
"workerHealthReport");
220 return Storage().isMember(
"workerLifecycleEvent");
227 MutableStorage()->removeMember(
"workerLifecycleEvent");
253 return Storage().isMember(
"workerMessageCode");
260 MutableStorage()->removeMember(
"workerMessageCode");
286 return Storage().isMember(
"workerMetrics");
293 MutableStorage()->removeMember(
"workerMetrics");
318 return Storage().isMember(
"workerShutdownNotice");
325 MutableStorage()->removeMember(
"workerShutdownNotice");
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