dataflow  v1b3
worker_pool.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_WORKER_POOL_H_
31 #define GOOGLE_DATAFLOW_API_WORKER_POOL_H_
32 
33 #include <string>
34 #include "googleapis/base/integral_types.h"
35 #include "googleapis/base/macros.h"
36 #include "googleapis/client/data/jsoncpp_data.h"
37 #include "googleapis/strings/stringpiece.h"
38 
39 #include "google/dataflow_api/autoscaling_settings.h"
40 #include "google/dataflow_api/disk.h"
41 #include "google/dataflow_api/package.h"
42 #include "google/dataflow_api/sdk_harness_container_image.h"
43 #include "google/dataflow_api/task_runner_settings.h"
44 
45 namespace Json {
46 class Value;
47 } // namespace Json
48 
49 namespace google_dataflow_api {
50 using namespace googleapis;
51 
61 class WorkerPool : public client::JsonCppData {
62  public:
68  static WorkerPool* New();
69 
75  explicit WorkerPool(const Json::Value& storage);
76 
82  explicit WorkerPool(Json::Value* storage);
83 
87  virtual ~WorkerPool();
88 
94  const StringPiece GetTypeName() const {
95  return StringPiece("google_dataflow_api::WorkerPool");
96  }
97 
104  return Storage().isMember("autoscalingSettings");
105  }
106 
111  MutableStorage()->removeMember("autoscalingSettings");
112  }
113 
114 
119  const AutoscalingSettings get_autoscaling_settings() const;
120 
129  AutoscalingSettings mutable_autoscalingSettings();
130 
136  bool has_data_disks() const {
137  return Storage().isMember("dataDisks");
138  }
139 
144  MutableStorage()->removeMember("dataDisks");
145  }
146 
147 
151  const client::JsonCppArray<Disk > get_data_disks() const;
152 
161  client::JsonCppArray<Disk > mutable_dataDisks();
162 
168  bool has_default_package_set() const {
169  return Storage().isMember("defaultPackageSet");
170  }
171 
176  MutableStorage()->removeMember("defaultPackageSet");
177  }
178 
179 
183  const StringPiece get_default_package_set() const {
184  const Json::Value& v = Storage("defaultPackageSet");
185  if (v == Json::Value::null) return StringPiece("");
186  return StringPiece(v.asCString());
187  }
188 
198  void set_default_package_set(const StringPiece& value) {
199  *MutableStorage("defaultPackageSet") = value.data();
200  }
201 
207  bool has_disk_size_gb() const {
208  return Storage().isMember("diskSizeGb");
209  }
210 
215  MutableStorage()->removeMember("diskSizeGb");
216  }
217 
218 
222  int32 get_disk_size_gb() const {
223  const Json::Value& storage = Storage("diskSizeGb");
224  return client::JsonValueToCppValueHelper<int32 >(storage);
225  }
226 
235  void set_disk_size_gb(int32 value) {
236  client::SetJsonValueFromCppValueHelper<int32 >(
237  value, MutableStorage("diskSizeGb"));
238  }
239 
245  bool has_disk_source_image() const {
246  return Storage().isMember("diskSourceImage");
247  }
248 
253  MutableStorage()->removeMember("diskSourceImage");
254  }
255 
256 
260  const StringPiece get_disk_source_image() const {
261  const Json::Value& v = Storage("diskSourceImage");
262  if (v == Json::Value::null) return StringPiece("");
263  return StringPiece(v.asCString());
264  }
265 
273  void set_disk_source_image(const StringPiece& value) {
274  *MutableStorage("diskSourceImage") = value.data();
275  }
276 
282  bool has_disk_type() const {
283  return Storage().isMember("diskType");
284  }
285 
290  MutableStorage()->removeMember("diskType");
291  }
292 
293 
297  const StringPiece get_disk_type() const {
298  const Json::Value& v = Storage("diskType");
299  if (v == Json::Value::null) return StringPiece("");
300  return StringPiece(v.asCString());
301  }
302 
311  void set_disk_type(const StringPiece& value) {
312  *MutableStorage("diskType") = value.data();
313  }
314 
320  bool has_ip_configuration() const {
321  return Storage().isMember("ipConfiguration");
322  }
323 
328  MutableStorage()->removeMember("ipConfiguration");
329  }
330 
331 
335  const StringPiece get_ip_configuration() const {
336  const Json::Value& v = Storage("ipConfiguration");
337  if (v == Json::Value::null) return StringPiece("");
338  return StringPiece(v.asCString());
339  }
340 
348  void set_ip_configuration(const StringPiece& value) {
349  *MutableStorage("ipConfiguration") = value.data();
350  }
351 
357  bool has_kind() const {
358  return Storage().isMember("kind");
359  }
360 
364  void clear_kind() {
365  MutableStorage()->removeMember("kind");
366  }
367 
368 
372  const StringPiece get_kind() const {
373  const Json::Value& v = Storage("kind");
374  if (v == Json::Value::null) return StringPiece("");
375  return StringPiece(v.asCString());
376  }
377 
386  void set_kind(const StringPiece& value) {
387  *MutableStorage("kind") = value.data();
388  }
389 
395  bool has_machine_type() const {
396  return Storage().isMember("machineType");
397  }
398 
403  MutableStorage()->removeMember("machineType");
404  }
405 
406 
410  const StringPiece get_machine_type() const {
411  const Json::Value& v = Storage("machineType");
412  if (v == Json::Value::null) return StringPiece("");
413  return StringPiece(v.asCString());
414  }
415 
424  void set_machine_type(const StringPiece& value) {
425  *MutableStorage("machineType") = value.data();
426  }
427 
433  bool has_metadata() const {
434  return Storage().isMember("metadata");
435  }
436 
440  void clear_metadata() {
441  MutableStorage()->removeMember("metadata");
442  }
443 
444 
448  const client::JsonCppAssociativeArray<string > get_metadata() const {
449  const Json::Value& storage = Storage("metadata");
450  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
451  }
452 
461  client::JsonCppAssociativeArray<string > mutable_metadata() {
462  Json::Value* storage = MutableStorage("metadata");
463  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
464  }
465 
471  bool has_network() const {
472  return Storage().isMember("network");
473  }
474 
478  void clear_network() {
479  MutableStorage()->removeMember("network");
480  }
481 
482 
486  const StringPiece get_network() const {
487  const Json::Value& v = Storage("network");
488  if (v == Json::Value::null) return StringPiece("");
489  return StringPiece(v.asCString());
490  }
491 
500  void set_network(const StringPiece& value) {
501  *MutableStorage("network") = value.data();
502  }
503 
510  return Storage().isMember("numThreadsPerWorker");
511  }
512 
517  MutableStorage()->removeMember("numThreadsPerWorker");
518  }
519 
520 
525  const Json::Value& storage = Storage("numThreadsPerWorker");
526  return client::JsonValueToCppValueHelper<int32 >(storage);
527  }
528 
538  void set_num_threads_per_worker(int32 value) {
539  client::SetJsonValueFromCppValueHelper<int32 >(
540  value, MutableStorage("numThreadsPerWorker"));
541  }
542 
548  bool has_num_workers() const {
549  return Storage().isMember("numWorkers");
550  }
551 
556  MutableStorage()->removeMember("numWorkers");
557  }
558 
559 
563  int32 get_num_workers() const {
564  const Json::Value& storage = Storage("numWorkers");
565  return client::JsonValueToCppValueHelper<int32 >(storage);
566  }
567 
577  void set_num_workers(int32 value) {
578  client::SetJsonValueFromCppValueHelper<int32 >(
579  value, MutableStorage("numWorkers"));
580  }
581 
587  bool has_on_host_maintenance() const {
588  return Storage().isMember("onHostMaintenance");
589  }
590 
595  MutableStorage()->removeMember("onHostMaintenance");
596  }
597 
598 
602  const StringPiece get_on_host_maintenance() const {
603  const Json::Value& v = Storage("onHostMaintenance");
604  if (v == Json::Value::null) return StringPiece("");
605  return StringPiece(v.asCString());
606  }
607 
616  void set_on_host_maintenance(const StringPiece& value) {
617  *MutableStorage("onHostMaintenance") = value.data();
618  }
619 
625  bool has_packages() const {
626  return Storage().isMember("packages");
627  }
628 
632  void clear_packages() {
633  MutableStorage()->removeMember("packages");
634  }
635 
636 
640  const client::JsonCppArray<Package > get_packages() const;
641 
650  client::JsonCppArray<Package > mutable_packages();
651 
657  bool has_pool_args() const {
658  return Storage().isMember("poolArgs");
659  }
660 
665  MutableStorage()->removeMember("poolArgs");
666  }
667 
668 
672  const client::JsonCppAssociativeArray<client::JsonCppData > get_pool_args() const {
673  const Json::Value& storage = Storage("poolArgs");
674  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
675  }
676 
685  client::JsonCppAssociativeArray<client::JsonCppData > mutable_poolArgs() {
686  Json::Value* storage = MutableStorage("poolArgs");
687  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
688  }
689 
698  return Storage().isMember("sdkHarnessContainerImages");
699  }
700 
705  MutableStorage()->removeMember("sdkHarnessContainerImages");
706  }
707 
708 
713  const client::JsonCppArray<SdkHarnessContainerImage > get_sdk_harness_container_images() const;
714 
726  client::JsonCppArray<SdkHarnessContainerImage > mutable_sdkHarnessContainerImages();
727 
733  bool has_subnetwork() const {
734  return Storage().isMember("subnetwork");
735  }
736 
741  MutableStorage()->removeMember("subnetwork");
742  }
743 
744 
748  const StringPiece get_subnetwork() const {
749  const Json::Value& v = Storage("subnetwork");
750  if (v == Json::Value::null) return StringPiece("");
751  return StringPiece(v.asCString());
752  }
753 
762  void set_subnetwork(const StringPiece& value) {
763  *MutableStorage("subnetwork") = value.data();
764  }
765 
771  bool has_taskrunner_settings() const {
772  return Storage().isMember("taskrunnerSettings");
773  }
774 
779  MutableStorage()->removeMember("taskrunnerSettings");
780  }
781 
782 
787  const TaskRunnerSettings get_taskrunner_settings() const;
788 
799  TaskRunnerSettings mutable_taskrunnerSettings();
800 
806  bool has_teardown_policy() const {
807  return Storage().isMember("teardownPolicy");
808  }
809 
814  MutableStorage()->removeMember("teardownPolicy");
815  }
816 
817 
821  const StringPiece get_teardown_policy() const {
822  const Json::Value& v = Storage("teardownPolicy");
823  if (v == Json::Value::null) return StringPiece("");
824  return StringPiece(v.asCString());
825  }
826 
849  void set_teardown_policy(const StringPiece& value) {
850  *MutableStorage("teardownPolicy") = value.data();
851  }
852 
861  return Storage().isMember("workerHarnessContainerImage");
862  }
863 
868  MutableStorage()->removeMember("workerHarnessContainerImage");
869  }
870 
871 
875  const StringPiece get_worker_harness_container_image() const {
876  const Json::Value& v = Storage("workerHarnessContainerImage");
877  if (v == Json::Value::null) return StringPiece("");
878  return StringPiece(v.asCString());
879  }
880 
891  void set_worker_harness_container_image(const StringPiece& value) {
892  *MutableStorage("workerHarnessContainerImage") = value.data();
893  }
894 
900  bool has_zone() const {
901  return Storage().isMember("zone");
902  }
903 
907  void clear_zone() {
908  MutableStorage()->removeMember("zone");
909  }
910 
911 
915  const StringPiece get_zone() const {
916  const Json::Value& v = Storage("zone");
917  if (v == Json::Value::null) return StringPiece("");
918  return StringPiece(v.asCString());
919  }
920 
929  void set_zone(const StringPiece& value) {
930  *MutableStorage("zone") = value.data();
931  }
932 
933  private:
934  void operator=(const WorkerPool&);
935 }; // WorkerPool
936 } // namespace google_dataflow_api
937 #endif // GOOGLE_DATAFLOW_API_WORKER_POOL_H_
void clear_machine_type()
Definition: worker_pool.h:402
void clear_num_threads_per_worker()
Definition: worker_pool.h:516
void set_num_workers(int32 value)
Definition: worker_pool.h:577
bool has_num_workers() const
Definition: worker_pool.h:548
void clear_disk_source_image()
Definition: worker_pool.h:252
bool has_kind() const
Definition: worker_pool.h:357
bool has_disk_type() const
Definition: worker_pool.h:282
bool has_on_host_maintenance() const
Definition: worker_pool.h:587
int32 get_num_workers() const
Definition: worker_pool.h:563
void clear_data_disks()
Definition: worker_pool.h:143
void clear_autoscaling_settings()
Definition: worker_pool.h:110
bool has_sdk_harness_container_images() const
Definition: worker_pool.h:697
void set_network(const StringPiece &value)
Definition: worker_pool.h:500
void clear_teardown_policy()
Definition: worker_pool.h:813
void clear_sdk_harness_container_images()
Definition: worker_pool.h:704
void clear_subnetwork()
Definition: worker_pool.h:740
bool has_zone() const
Definition: worker_pool.h:900
const StringPiece get_on_host_maintenance() const
Definition: worker_pool.h:602
void clear_on_host_maintenance()
Definition: worker_pool.h:594
void clear_kind()
Definition: worker_pool.h:364
int32 get_disk_size_gb() const
Definition: worker_pool.h:222
Definition: worker_pool.h:61
Definition: task_runner_settings.h:52
void clear_disk_size_gb()
Definition: worker_pool.h:214
bool has_num_threads_per_worker() const
Definition: worker_pool.h:509
const StringPiece get_worker_harness_container_image() const
Definition: worker_pool.h:875
void clear_pool_args()
Definition: worker_pool.h:664
const StringPiece get_disk_type() const
Definition: worker_pool.h:297
const client::JsonCppAssociativeArray< client::JsonCppData > get_pool_args() const
Definition: worker_pool.h:672
void clear_default_package_set()
Definition: worker_pool.h:175
bool has_machine_type() const
Definition: worker_pool.h:395
Definition: autoscaling_settings.h:51
bool has_autoscaling_settings() const
Definition: worker_pool.h:103
const StringPiece get_machine_type() const
Definition: worker_pool.h:410
bool has_disk_size_gb() const
Definition: worker_pool.h:207
void set_disk_type(const StringPiece &value)
Definition: worker_pool.h:311
int32 get_num_threads_per_worker() const
Definition: worker_pool.h:524
void set_disk_size_gb(int32 value)
Definition: worker_pool.h:235
bool has_worker_harness_container_image() const
Definition: worker_pool.h:860
const StringPiece get_network() const
Definition: worker_pool.h:486
void clear_packages()
Definition: worker_pool.h:632
const StringPiece get_subnetwork() const
Definition: worker_pool.h:748
void clear_num_workers()
Definition: worker_pool.h:555
client::JsonCppAssociativeArray< string > mutable_metadata()
Definition: worker_pool.h:461
const StringPiece get_disk_source_image() const
Definition: worker_pool.h:260
const client::JsonCppAssociativeArray< string > get_metadata() const
Definition: worker_pool.h:448
bool has_taskrunner_settings() const
Definition: worker_pool.h:771
void set_worker_harness_container_image(const StringPiece &value)
Definition: worker_pool.h:891
const StringPiece get_kind() const
Definition: worker_pool.h:372
bool has_teardown_policy() const
Definition: worker_pool.h:806
void set_num_threads_per_worker(int32 value)
Definition: worker_pool.h:538
void clear_taskrunner_settings()
Definition: worker_pool.h:778
void set_ip_configuration(const StringPiece &value)
Definition: worker_pool.h:348
void set_on_host_maintenance(const StringPiece &value)
Definition: worker_pool.h:616
bool has_default_package_set() const
Definition: worker_pool.h:168
Definition: approximate_progress.h:40
void set_kind(const StringPiece &value)
Definition: worker_pool.h:386
client::JsonCppAssociativeArray< client::JsonCppData > mutable_poolArgs()
Definition: worker_pool.h:685
bool has_metadata() const
Definition: worker_pool.h:433
bool has_pool_args() const
Definition: worker_pool.h:657
void clear_worker_harness_container_image()
Definition: worker_pool.h:867
bool has_subnetwork() const
Definition: worker_pool.h:733
void clear_network()
Definition: worker_pool.h:478
const StringPiece get_teardown_policy() const
Definition: worker_pool.h:821
void clear_ip_configuration()
Definition: worker_pool.h:327
void set_teardown_policy(const StringPiece &value)
Definition: worker_pool.h:849
void set_disk_source_image(const StringPiece &value)
Definition: worker_pool.h:273
void clear_zone()
Definition: worker_pool.h:907
const StringPiece get_ip_configuration() const
Definition: worker_pool.h:335
bool has_network() const
Definition: worker_pool.h:471
Definition: approximate_progress.cc:42
bool has_ip_configuration() const
Definition: worker_pool.h:320
bool has_data_disks() const
Definition: worker_pool.h:136
const StringPiece GetTypeName() const
Definition: worker_pool.h:94
void clear_disk_type()
Definition: worker_pool.h:289
const StringPiece get_default_package_set() const
Definition: worker_pool.h:183
void set_zone(const StringPiece &value)
Definition: worker_pool.h:929
bool has_disk_source_image() const
Definition: worker_pool.h:245
void set_default_package_set(const StringPiece &value)
Definition: worker_pool.h:198
bool has_packages() const
Definition: worker_pool.h:625
void clear_metadata()
Definition: worker_pool.h:440
void set_subnetwork(const StringPiece &value)
Definition: worker_pool.h:762
void set_machine_type(const StringPiece &value)
Definition: worker_pool.h:424
const StringPiece get_zone() const
Definition: worker_pool.h:915