pub struct GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment {Show 16 fields
pub additional_experiments: Option<Vec<String>>,
pub additional_user_labels: Option<HashMap<String, String>>,
pub enable_streaming_engine: Option<bool>,
pub flexrs_goal: Option<String>,
pub ip_configuration: Option<String>,
pub kms_key_name: Option<String>,
pub machine_type: Option<String>,
pub max_workers: Option<i32>,
pub network: Option<String>,
pub num_workers: Option<i32>,
pub service_account_email: Option<String>,
pub subnetwork: Option<String>,
pub temp_location: Option<String>,
pub worker_region: Option<String>,
pub worker_zone: Option<String>,
pub zone: Option<String>,
}
Expand description
The environment values to be set at runtime for a Flex Template.
This type is not used in any activity, and only used as part of another schema.
Fields§
§additional_experiments: Option<Vec<String>>
Additional experiment flags for the job.
additional_user_labels: Option<HashMap<String, String>>
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the labeling restrictions. An object containing a list of key/value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }
.
enable_streaming_engine: Option<bool>
Whether to enable Streaming Engine for the job.
flexrs_goal: Option<String>
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
ip_configuration: Option<String>
Configuration for VM IPs.
kms_key_name: Option<String>
Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/
machine_type: Option<String>
The machine type to use for the job. Defaults to the value from the template if not specified.
max_workers: Option<i32>
The maximum number of Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
network: Option<String>
Network to which VMs will be assigned. If empty or unspecified, the service will use the network “default”.
num_workers: Option<i32>
The initial number of Compute Engine instances for the job.
service_account_email: Option<String>
The email address of the service account to run the job as.
subnetwork: Option<String>
Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form “https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK” or “regions/REGION/subnetworks/SUBNETWORK”. If the subnetwork is located in a Shared VPC network, you must use the complete URL.
temp_location: Option<String>
The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://
.
worker_region: Option<String>
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. “us-west1”. Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, defaults to the control plane region.
worker_zone: Option<String>
The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. “us-west1-a”. Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane region is chosen based on available capacity. If both worker_zone
and zone
are set, worker_zone
takes precedence.
zone: Option<String>
The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
Trait Implementations§
Source§impl Clone for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl Clone for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Source§fn clone(&self) -> GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
fn clone(&self) -> GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Default for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl Default for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Source§fn default() -> GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
fn default() -> GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Source§impl<'de> Deserialize<'de> for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl<'de> Deserialize<'de> for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Part for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Auto Trait Implementations§
impl Freeze for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl RefUnwindSafe for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl Send for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl Sync for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl Unpin for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
impl UnwindSafe for GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more