30 #ifndef GOOGLE_DATAFLOW_API_PUBSUB_LOCATION_H_ 31 #define GOOGLE_DATAFLOW_API_PUBSUB_LOCATION_H_ 34 #include "googleapis/base/macros.h" 35 #include "googleapis/client/data/jsoncpp_data.h" 36 #include "googleapis/strings/stringpiece.h" 85 return StringPiece(
"google_dataflow_api::PubsubLocation");
94 return Storage().isMember(
"dropLateData");
101 MutableStorage()->removeMember(
"dropLateData");
109 const Json::Value& storage = Storage(
"dropLateData");
110 return client::JsonValueToCppValueHelper<bool >(storage);
121 client::SetJsonValueFromCppValueHelper<bool >(
122 value, MutableStorage(
"dropLateData"));
131 return Storage().isMember(
"idLabel");
138 MutableStorage()->removeMember(
"idLabel");
146 const Json::Value& v = Storage(
"idLabel");
147 if (v == Json::Value::null)
return StringPiece(
"");
148 return StringPiece(v.asCString());
160 *MutableStorage(
"idLabel") = value.data();
169 return Storage().isMember(
"subscription");
176 MutableStorage()->removeMember(
"subscription");
184 const Json::Value& v = Storage(
"subscription");
185 if (v == Json::Value::null)
return StringPiece(
"");
186 return StringPiece(v.asCString());
198 *MutableStorage(
"subscription") = value.data();
207 return Storage().isMember(
"timestampLabel");
214 MutableStorage()->removeMember(
"timestampLabel");
222 const Json::Value& v = Storage(
"timestampLabel");
223 if (v == Json::Value::null)
return StringPiece(
"");
224 return StringPiece(v.asCString());
236 *MutableStorage(
"timestampLabel") = value.data();
245 return Storage().isMember(
"topic");
252 MutableStorage()->removeMember(
"topic");
260 const Json::Value& v = Storage(
"topic");
261 if (v == Json::Value::null)
return StringPiece(
"");
262 return StringPiece(v.asCString());
274 *MutableStorage(
"topic") = value.data();
283 return Storage().isMember(
"trackingSubscription");
290 MutableStorage()->removeMember(
"trackingSubscription");
298 const Json::Value& v = Storage(
"trackingSubscription");
299 if (v == Json::Value::null)
return StringPiece(
"");
300 return StringPiece(v.asCString());
312 *MutableStorage(
"trackingSubscription") = value.data();
321 return Storage().isMember(
"withAttributes");
328 MutableStorage()->removeMember(
"withAttributes");
336 const Json::Value& storage = Storage(
"withAttributes");
337 return client::JsonValueToCppValueHelper<bool >(storage);
348 client::SetJsonValueFromCppValueHelper<bool >(
349 value, MutableStorage(
"withAttributes"));
356 #endif // GOOGLE_DATAFLOW_API_PUBSUB_LOCATION_H_ const StringPiece get_subscription() const
Definition: pubsub_location.h:183
bool has_tracking_subscription() const
Definition: pubsub_location.h:282
void clear_subscription()
Definition: pubsub_location.h:175
bool has_topic() const
Definition: pubsub_location.h:244
bool has_id_label() const
Definition: pubsub_location.h:130
const StringPiece get_id_label() const
Definition: pubsub_location.h:145
const StringPiece get_timestamp_label() const
Definition: pubsub_location.h:221
void clear_timestamp_label()
Definition: pubsub_location.h:213
void clear_id_label()
Definition: pubsub_location.h:137
bool has_drop_late_data() const
Definition: pubsub_location.h:93
void clear_topic()
Definition: pubsub_location.h:251
void set_topic(const StringPiece &value)
Definition: pubsub_location.h:273
const StringPiece get_topic() const
Definition: pubsub_location.h:259
bool get_drop_late_data() const
Definition: pubsub_location.h:108
void set_timestamp_label(const StringPiece &value)
Definition: pubsub_location.h:235
const StringPiece get_tracking_subscription() const
Definition: pubsub_location.h:297
Definition: approximate_progress.h:40
bool has_with_attributes() const
Definition: pubsub_location.h:320
bool has_subscription() const
Definition: pubsub_location.h:168
void set_tracking_subscription(const StringPiece &value)
Definition: pubsub_location.h:311
bool get_with_attributes() const
Definition: pubsub_location.h:335
bool has_timestamp_label() const
Definition: pubsub_location.h:206
const StringPiece GetTypeName() const
Definition: pubsub_location.h:84
void set_subscription(const StringPiece &value)
Definition: pubsub_location.h:197
void clear_tracking_subscription()
Definition: pubsub_location.h:289
void set_drop_late_data(bool value)
Definition: pubsub_location.h:120
Definition: approximate_progress.cc:42
void clear_drop_late_data()
Definition: pubsub_location.h:100
Definition: pubsub_location.h:51
void set_id_label(const StringPiece &value)
Definition: pubsub_location.h:159
void clear_with_attributes()
Definition: pubsub_location.h:327
void set_with_attributes(bool value)
Definition: pubsub_location.h:347