Struct google_api_proto::google::dataflow::v1beta3::RuntimeEnvironment

pub struct RuntimeEnvironment {

    pub num_workers: i32,
    pub max_workers: i32,
    pub zone: String,
    pub service_account_email: String,
    pub temp_location: String,
    pub bypass_temp_dir_validation: bool,
    pub machine_type: String,
    pub additional_experiments: Vec<String>,
    pub network: String,
    pub subnetwork: String,
    pub additional_user_labels: BTreeMap<String, String>,
    pub kms_key_name: String,
    pub ip_configuration: i32,
    pub worker_region: String,
    pub worker_zone: String,
    pub enable_streaming_engine: bool,
}

The environment values to set at runtime.

Fields

num_workers: i32

The initial number of Google Compute Engine instnaces for the job.

max_workers: i32

The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

zone: String

The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

service_account_email: String

The email address of the service account to run the job as.

temp_location: String

The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://.

bypass_temp_dir_validation: bool

Whether to bypass the safety checks for the job’s temporary directory. Use with caution.

machine_type: String

The machine type to use for the job. Defaults to the value from the template if not specified.

additional_experiments: Vec<String>

Additional experiment flags for the job, specified with the --experiments option.

network: String

Network to which VMs will be assigned. If empty or unspecified, the service will use the network “default”.

subnetwork: 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.

additional_user_labels: BTreeMap<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” }.

kms_key_name: String

Name for the Cloud KMS key for the job. Key format is: projects//locations//keyRings//cryptoKeys/

ip_configuration: i32

Configuration for VM IPs.

worker_region: 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: 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.

enable_streaming_engine: bool

Whether to enable Streaming Engine for the job.

Implementations

impl RuntimeEnvironment

pub fn ip_configuration(&self) -> WorkerIpAddressConfiguration

Returns the enum value of ip_configuration, or the default if the field is set to an invalid enum value.

pub fn set_ip_configuration(&mut self, value: WorkerIpAddressConfiguration)

Sets ip_configuration to the provided enum value.

Trait Implementations

impl Clone for RuntimeEnvironment

fn clone(&self) -> RuntimeEnvironment

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RuntimeEnvironment

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RuntimeEnvironment

fn default() -> Self

Returns the “default value” for a type.

impl Message for RuntimeEnvironment

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for RuntimeEnvironment

fn eq(&self, other: &RuntimeEnvironment) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RuntimeEnvironment