30 #ifndef GOOGLE_DATAFLOW_API_WORKER_MESSAGE_RESPONSE_H_ 31 #define GOOGLE_DATAFLOW_API_WORKER_MESSAGE_RESPONSE_H_ 33 #include "googleapis/base/macros.h" 34 #include "googleapis/client/data/jsoncpp_data.h" 35 #include "googleapis/strings/stringpiece.h" 37 #include "google/dataflow_api/resource_utilization_report_response.h" 38 #include "google/dataflow_api/worker_health_report_response.h" 39 #include "google/dataflow_api/worker_shutdown_notice_response.h" 88 return StringPiece(
"google_dataflow_api::WorkerMessageResponse");
99 return Storage().isMember(
"workerHealthReportResponse");
106 MutableStorage()->removeMember(
"workerHealthReportResponse");
132 return Storage().isMember(
"workerMetricsResponse");
139 MutableStorage()->removeMember(
"workerMetricsResponse");
167 return Storage().isMember(
"workerShutdownNoticeResponse");
174 MutableStorage()->removeMember(
"workerShutdownNoticeResponse");
198 #endif // GOOGLE_DATAFLOW_API_WORKER_MESSAGE_RESPONSE_H_ const StringPiece GetTypeName() const
Definition: worker_message_response.h:87
bool has_worker_health_report_response() const
Definition: worker_message_response.h:98
void clear_worker_shutdown_notice_response()
Definition: worker_message_response.h:173
Definition: resource_utilization_report_response.h:49
Definition: worker_health_report_response.h:51
bool has_worker_shutdown_notice_response() const
Definition: worker_message_response.h:166
Definition: approximate_progress.h:40
Definition: worker_shutdown_notice_response.h:49
void clear_worker_health_report_response()
Definition: worker_message_response.h:105
Definition: approximate_progress.cc:42
bool has_worker_metrics_response() const
Definition: worker_message_response.h:131
void clear_worker_metrics_response()
Definition: worker_message_response.h:138
Definition: worker_message_response.h:54