30 #ifndef GOOGLE_DATAFLOW_API_TASK_RUNNER_SETTINGS_H_ 31 #define GOOGLE_DATAFLOW_API_TASK_RUNNER_SETTINGS_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/worker_settings.h" 86 return StringPiece(
"google_dataflow_api::TaskRunnerSettings");
95 return Storage().isMember(
"alsologtostderr");
102 MutableStorage()->removeMember(
"alsologtostderr");
110 const Json::Value& storage = Storage(
"alsologtostderr");
111 return client::JsonValueToCppValueHelper<bool >(storage);
122 client::SetJsonValueFromCppValueHelper<bool >(
123 value, MutableStorage(
"alsologtostderr"));
132 return Storage().isMember(
"baseTaskDir");
139 MutableStorage()->removeMember(
"baseTaskDir");
147 const Json::Value& v = Storage(
"baseTaskDir");
148 if (v == Json::Value::null)
return StringPiece(
"");
149 return StringPiece(v.asCString());
160 *MutableStorage(
"baseTaskDir") = value.data();
169 return Storage().isMember(
"baseUrl");
176 MutableStorage()->removeMember(
"baseUrl");
184 const Json::Value& v = Storage(
"baseUrl");
185 if (v == Json::Value::null)
return StringPiece(
"");
186 return StringPiece(v.asCString());
205 *MutableStorage(
"baseUrl") = value.data();
214 return Storage().isMember(
"commandlinesFileName");
221 MutableStorage()->removeMember(
"commandlinesFileName");
229 const Json::Value& v = Storage(
"commandlinesFileName");
230 if (v == Json::Value::null)
return StringPiece(
"");
231 return StringPiece(v.asCString());
242 *MutableStorage(
"commandlinesFileName") = value.data();
251 return Storage().isMember(
"continueOnException");
258 MutableStorage()->removeMember(
"continueOnException");
266 const Json::Value& storage = Storage(
"continueOnException");
267 return client::JsonValueToCppValueHelper<bool >(storage);
278 client::SetJsonValueFromCppValueHelper<bool >(
279 value, MutableStorage(
"continueOnException"));
288 return Storage().isMember(
"dataflowApiVersion");
295 MutableStorage()->removeMember(
"dataflowApiVersion");
303 const Json::Value& v = Storage(
"dataflowApiVersion");
304 if (v == Json::Value::null)
return StringPiece(
"");
305 return StringPiece(v.asCString());
316 *MutableStorage(
"dataflowApiVersion") = value.data();
325 return Storage().isMember(
"harnessCommand");
332 MutableStorage()->removeMember(
"harnessCommand");
340 const Json::Value& v = Storage(
"harnessCommand");
341 if (v == Json::Value::null)
return StringPiece(
"");
342 return StringPiece(v.asCString());
353 *MutableStorage(
"harnessCommand") = value.data();
362 return Storage().isMember(
"languageHint");
369 MutableStorage()->removeMember(
"languageHint");
377 const Json::Value& v = Storage(
"languageHint");
378 if (v == Json::Value::null)
return StringPiece(
"");
379 return StringPiece(v.asCString());
390 *MutableStorage(
"languageHint") = value.data();
399 return Storage().isMember(
"logDir");
406 MutableStorage()->removeMember(
"logDir");
414 const Json::Value& v = Storage(
"logDir");
415 if (v == Json::Value::null)
return StringPiece(
"");
416 return StringPiece(v.asCString());
427 *MutableStorage(
"logDir") = value.data();
436 return Storage().isMember(
"logToSerialconsole");
443 MutableStorage()->removeMember(
"logToSerialconsole");
451 const Json::Value& storage = Storage(
"logToSerialconsole");
452 return client::JsonValueToCppValueHelper<bool >(storage);
464 client::SetJsonValueFromCppValueHelper<bool >(
465 value, MutableStorage(
"logToSerialconsole"));
474 return Storage().isMember(
"logUploadLocation");
481 MutableStorage()->removeMember(
"logUploadLocation");
489 const Json::Value& v = Storage(
"logUploadLocation");
490 if (v == Json::Value::null)
return StringPiece(
"");
491 return StringPiece(v.asCString());
509 *MutableStorage(
"logUploadLocation") = value.data();
518 return Storage().isMember(
"oauthScopes");
525 MutableStorage()->removeMember(
"oauthScopes");
533 const Json::Value& storage = Storage(
"oauthScopes");
534 return client::JsonValueToCppValueHelper<client::JsonCppArray<string > >(storage);
547 Json::Value* storage = MutableStorage(
"oauthScopes");
548 return client::JsonValueToMutableCppValueHelper<client::JsonCppArray<string > >(storage);
558 return Storage().isMember(
"parallelWorkerSettings");
565 MutableStorage()->removeMember(
"parallelWorkerSettings");
592 return Storage().isMember(
"streamingWorkerMainClass");
599 MutableStorage()->removeMember(
"streamingWorkerMainClass");
607 const Json::Value& v = Storage(
"streamingWorkerMainClass");
608 if (v == Json::Value::null)
return StringPiece(
"");
609 return StringPiece(v.asCString());
620 *MutableStorage(
"streamingWorkerMainClass") = value.data();
629 return Storage().isMember(
"taskGroup");
636 MutableStorage()->removeMember(
"taskGroup");
644 const Json::Value& v = Storage(
"taskGroup");
645 if (v == Json::Value::null)
return StringPiece(
"");
646 return StringPiece(v.asCString());
658 *MutableStorage(
"taskGroup") = value.data();
667 return Storage().isMember(
"taskUser");
674 MutableStorage()->removeMember(
"taskUser");
682 const Json::Value& v = Storage(
"taskUser");
683 if (v == Json::Value::null)
return StringPiece(
"");
684 return StringPiece(v.asCString());
696 *MutableStorage(
"taskUser") = value.data();
705 return Storage().isMember(
"tempStoragePrefix");
712 MutableStorage()->removeMember(
"tempStoragePrefix");
720 const Json::Value& v = Storage(
"tempStoragePrefix");
721 if (v == Json::Value::null)
return StringPiece(
"");
722 return StringPiece(v.asCString());
740 *MutableStorage(
"tempStoragePrefix") = value.data();
749 return Storage().isMember(
"vmId");
756 MutableStorage()->removeMember(
"vmId");
764 const Json::Value& v = Storage(
"vmId");
765 if (v == Json::Value::null)
return StringPiece(
"");
766 return StringPiece(v.asCString());
777 *MutableStorage(
"vmId") = value.data();
786 return Storage().isMember(
"workflowFileName");
793 MutableStorage()->removeMember(
"workflowFileName");
801 const Json::Value& v = Storage(
"workflowFileName");
802 if (v == Json::Value::null)
return StringPiece(
"");
803 return StringPiece(v.asCString());
814 *MutableStorage(
"workflowFileName") = value.data();
821 #endif // GOOGLE_DATAFLOW_API_TASK_RUNNER_SETTINGS_H_ bool has_task_user() const
Definition: task_runner_settings.h:666
void set_base_task_dir(const StringPiece &value)
Definition: task_runner_settings.h:159
bool has_language_hint() const
Definition: task_runner_settings.h:361
bool has_task_group() const
Definition: task_runner_settings.h:628
void set_temp_storage_prefix(const StringPiece &value)
Definition: task_runner_settings.h:739
void clear_streaming_worker_main_class()
Definition: task_runner_settings.h:598
void clear_continue_on_exception()
Definition: task_runner_settings.h:257
const StringPiece GetTypeName() const
Definition: task_runner_settings.h:85
bool has_alsologtostderr() const
Definition: task_runner_settings.h:94
const StringPiece get_vm_id() const
Definition: task_runner_settings.h:763
void set_log_dir(const StringPiece &value)
Definition: task_runner_settings.h:426
bool has_base_url() const
Definition: task_runner_settings.h:168
void clear_alsologtostderr()
Definition: task_runner_settings.h:101
void clear_language_hint()
Definition: task_runner_settings.h:368
const StringPiece get_base_task_dir() const
Definition: task_runner_settings.h:146
bool has_workflow_file_name() const
Definition: task_runner_settings.h:785
Definition: task_runner_settings.h:52
bool get_log_to_serialconsole() const
Definition: task_runner_settings.h:450
bool has_harness_command() const
Definition: task_runner_settings.h:324
const StringPiece get_task_group() const
Definition: task_runner_settings.h:643
void clear_oauth_scopes()
Definition: task_runner_settings.h:524
bool has_oauth_scopes() const
Definition: task_runner_settings.h:517
void set_dataflow_api_version(const StringPiece &value)
Definition: task_runner_settings.h:315
void set_log_upload_location(const StringPiece &value)
Definition: task_runner_settings.h:508
const StringPiece get_dataflow_api_version() const
Definition: task_runner_settings.h:302
const StringPiece get_harness_command() const
Definition: task_runner_settings.h:339
Definition: worker_settings.h:50
void set_commandlines_file_name(const StringPiece &value)
Definition: task_runner_settings.h:241
bool has_commandlines_file_name() const
Definition: task_runner_settings.h:213
void set_base_url(const StringPiece &value)
Definition: task_runner_settings.h:204
void clear_dataflow_api_version()
Definition: task_runner_settings.h:294
void clear_temp_storage_prefix()
Definition: task_runner_settings.h:711
const StringPiece get_streaming_worker_main_class() const
Definition: task_runner_settings.h:606
void clear_commandlines_file_name()
Definition: task_runner_settings.h:220
void clear_log_dir()
Definition: task_runner_settings.h:405
const StringPiece get_log_dir() const
Definition: task_runner_settings.h:413
void set_task_user(const StringPiece &value)
Definition: task_runner_settings.h:695
bool has_streaming_worker_main_class() const
Definition: task_runner_settings.h:591
bool has_dataflow_api_version() const
Definition: task_runner_settings.h:287
void clear_base_task_dir()
Definition: task_runner_settings.h:138
void set_alsologtostderr(bool value)
Definition: task_runner_settings.h:121
void set_language_hint(const StringPiece &value)
Definition: task_runner_settings.h:389
const client::JsonCppArray< string > get_oauth_scopes() const
Definition: task_runner_settings.h:532
bool get_continue_on_exception() const
Definition: task_runner_settings.h:265
bool has_parallel_worker_settings() const
Definition: task_runner_settings.h:557
bool has_log_upload_location() const
Definition: task_runner_settings.h:473
void clear_workflow_file_name()
Definition: task_runner_settings.h:792
Definition: approximate_progress.h:40
const StringPiece get_base_url() const
Definition: task_runner_settings.h:183
void clear_task_user()
Definition: task_runner_settings.h:673
void clear_task_group()
Definition: task_runner_settings.h:635
const StringPiece get_task_user() const
Definition: task_runner_settings.h:681
const StringPiece get_commandlines_file_name() const
Definition: task_runner_settings.h:228
void clear_base_url()
Definition: task_runner_settings.h:175
bool has_vm_id() const
Definition: task_runner_settings.h:748
bool has_continue_on_exception() const
Definition: task_runner_settings.h:250
client::JsonCppArray< string > mutable_oauthScopes()
Definition: task_runner_settings.h:546
void set_workflow_file_name(const StringPiece &value)
Definition: task_runner_settings.h:813
void clear_log_upload_location()
Definition: task_runner_settings.h:480
void set_task_group(const StringPiece &value)
Definition: task_runner_settings.h:657
const StringPiece get_workflow_file_name() const
Definition: task_runner_settings.h:800
bool has_log_to_serialconsole() const
Definition: task_runner_settings.h:435
void set_continue_on_exception(bool value)
Definition: task_runner_settings.h:277
void clear_harness_command()
Definition: task_runner_settings.h:331
void clear_parallel_worker_settings()
Definition: task_runner_settings.h:564
void set_vm_id(const StringPiece &value)
Definition: task_runner_settings.h:776
Definition: approximate_progress.cc:42
const StringPiece get_log_upload_location() const
Definition: task_runner_settings.h:488
bool has_temp_storage_prefix() const
Definition: task_runner_settings.h:704
bool has_log_dir() const
Definition: task_runner_settings.h:398
void set_streaming_worker_main_class(const StringPiece &value)
Definition: task_runner_settings.h:619
bool get_alsologtostderr() const
Definition: task_runner_settings.h:109
bool has_base_task_dir() const
Definition: task_runner_settings.h:131
void clear_log_to_serialconsole()
Definition: task_runner_settings.h:442
void set_log_to_serialconsole(bool value)
Definition: task_runner_settings.h:463
void set_harness_command(const StringPiece &value)
Definition: task_runner_settings.h:352
const StringPiece get_temp_storage_prefix() const
Definition: task_runner_settings.h:719
const StringPiece get_language_hint() const
Definition: task_runner_settings.h:376
void clear_vm_id()
Definition: task_runner_settings.h:755