dataflow  v1b3
task_runner_settings.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_TASK_RUNNER_SETTINGS_H_
31 #define GOOGLE_DATAFLOW_API_TASK_RUNNER_SETTINGS_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/worker_settings.h"
39 
40 namespace Json {
41 class Value;
42 } // namespace Json
43 
44 namespace google_dataflow_api {
45 using namespace googleapis;
46 
52 class TaskRunnerSettings : public client::JsonCppData {
53  public:
59  static TaskRunnerSettings* New();
60 
66  explicit TaskRunnerSettings(const Json::Value& storage);
67 
73  explicit TaskRunnerSettings(Json::Value* storage);
74 
78  virtual ~TaskRunnerSettings();
79 
85  const StringPiece GetTypeName() const {
86  return StringPiece("google_dataflow_api::TaskRunnerSettings");
87  }
88 
94  bool has_alsologtostderr() const {
95  return Storage().isMember("alsologtostderr");
96  }
97 
102  MutableStorage()->removeMember("alsologtostderr");
103  }
104 
105 
109  bool get_alsologtostderr() const {
110  const Json::Value& storage = Storage("alsologtostderr");
111  return client::JsonValueToCppValueHelper<bool >(storage);
112  }
113 
121  void set_alsologtostderr(bool value) {
122  client::SetJsonValueFromCppValueHelper<bool >(
123  value, MutableStorage("alsologtostderr"));
124  }
125 
131  bool has_base_task_dir() const {
132  return Storage().isMember("baseTaskDir");
133  }
134 
139  MutableStorage()->removeMember("baseTaskDir");
140  }
141 
142 
146  const StringPiece get_base_task_dir() const {
147  const Json::Value& v = Storage("baseTaskDir");
148  if (v == Json::Value::null) return StringPiece("");
149  return StringPiece(v.asCString());
150  }
151 
159  void set_base_task_dir(const StringPiece& value) {
160  *MutableStorage("baseTaskDir") = value.data();
161  }
162 
168  bool has_base_url() const {
169  return Storage().isMember("baseUrl");
170  }
171 
175  void clear_base_url() {
176  MutableStorage()->removeMember("baseUrl");
177  }
178 
179 
183  const StringPiece get_base_url() const {
184  const Json::Value& v = Storage("baseUrl");
185  if (v == Json::Value::null) return StringPiece("");
186  return StringPiece(v.asCString());
187  }
188 
204  void set_base_url(const StringPiece& value) {
205  *MutableStorage("baseUrl") = value.data();
206  }
207 
214  return Storage().isMember("commandlinesFileName");
215  }
216 
221  MutableStorage()->removeMember("commandlinesFileName");
222  }
223 
224 
228  const StringPiece get_commandlines_file_name() const {
229  const Json::Value& v = Storage("commandlinesFileName");
230  if (v == Json::Value::null) return StringPiece("");
231  return StringPiece(v.asCString());
232  }
233 
241  void set_commandlines_file_name(const StringPiece& value) {
242  *MutableStorage("commandlinesFileName") = value.data();
243  }
244 
251  return Storage().isMember("continueOnException");
252  }
253 
258  MutableStorage()->removeMember("continueOnException");
259  }
260 
261 
266  const Json::Value& storage = Storage("continueOnException");
267  return client::JsonValueToCppValueHelper<bool >(storage);
268  }
269 
277  void set_continue_on_exception(bool value) {
278  client::SetJsonValueFromCppValueHelper<bool >(
279  value, MutableStorage("continueOnException"));
280  }
281 
288  return Storage().isMember("dataflowApiVersion");
289  }
290 
295  MutableStorage()->removeMember("dataflowApiVersion");
296  }
297 
298 
302  const StringPiece get_dataflow_api_version() const {
303  const Json::Value& v = Storage("dataflowApiVersion");
304  if (v == Json::Value::null) return StringPiece("");
305  return StringPiece(v.asCString());
306  }
307 
315  void set_dataflow_api_version(const StringPiece& value) {
316  *MutableStorage("dataflowApiVersion") = value.data();
317  }
318 
324  bool has_harness_command() const {
325  return Storage().isMember("harnessCommand");
326  }
327 
332  MutableStorage()->removeMember("harnessCommand");
333  }
334 
335 
339  const StringPiece get_harness_command() const {
340  const Json::Value& v = Storage("harnessCommand");
341  if (v == Json::Value::null) return StringPiece("");
342  return StringPiece(v.asCString());
343  }
344 
352  void set_harness_command(const StringPiece& value) {
353  *MutableStorage("harnessCommand") = value.data();
354  }
355 
361  bool has_language_hint() const {
362  return Storage().isMember("languageHint");
363  }
364 
369  MutableStorage()->removeMember("languageHint");
370  }
371 
372 
376  const StringPiece get_language_hint() const {
377  const Json::Value& v = Storage("languageHint");
378  if (v == Json::Value::null) return StringPiece("");
379  return StringPiece(v.asCString());
380  }
381 
389  void set_language_hint(const StringPiece& value) {
390  *MutableStorage("languageHint") = value.data();
391  }
392 
398  bool has_log_dir() const {
399  return Storage().isMember("logDir");
400  }
401 
405  void clear_log_dir() {
406  MutableStorage()->removeMember("logDir");
407  }
408 
409 
413  const StringPiece get_log_dir() const {
414  const Json::Value& v = Storage("logDir");
415  if (v == Json::Value::null) return StringPiece("");
416  return StringPiece(v.asCString());
417  }
418 
426  void set_log_dir(const StringPiece& value) {
427  *MutableStorage("logDir") = value.data();
428  }
429 
436  return Storage().isMember("logToSerialconsole");
437  }
438 
443  MutableStorage()->removeMember("logToSerialconsole");
444  }
445 
446 
451  const Json::Value& storage = Storage("logToSerialconsole");
452  return client::JsonValueToCppValueHelper<bool >(storage);
453  }
454 
463  void set_log_to_serialconsole(bool value) {
464  client::SetJsonValueFromCppValueHelper<bool >(
465  value, MutableStorage("logToSerialconsole"));
466  }
467 
473  bool has_log_upload_location() const {
474  return Storage().isMember("logUploadLocation");
475  }
476 
481  MutableStorage()->removeMember("logUploadLocation");
482  }
483 
484 
488  const StringPiece get_log_upload_location() const {
489  const Json::Value& v = Storage("logUploadLocation");
490  if (v == Json::Value::null) return StringPiece("");
491  return StringPiece(v.asCString());
492  }
493 
508  void set_log_upload_location(const StringPiece& value) {
509  *MutableStorage("logUploadLocation") = value.data();
510  }
511 
517  bool has_oauth_scopes() const {
518  return Storage().isMember("oauthScopes");
519  }
520 
525  MutableStorage()->removeMember("oauthScopes");
526  }
527 
528 
532  const client::JsonCppArray<string > get_oauth_scopes() const {
533  const Json::Value& storage = Storage("oauthScopes");
534  return client::JsonValueToCppValueHelper<client::JsonCppArray<string > >(storage);
535  }
536 
546  client::JsonCppArray<string > mutable_oauthScopes() {
547  Json::Value* storage = MutableStorage("oauthScopes");
548  return client::JsonValueToMutableCppValueHelper<client::JsonCppArray<string > >(storage);
549  }
550 
558  return Storage().isMember("parallelWorkerSettings");
559  }
560 
565  MutableStorage()->removeMember("parallelWorkerSettings");
566  }
567 
568 
573  const WorkerSettings get_parallel_worker_settings() const;
574 
583  WorkerSettings mutable_parallelWorkerSettings();
584 
592  return Storage().isMember("streamingWorkerMainClass");
593  }
594 
599  MutableStorage()->removeMember("streamingWorkerMainClass");
600  }
601 
602 
606  const StringPiece get_streaming_worker_main_class() const {
607  const Json::Value& v = Storage("streamingWorkerMainClass");
608  if (v == Json::Value::null) return StringPiece("");
609  return StringPiece(v.asCString());
610  }
611 
619  void set_streaming_worker_main_class(const StringPiece& value) {
620  *MutableStorage("streamingWorkerMainClass") = value.data();
621  }
622 
628  bool has_task_group() const {
629  return Storage().isMember("taskGroup");
630  }
631 
636  MutableStorage()->removeMember("taskGroup");
637  }
638 
639 
643  const StringPiece get_task_group() const {
644  const Json::Value& v = Storage("taskGroup");
645  if (v == Json::Value::null) return StringPiece("");
646  return StringPiece(v.asCString());
647  }
648 
657  void set_task_group(const StringPiece& value) {
658  *MutableStorage("taskGroup") = value.data();
659  }
660 
666  bool has_task_user() const {
667  return Storage().isMember("taskUser");
668  }
669 
674  MutableStorage()->removeMember("taskUser");
675  }
676 
677 
681  const StringPiece get_task_user() const {
682  const Json::Value& v = Storage("taskUser");
683  if (v == Json::Value::null) return StringPiece("");
684  return StringPiece(v.asCString());
685  }
686 
695  void set_task_user(const StringPiece& value) {
696  *MutableStorage("taskUser") = value.data();
697  }
698 
704  bool has_temp_storage_prefix() const {
705  return Storage().isMember("tempStoragePrefix");
706  }
707 
712  MutableStorage()->removeMember("tempStoragePrefix");
713  }
714 
715 
719  const StringPiece get_temp_storage_prefix() const {
720  const Json::Value& v = Storage("tempStoragePrefix");
721  if (v == Json::Value::null) return StringPiece("");
722  return StringPiece(v.asCString());
723  }
724 
739  void set_temp_storage_prefix(const StringPiece& value) {
740  *MutableStorage("tempStoragePrefix") = value.data();
741  }
742 
748  bool has_vm_id() const {
749  return Storage().isMember("vmId");
750  }
751 
755  void clear_vm_id() {
756  MutableStorage()->removeMember("vmId");
757  }
758 
759 
763  const StringPiece get_vm_id() const {
764  const Json::Value& v = Storage("vmId");
765  if (v == Json::Value::null) return StringPiece("");
766  return StringPiece(v.asCString());
767  }
768 
776  void set_vm_id(const StringPiece& value) {
777  *MutableStorage("vmId") = value.data();
778  }
779 
785  bool has_workflow_file_name() const {
786  return Storage().isMember("workflowFileName");
787  }
788 
793  MutableStorage()->removeMember("workflowFileName");
794  }
795 
796 
800  const StringPiece get_workflow_file_name() const {
801  const Json::Value& v = Storage("workflowFileName");
802  if (v == Json::Value::null) return StringPiece("");
803  return StringPiece(v.asCString());
804  }
805 
813  void set_workflow_file_name(const StringPiece& value) {
814  *MutableStorage("workflowFileName") = value.data();
815  }
816 
817  private:
818  void operator=(const TaskRunnerSettings&);
819 }; // TaskRunnerSettings
820 } // namespace google_dataflow_api
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