30 #ifndef GOOGLE_DATAFLOW_API_ENVIRONMENT_H_ 31 #define GOOGLE_DATAFLOW_API_ENVIRONMENT_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_pool.h" 86 return StringPiece(
"google_dataflow_api::Environment");
96 return Storage().isMember(
"clusterManagerApiService");
103 MutableStorage()->removeMember(
"clusterManagerApiService");
111 const Json::Value& v = Storage(
"clusterManagerApiService");
112 if (v == Json::Value::null)
return StringPiece(
"");
113 return StringPiece(v.asCString());
127 *MutableStorage(
"clusterManagerApiService") = value.data();
136 return Storage().isMember(
"dataset");
143 MutableStorage()->removeMember(
"dataset");
151 const Json::Value& v = Storage(
"dataset");
152 if (v == Json::Value::null)
return StringPiece(
"");
153 return StringPiece(v.asCString());
170 *MutableStorage(
"dataset") = value.data();
179 return Storage().isMember(
"experiments");
186 MutableStorage()->removeMember(
"experiments");
194 const Json::Value& storage = Storage(
"experiments");
195 return client::JsonValueToCppValueHelper<client::JsonCppArray<string > >(storage);
207 Json::Value* storage = MutableStorage(
"experiments");
208 return client::JsonValueToMutableCppValueHelper<client::JsonCppArray<string > >(storage);
219 return Storage().isMember(
"flexResourceSchedulingGoal");
226 MutableStorage()->removeMember(
"flexResourceSchedulingGoal");
234 const Json::Value& v = Storage(
"flexResourceSchedulingGoal");
235 if (v == Json::Value::null)
return StringPiece(
"");
236 return StringPiece(v.asCString());
247 *MutableStorage(
"flexResourceSchedulingGoal") = value.data();
256 return Storage().isMember(
"internalExperiments");
263 MutableStorage()->removeMember(
"internalExperiments");
272 const Json::Value& storage = Storage(
"internalExperiments");
273 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
285 Json::Value* storage = MutableStorage(
"internalExperiments");
286 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
295 return Storage().isMember(
"sdkPipelineOptions");
302 MutableStorage()->removeMember(
"sdkPipelineOptions");
311 const Json::Value& storage = Storage(
"sdkPipelineOptions");
312 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
327 Json::Value* storage = MutableStorage(
"sdkPipelineOptions");
328 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
337 return Storage().isMember(
"serviceAccountEmail");
344 MutableStorage()->removeMember(
"serviceAccountEmail");
352 const Json::Value& v = Storage(
"serviceAccountEmail");
353 if (v == Json::Value::null)
return StringPiece(
"");
354 return StringPiece(v.asCString());
365 *MutableStorage(
"serviceAccountEmail") = value.data();
374 return Storage().isMember(
"serviceKmsKeyName");
381 MutableStorage()->removeMember(
"serviceKmsKeyName");
389 const Json::Value& v = Storage(
"serviceKmsKeyName");
390 if (v == Json::Value::null)
return StringPiece(
"");
391 return StringPiece(v.asCString());
406 *MutableStorage(
"serviceKmsKeyName") = value.data();
415 return Storage().isMember(
"tempStoragePrefix");
422 MutableStorage()->removeMember(
"tempStoragePrefix");
430 const Json::Value& v = Storage(
"tempStoragePrefix");
431 if (v == Json::Value::null)
return StringPiece(
"");
432 return StringPiece(v.asCString());
455 *MutableStorage(
"tempStoragePrefix") = value.data();
464 return Storage().isMember(
"userAgent");
471 MutableStorage()->removeMember(
"userAgent");
478 const client::JsonCppAssociativeArray<client::JsonCppData >
get_user_agent()
const {
479 const Json::Value& storage = Storage(
"userAgent");
480 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
492 Json::Value* storage = MutableStorage(
"userAgent");
493 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
502 return Storage().isMember(
"version");
509 MutableStorage()->removeMember(
"version");
516 const client::JsonCppAssociativeArray<client::JsonCppData >
get_version()
const {
517 const Json::Value& storage = Storage(
"version");
518 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
530 Json::Value* storage = MutableStorage(
"version");
531 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
540 return Storage().isMember(
"workerPools");
547 MutableStorage()->removeMember(
"workerPools");
554 const client::JsonCppArray<WorkerPool > get_worker_pools()
const;
565 client::JsonCppArray<WorkerPool > mutable_workerPools();
573 return Storage().isMember(
"workerRegion");
580 MutableStorage()->removeMember(
"workerRegion");
588 const Json::Value& v = Storage(
"workerRegion");
589 if (v == Json::Value::null)
return StringPiece(
"");
590 return StringPiece(v.asCString());
606 *MutableStorage(
"workerRegion") = value.data();
615 return Storage().isMember(
"workerZone");
622 MutableStorage()->removeMember(
"workerZone");
630 const Json::Value& v = Storage(
"workerZone");
631 if (v == Json::Value::null)
return StringPiece(
"");
632 return StringPiece(v.asCString());
648 *MutableStorage(
"workerZone") = value.data();
655 #endif // GOOGLE_DATAFLOW_API_ENVIRONMENT_H_ client::JsonCppAssociativeArray< client::JsonCppData > mutable_version()
Definition: environment.h:529
const StringPiece get_flex_resource_scheduling_goal() const
Definition: environment.h:233
void clear_worker_pools()
Definition: environment.h:546
const StringPiece get_worker_region() const
Definition: environment.h:587
Definition: environment.h:52
void set_worker_zone(const StringPiece &value)
Definition: environment.h:647
void set_worker_region(const StringPiece &value)
Definition: environment.h:605
void set_dataset(const StringPiece &value)
Definition: environment.h:169
const StringPiece get_service_account_email() const
Definition: environment.h:351
const client::JsonCppAssociativeArray< client::JsonCppData > get_sdk_pipeline_options() const
Definition: environment.h:310
void clear_worker_region()
Definition: environment.h:579
bool has_worker_zone() const
Definition: environment.h:614
void clear_flex_resource_scheduling_goal()
Definition: environment.h:225
void clear_version()
Definition: environment.h:508
void clear_experiments()
Definition: environment.h:185
client::JsonCppAssociativeArray< client::JsonCppData > mutable_userAgent()
Definition: environment.h:491
const StringPiece get_temp_storage_prefix() const
Definition: environment.h:429
bool has_service_account_email() const
Definition: environment.h:336
bool has_internal_experiments() const
Definition: environment.h:255
const client::JsonCppArray< string > get_experiments() const
Definition: environment.h:193
bool has_service_kms_key_name() const
Definition: environment.h:373
bool has_flex_resource_scheduling_goal() const
Definition: environment.h:218
void clear_service_kms_key_name()
Definition: environment.h:380
bool has_worker_region() const
Definition: environment.h:572
void clear_internal_experiments()
Definition: environment.h:262
bool has_dataset() const
Definition: environment.h:135
const client::JsonCppAssociativeArray< client::JsonCppData > get_user_agent() const
Definition: environment.h:478
void clear_cluster_manager_api_service()
Definition: environment.h:102
client::JsonCppAssociativeArray< client::JsonCppData > mutable_internalExperiments()
Definition: environment.h:284
void set_cluster_manager_api_service(const StringPiece &value)
Definition: environment.h:126
bool has_sdk_pipeline_options() const
Definition: environment.h:294
bool has_experiments() const
Definition: environment.h:178
bool has_user_agent() const
Definition: environment.h:463
const StringPiece GetTypeName() const
Definition: environment.h:85
bool has_cluster_manager_api_service() const
Definition: environment.h:95
void clear_sdk_pipeline_options()
Definition: environment.h:301
client::JsonCppAssociativeArray< client::JsonCppData > mutable_sdkPipelineOptions()
Definition: environment.h:326
Definition: approximate_progress.h:40
const client::JsonCppAssociativeArray< client::JsonCppData > get_version() const
Definition: environment.h:516
bool has_worker_pools() const
Definition: environment.h:539
void set_temp_storage_prefix(const StringPiece &value)
Definition: environment.h:454
const StringPiece get_dataset() const
Definition: environment.h:150
void set_service_account_email(const StringPiece &value)
Definition: environment.h:364
bool has_version() const
Definition: environment.h:501
const StringPiece get_cluster_manager_api_service() const
Definition: environment.h:110
void set_flex_resource_scheduling_goal(const StringPiece &value)
Definition: environment.h:246
bool has_temp_storage_prefix() const
Definition: environment.h:414
const StringPiece get_worker_zone() const
Definition: environment.h:629
const client::JsonCppAssociativeArray< client::JsonCppData > get_internal_experiments() const
Definition: environment.h:271
void clear_user_agent()
Definition: environment.h:470
client::JsonCppArray< string > mutable_experiments()
Definition: environment.h:206
void clear_worker_zone()
Definition: environment.h:621
void clear_dataset()
Definition: environment.h:142
Definition: approximate_progress.cc:42
void set_service_kms_key_name(const StringPiece &value)
Definition: environment.h:405
void clear_service_account_email()
Definition: environment.h:343
void clear_temp_storage_prefix()
Definition: environment.h:421
const StringPiece get_service_kms_key_name() const
Definition: environment.h:388