pub struct GoogleCloudDatapipelinesV1RuntimeEnvironment {Show 16 fields
pub additional_experiments: Option<Vec<String>>,
pub additional_user_labels: Option<HashMap<String, String>>,
pub bypass_temp_dir_validation: Option<bool>,
pub enable_streaming_engine: Option<bool>,
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 set at runtime.
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 should follow the restrictions specified in the labeling restrictions page. An object containing a list of key/value pairs. Example: { “name”: “wrench”, “mass”: “1kg”, “count”: “3” }.
bypass_temp_dir_validation: Option<bool>Whether to bypass the safety checks for the job’s temporary directory. Use with caution.
enable_streaming_engine: Option<bool>Whether to enable Streaming Engine for the job.
ip_configuration: Option<String>Configuration for VM IPs.
kms_key_name: Option<String>Name for the Cloud KMS key for the job. The 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, default to the control plane’s 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’s 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
sourceimpl Clone for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl Clone for GoogleCloudDatapipelinesV1RuntimeEnvironment
sourcefn clone(&self) -> GoogleCloudDatapipelinesV1RuntimeEnvironment
fn clone(&self) -> GoogleCloudDatapipelinesV1RuntimeEnvironment
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read more
sourceimpl Default for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl Default for GoogleCloudDatapipelinesV1RuntimeEnvironment
sourcefn default() -> GoogleCloudDatapipelinesV1RuntimeEnvironment
fn default() -> GoogleCloudDatapipelinesV1RuntimeEnvironment
Returns the “default value” for a type. Read more
sourceimpl<'de> Deserialize<'de> for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl<'de> Deserialize<'de> for GoogleCloudDatapipelinesV1RuntimeEnvironment
sourcefn 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>,
Deserialize this value from the given Serde deserializer. Read more
impl Part for GoogleCloudDatapipelinesV1RuntimeEnvironment
Auto Trait Implementations
impl RefUnwindSafe for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl Send for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl Sync for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl Unpin for GoogleCloudDatapipelinesV1RuntimeEnvironment
impl UnwindSafe for GoogleCloudDatapipelinesV1RuntimeEnvironment
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more