#[non_exhaustive]pub struct EnvironmentBuilder { /* private fields */ }
Expand description
A builder for Environment
.
Implementations§
Source§impl EnvironmentBuilder
impl EnvironmentBuilder
Sourcepub fn name(self, input: impl Into<String>) -> Self
pub fn name(self, input: impl Into<String>) -> Self
The name of the Amazon MWAA environment. For example, MyMWAAEnvironment
.
Sourcepub fn set_name(self, input: Option<String>) -> Self
pub fn set_name(self, input: Option<String>) -> Self
The name of the Amazon MWAA environment. For example, MyMWAAEnvironment
.
Sourcepub fn get_name(&self) -> &Option<String>
pub fn get_name(&self) -> &Option<String>
The name of the Amazon MWAA environment. For example, MyMWAAEnvironment
.
Sourcepub fn status(self, input: EnvironmentStatus) -> Self
pub fn status(self, input: EnvironmentStatus) -> Self
The status of the Amazon MWAA environment.
Valid values:
-
CREATING
- Indicates the request to create the environment is in progress. -
CREATING_SNAPSHOT
- Indicates the request to update environment details, or upgrade the environment version, is in progress and Amazon MWAA is creating a storage volume snapshot of the Amazon RDS database cluster associated with the environment. A database snapshot is a backup created at a specific point in time. Amazon MWAA uses snapshots to recover environment metadata if the process to update or upgrade an environment fails. -
CREATE_FAILED
- Indicates the request to create the environment failed, and the environment could not be created. -
AVAILABLE
- Indicates the request was successful and the environment is ready to use. -
PENDING
- Indicates the request was successful, but the process to create the environment is paused until you create the required VPC endpoints in your VPC. After you create the VPC endpoints, the process resumes. -
UPDATING
- Indicates the request to update the environment is in progress. -
ROLLING_BACK
- Indicates the request to update environment details, or upgrade the environment version, failed and Amazon MWAA is restoring the environment using the latest storage volume snapshot. -
DELETING
- Indicates the request to delete the environment is in progress. -
DELETED
- Indicates the request to delete the environment is complete, and the environment has been deleted. -
UNAVAILABLE
- Indicates the request failed, but the environment did not return to its previous state and is not stable. -
UPDATE_FAILED
- Indicates the request to update the environment failed, and the environment was restored to its previous state successfully and is ready to use. -
MAINTENANCE
- Indicates that the environment is undergoing maintenance. Depending on the type of work Amazon MWAA is performing, your environment might become unavailable during this process. After all operations are done, your environment will return to its status prior to mainteneace operations.
We recommend reviewing our troubleshooting guide for a list of common errors and their solutions. For more information, see Amazon MWAA troubleshooting.
Sourcepub fn set_status(self, input: Option<EnvironmentStatus>) -> Self
pub fn set_status(self, input: Option<EnvironmentStatus>) -> Self
The status of the Amazon MWAA environment.
Valid values:
-
CREATING
- Indicates the request to create the environment is in progress. -
CREATING_SNAPSHOT
- Indicates the request to update environment details, or upgrade the environment version, is in progress and Amazon MWAA is creating a storage volume snapshot of the Amazon RDS database cluster associated with the environment. A database snapshot is a backup created at a specific point in time. Amazon MWAA uses snapshots to recover environment metadata if the process to update or upgrade an environment fails. -
CREATE_FAILED
- Indicates the request to create the environment failed, and the environment could not be created. -
AVAILABLE
- Indicates the request was successful and the environment is ready to use. -
PENDING
- Indicates the request was successful, but the process to create the environment is paused until you create the required VPC endpoints in your VPC. After you create the VPC endpoints, the process resumes. -
UPDATING
- Indicates the request to update the environment is in progress. -
ROLLING_BACK
- Indicates the request to update environment details, or upgrade the environment version, failed and Amazon MWAA is restoring the environment using the latest storage volume snapshot. -
DELETING
- Indicates the request to delete the environment is in progress. -
DELETED
- Indicates the request to delete the environment is complete, and the environment has been deleted. -
UNAVAILABLE
- Indicates the request failed, but the environment did not return to its previous state and is not stable. -
UPDATE_FAILED
- Indicates the request to update the environment failed, and the environment was restored to its previous state successfully and is ready to use. -
MAINTENANCE
- Indicates that the environment is undergoing maintenance. Depending on the type of work Amazon MWAA is performing, your environment might become unavailable during this process. After all operations are done, your environment will return to its status prior to mainteneace operations.
We recommend reviewing our troubleshooting guide for a list of common errors and their solutions. For more information, see Amazon MWAA troubleshooting.
Sourcepub fn get_status(&self) -> &Option<EnvironmentStatus>
pub fn get_status(&self) -> &Option<EnvironmentStatus>
The status of the Amazon MWAA environment.
Valid values:
-
CREATING
- Indicates the request to create the environment is in progress. -
CREATING_SNAPSHOT
- Indicates the request to update environment details, or upgrade the environment version, is in progress and Amazon MWAA is creating a storage volume snapshot of the Amazon RDS database cluster associated with the environment. A database snapshot is a backup created at a specific point in time. Amazon MWAA uses snapshots to recover environment metadata if the process to update or upgrade an environment fails. -
CREATE_FAILED
- Indicates the request to create the environment failed, and the environment could not be created. -
AVAILABLE
- Indicates the request was successful and the environment is ready to use. -
PENDING
- Indicates the request was successful, but the process to create the environment is paused until you create the required VPC endpoints in your VPC. After you create the VPC endpoints, the process resumes. -
UPDATING
- Indicates the request to update the environment is in progress. -
ROLLING_BACK
- Indicates the request to update environment details, or upgrade the environment version, failed and Amazon MWAA is restoring the environment using the latest storage volume snapshot. -
DELETING
- Indicates the request to delete the environment is in progress. -
DELETED
- Indicates the request to delete the environment is complete, and the environment has been deleted. -
UNAVAILABLE
- Indicates the request failed, but the environment did not return to its previous state and is not stable. -
UPDATE_FAILED
- Indicates the request to update the environment failed, and the environment was restored to its previous state successfully and is ready to use. -
MAINTENANCE
- Indicates that the environment is undergoing maintenance. Depending on the type of work Amazon MWAA is performing, your environment might become unavailable during this process. After all operations are done, your environment will return to its status prior to mainteneace operations.
We recommend reviewing our troubleshooting guide for a list of common errors and their solutions. For more information, see Amazon MWAA troubleshooting.
Sourcepub fn arn(self, input: impl Into<String>) -> Self
pub fn arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the Amazon MWAA environment.
Sourcepub fn set_arn(self, input: Option<String>) -> Self
pub fn set_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the Amazon MWAA environment.
Sourcepub fn get_arn(&self) -> &Option<String>
pub fn get_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) of the Amazon MWAA environment.
Sourcepub fn created_at(self, input: DateTime) -> Self
pub fn created_at(self, input: DateTime) -> Self
The day and time the environment was created.
Sourcepub fn set_created_at(self, input: Option<DateTime>) -> Self
pub fn set_created_at(self, input: Option<DateTime>) -> Self
The day and time the environment was created.
Sourcepub fn get_created_at(&self) -> &Option<DateTime>
pub fn get_created_at(&self) -> &Option<DateTime>
The day and time the environment was created.
Sourcepub fn webserver_url(self, input: impl Into<String>) -> Self
pub fn webserver_url(self, input: impl Into<String>) -> Self
The Apache Airflow web server host name for the Amazon MWAA environment. For more information, see Accessing the Apache Airflow UI.
Sourcepub fn set_webserver_url(self, input: Option<String>) -> Self
pub fn set_webserver_url(self, input: Option<String>) -> Self
The Apache Airflow web server host name for the Amazon MWAA environment. For more information, see Accessing the Apache Airflow UI.
Sourcepub fn get_webserver_url(&self) -> &Option<String>
pub fn get_webserver_url(&self) -> &Option<String>
The Apache Airflow web server host name for the Amazon MWAA environment. For more information, see Accessing the Apache Airflow UI.
Sourcepub fn execution_role_arn(self, input: impl Into<String>) -> Self
pub fn execution_role_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA to access Amazon Web Services resources in your environment. For example, arn:aws:iam::123456789:role/my-execution-role
. For more information, see Amazon MWAA Execution role.
Sourcepub fn set_execution_role_arn(self, input: Option<String>) -> Self
pub fn set_execution_role_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA to access Amazon Web Services resources in your environment. For example, arn:aws:iam::123456789:role/my-execution-role
. For more information, see Amazon MWAA Execution role.
Sourcepub fn get_execution_role_arn(&self) -> &Option<String>
pub fn get_execution_role_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA to access Amazon Web Services resources in your environment. For example, arn:aws:iam::123456789:role/my-execution-role
. For more information, see Amazon MWAA Execution role.
Sourcepub fn service_role_arn(self, input: impl Into<String>) -> Self
pub fn service_role_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) for the service-linked role of the environment. For more information, see Amazon MWAA Service-linked role.
Sourcepub fn set_service_role_arn(self, input: Option<String>) -> Self
pub fn set_service_role_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) for the service-linked role of the environment. For more information, see Amazon MWAA Service-linked role.
Sourcepub fn get_service_role_arn(&self) -> &Option<String>
pub fn get_service_role_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) for the service-linked role of the environment. For more information, see Amazon MWAA Service-linked role.
Sourcepub fn kms_key(self, input: impl Into<String>) -> Self
pub fn kms_key(self, input: impl Into<String>) -> Self
The KMS encryption key used to encrypt the data in your environment.
Sourcepub fn set_kms_key(self, input: Option<String>) -> Self
pub fn set_kms_key(self, input: Option<String>) -> Self
The KMS encryption key used to encrypt the data in your environment.
Sourcepub fn get_kms_key(&self) -> &Option<String>
pub fn get_kms_key(&self) -> &Option<String>
The KMS encryption key used to encrypt the data in your environment.
Sourcepub fn airflow_version(self, input: impl Into<String>) -> Self
pub fn airflow_version(self, input: impl Into<String>) -> Self
The Apache Airflow version on your environment.
Valid values: 1.10.12
, 2.0.2
, 2.2.2
, 2.4.3
, 2.5.1
, 2.6.3
, 2.7.2
, 2.8.1
, 2.9.2
, 2.10.1
, and 2.10.3
.
Sourcepub fn set_airflow_version(self, input: Option<String>) -> Self
pub fn set_airflow_version(self, input: Option<String>) -> Self
The Apache Airflow version on your environment.
Valid values: 1.10.12
, 2.0.2
, 2.2.2
, 2.4.3
, 2.5.1
, 2.6.3
, 2.7.2
, 2.8.1
, 2.9.2
, 2.10.1
, and 2.10.3
.
Sourcepub fn get_airflow_version(&self) -> &Option<String>
pub fn get_airflow_version(&self) -> &Option<String>
The Apache Airflow version on your environment.
Valid values: 1.10.12
, 2.0.2
, 2.2.2
, 2.4.3
, 2.5.1
, 2.6.3
, 2.7.2
, 2.8.1
, 2.9.2
, 2.10.1
, and 2.10.3
.
Sourcepub fn source_bucket_arn(self, input: impl Into<String>) -> Self
pub fn source_bucket_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name
. For more information, see Create an Amazon S3 bucket for Amazon MWAA.
Sourcepub fn set_source_bucket_arn(self, input: Option<String>) -> Self
pub fn set_source_bucket_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name
. For more information, see Create an Amazon S3 bucket for Amazon MWAA.
Sourcepub fn get_source_bucket_arn(&self) -> &Option<String>
pub fn get_source_bucket_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name
. For more information, see Create an Amazon S3 bucket for Amazon MWAA.
Sourcepub fn dag_s3_path(self, input: impl Into<String>) -> Self
pub fn dag_s3_path(self, input: impl Into<String>) -> Self
The relative path to the DAGs folder in your Amazon S3 bucket. For example, s3://mwaa-environment/dags
. For more information, see Adding or updating DAGs.
Sourcepub fn set_dag_s3_path(self, input: Option<String>) -> Self
pub fn set_dag_s3_path(self, input: Option<String>) -> Self
The relative path to the DAGs folder in your Amazon S3 bucket. For example, s3://mwaa-environment/dags
. For more information, see Adding or updating DAGs.
Sourcepub fn get_dag_s3_path(&self) -> &Option<String>
pub fn get_dag_s3_path(&self) -> &Option<String>
The relative path to the DAGs folder in your Amazon S3 bucket. For example, s3://mwaa-environment/dags
. For more information, see Adding or updating DAGs.
Sourcepub fn plugins_s3_path(self, input: impl Into<String>) -> Self
pub fn plugins_s3_path(self, input: impl Into<String>) -> Self
The relative path to the file in your Amazon S3 bucket. For example, s3://mwaa-environment/plugins.zip
. For more information, see Installing custom plugins.
Sourcepub fn set_plugins_s3_path(self, input: Option<String>) -> Self
pub fn set_plugins_s3_path(self, input: Option<String>) -> Self
The relative path to the file in your Amazon S3 bucket. For example, s3://mwaa-environment/plugins.zip
. For more information, see Installing custom plugins.
Sourcepub fn get_plugins_s3_path(&self) -> &Option<String>
pub fn get_plugins_s3_path(&self) -> &Option<String>
The relative path to the file in your Amazon S3 bucket. For example, s3://mwaa-environment/plugins.zip
. For more information, see Installing custom plugins.
Sourcepub fn plugins_s3_object_version(self, input: impl Into<String>) -> Self
pub fn plugins_s3_object_version(self, input: impl Into<String>) -> Self
The version of the plugins.zip
file in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing custom plugins.
Sourcepub fn set_plugins_s3_object_version(self, input: Option<String>) -> Self
pub fn set_plugins_s3_object_version(self, input: Option<String>) -> Self
The version of the plugins.zip
file in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing custom plugins.
Sourcepub fn get_plugins_s3_object_version(&self) -> &Option<String>
pub fn get_plugins_s3_object_version(&self) -> &Option<String>
The version of the plugins.zip
file in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing custom plugins.
Sourcepub fn requirements_s3_path(self, input: impl Into<String>) -> Self
pub fn requirements_s3_path(self, input: impl Into<String>) -> Self
The relative path to the requirements.txt
file in your Amazon S3 bucket. For example, s3://mwaa-environment/requirements.txt
. For more information, see Installing Python dependencies.
Sourcepub fn set_requirements_s3_path(self, input: Option<String>) -> Self
pub fn set_requirements_s3_path(self, input: Option<String>) -> Self
The relative path to the requirements.txt
file in your Amazon S3 bucket. For example, s3://mwaa-environment/requirements.txt
. For more information, see Installing Python dependencies.
Sourcepub fn get_requirements_s3_path(&self) -> &Option<String>
pub fn get_requirements_s3_path(&self) -> &Option<String>
The relative path to the requirements.txt
file in your Amazon S3 bucket. For example, s3://mwaa-environment/requirements.txt
. For more information, see Installing Python dependencies.
Sourcepub fn requirements_s3_object_version(self, input: impl Into<String>) -> Self
pub fn requirements_s3_object_version(self, input: impl Into<String>) -> Self
The version of the requirements.txt
file on your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing Python dependencies.
Sourcepub fn set_requirements_s3_object_version(self, input: Option<String>) -> Self
pub fn set_requirements_s3_object_version(self, input: Option<String>) -> Self
The version of the requirements.txt
file on your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing Python dependencies.
Sourcepub fn get_requirements_s3_object_version(&self) -> &Option<String>
pub fn get_requirements_s3_object_version(&self) -> &Option<String>
The version of the requirements.txt
file on your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Installing Python dependencies.
Sourcepub fn startup_script_s3_path(self, input: impl Into<String>) -> Self
pub fn startup_script_s3_path(self, input: impl Into<String>) -> Self
The relative path to the startup shell script in your Amazon S3 bucket. For example, s3://mwaa-environment/startup.sh
.
Amazon MWAA runs the script as your environment starts, and before running the Apache Airflow process. You can use this script to install dependencies, modify Apache Airflow configuration options, and set environment variables. For more information, see Using a startup script.
Sourcepub fn set_startup_script_s3_path(self, input: Option<String>) -> Self
pub fn set_startup_script_s3_path(self, input: Option<String>) -> Self
The relative path to the startup shell script in your Amazon S3 bucket. For example, s3://mwaa-environment/startup.sh
.
Amazon MWAA runs the script as your environment starts, and before running the Apache Airflow process. You can use this script to install dependencies, modify Apache Airflow configuration options, and set environment variables. For more information, see Using a startup script.
Sourcepub fn get_startup_script_s3_path(&self) -> &Option<String>
pub fn get_startup_script_s3_path(&self) -> &Option<String>
The relative path to the startup shell script in your Amazon S3 bucket. For example, s3://mwaa-environment/startup.sh
.
Amazon MWAA runs the script as your environment starts, and before running the Apache Airflow process. You can use this script to install dependencies, modify Apache Airflow configuration options, and set environment variables. For more information, see Using a startup script.
Sourcepub fn startup_script_s3_object_version(self, input: impl Into<String>) -> Self
pub fn startup_script_s3_object_version(self, input: impl Into<String>) -> Self
The version of the startup shell script in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Using a startup script.
Sourcepub fn set_startup_script_s3_object_version(self, input: Option<String>) -> Self
pub fn set_startup_script_s3_object_version(self, input: Option<String>) -> Self
The version of the startup shell script in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Using a startup script.
Sourcepub fn get_startup_script_s3_object_version(&self) -> &Option<String>
pub fn get_startup_script_s3_object_version(&self) -> &Option<String>
The version of the startup shell script in your Amazon S3 bucket. You must specify the version ID that Amazon S3 assigns to the file.
Version IDs are Unicode, UTF-8 encoded, URL-ready, opaque strings that are no more than 1,024 bytes long. The following is an example:
3sL4kqtJlcpXroDTDmJ+rmSpXd3dIbrHY+MTRCxf3vjVBH40Nr8X8gdRQBpUMLUo
For more information, see Using a startup script.
Sourcepub fn airflow_configuration_options(
self,
k: impl Into<String>,
v: impl Into<String>,
) -> Self
pub fn airflow_configuration_options( self, k: impl Into<String>, v: impl Into<String>, ) -> Self
Adds a key-value pair to airflow_configuration_options
.
To override the contents of this collection use set_airflow_configuration_options
.
A list of key-value pairs containing the Apache Airflow configuration options attached to your environment. For more information, see Apache Airflow configuration options.
Sourcepub fn set_airflow_configuration_options(
self,
input: Option<HashMap<String, String>>,
) -> Self
pub fn set_airflow_configuration_options( self, input: Option<HashMap<String, String>>, ) -> Self
A list of key-value pairs containing the Apache Airflow configuration options attached to your environment. For more information, see Apache Airflow configuration options.
Sourcepub fn get_airflow_configuration_options(
&self,
) -> &Option<HashMap<String, String>>
pub fn get_airflow_configuration_options( &self, ) -> &Option<HashMap<String, String>>
A list of key-value pairs containing the Apache Airflow configuration options attached to your environment. For more information, see Apache Airflow configuration options.
Sourcepub fn environment_class(self, input: impl Into<String>) -> Self
pub fn environment_class(self, input: impl Into<String>) -> Self
The environment class type. Valid values: mw1.micro
, mw1.small
, mw1.medium
, mw1.large
, mw1.xlarge
, and mw1.2xlarge
. For more information, see Amazon MWAA environment class.
Sourcepub fn set_environment_class(self, input: Option<String>) -> Self
pub fn set_environment_class(self, input: Option<String>) -> Self
The environment class type. Valid values: mw1.micro
, mw1.small
, mw1.medium
, mw1.large
, mw1.xlarge
, and mw1.2xlarge
. For more information, see Amazon MWAA environment class.
Sourcepub fn get_environment_class(&self) -> &Option<String>
pub fn get_environment_class(&self) -> &Option<String>
The environment class type. Valid values: mw1.micro
, mw1.small
, mw1.medium
, mw1.large
, mw1.xlarge
, and mw1.2xlarge
. For more information, see Amazon MWAA environment class.
Sourcepub fn max_workers(self, input: i32) -> Self
pub fn max_workers(self, input: i32) -> Self
The maximum number of workers that run in your environment. For example, 20
.
Sourcepub fn set_max_workers(self, input: Option<i32>) -> Self
pub fn set_max_workers(self, input: Option<i32>) -> Self
The maximum number of workers that run in your environment. For example, 20
.
Sourcepub fn get_max_workers(&self) -> &Option<i32>
pub fn get_max_workers(&self) -> &Option<i32>
The maximum number of workers that run in your environment. For example, 20
.
Sourcepub fn network_configuration(self, input: NetworkConfiguration) -> Self
pub fn network_configuration(self, input: NetworkConfiguration) -> Self
Describes the VPC networking components used to secure and enable network traffic between the Amazon Web Services resources for your environment. For more information, see About networking on Amazon MWAA.
Sourcepub fn set_network_configuration(
self,
input: Option<NetworkConfiguration>,
) -> Self
pub fn set_network_configuration( self, input: Option<NetworkConfiguration>, ) -> Self
Describes the VPC networking components used to secure and enable network traffic between the Amazon Web Services resources for your environment. For more information, see About networking on Amazon MWAA.
Sourcepub fn get_network_configuration(&self) -> &Option<NetworkConfiguration>
pub fn get_network_configuration(&self) -> &Option<NetworkConfiguration>
Describes the VPC networking components used to secure and enable network traffic between the Amazon Web Services resources for your environment. For more information, see About networking on Amazon MWAA.
Sourcepub fn logging_configuration(self, input: LoggingConfiguration) -> Self
pub fn logging_configuration(self, input: LoggingConfiguration) -> Self
The Apache Airflow logs published to CloudWatch Logs.
Sourcepub fn set_logging_configuration(
self,
input: Option<LoggingConfiguration>,
) -> Self
pub fn set_logging_configuration( self, input: Option<LoggingConfiguration>, ) -> Self
The Apache Airflow logs published to CloudWatch Logs.
Sourcepub fn get_logging_configuration(&self) -> &Option<LoggingConfiguration>
pub fn get_logging_configuration(&self) -> &Option<LoggingConfiguration>
The Apache Airflow logs published to CloudWatch Logs.
Sourcepub fn last_update(self, input: LastUpdate) -> Self
pub fn last_update(self, input: LastUpdate) -> Self
The status of the last update on the environment.
Sourcepub fn set_last_update(self, input: Option<LastUpdate>) -> Self
pub fn set_last_update(self, input: Option<LastUpdate>) -> Self
The status of the last update on the environment.
Sourcepub fn get_last_update(&self) -> &Option<LastUpdate>
pub fn get_last_update(&self) -> &Option<LastUpdate>
The status of the last update on the environment.
Sourcepub fn weekly_maintenance_window_start(self, input: impl Into<String>) -> Self
pub fn weekly_maintenance_window_start(self, input: impl Into<String>) -> Self
The day and time of the week in Coordinated Universal Time (UTC) 24-hour standard time that weekly maintenance updates are scheduled. For example: TUE:03:30
.
Sourcepub fn set_weekly_maintenance_window_start(self, input: Option<String>) -> Self
pub fn set_weekly_maintenance_window_start(self, input: Option<String>) -> Self
The day and time of the week in Coordinated Universal Time (UTC) 24-hour standard time that weekly maintenance updates are scheduled. For example: TUE:03:30
.
Sourcepub fn get_weekly_maintenance_window_start(&self) -> &Option<String>
pub fn get_weekly_maintenance_window_start(&self) -> &Option<String>
The day and time of the week in Coordinated Universal Time (UTC) 24-hour standard time that weekly maintenance updates are scheduled. For example: TUE:03:30
.
Adds a key-value pair to tags
.
To override the contents of this collection use set_tags
.
The key-value tag pairs associated to your environment. For example, "Environment": "Staging"
. For more information, see Tagging Amazon Web Services resources.
The key-value tag pairs associated to your environment. For example, "Environment": "Staging"
. For more information, see Tagging Amazon Web Services resources.
The key-value tag pairs associated to your environment. For example, "Environment": "Staging"
. For more information, see Tagging Amazon Web Services resources.
Sourcepub fn webserver_access_mode(self, input: WebserverAccessMode) -> Self
pub fn webserver_access_mode(self, input: WebserverAccessMode) -> Self
The Apache Airflow web server access mode. For more information, see Apache Airflow access modes.
Sourcepub fn set_webserver_access_mode(
self,
input: Option<WebserverAccessMode>,
) -> Self
pub fn set_webserver_access_mode( self, input: Option<WebserverAccessMode>, ) -> Self
The Apache Airflow web server access mode. For more information, see Apache Airflow access modes.
Sourcepub fn get_webserver_access_mode(&self) -> &Option<WebserverAccessMode>
pub fn get_webserver_access_mode(&self) -> &Option<WebserverAccessMode>
The Apache Airflow web server access mode. For more information, see Apache Airflow access modes.
Sourcepub fn min_workers(self, input: i32) -> Self
pub fn min_workers(self, input: i32) -> Self
The minimum number of workers that run in your environment. For example, 2
.
Sourcepub fn set_min_workers(self, input: Option<i32>) -> Self
pub fn set_min_workers(self, input: Option<i32>) -> Self
The minimum number of workers that run in your environment. For example, 2
.
Sourcepub fn get_min_workers(&self) -> &Option<i32>
pub fn get_min_workers(&self) -> &Option<i32>
The minimum number of workers that run in your environment. For example, 2
.
Sourcepub fn schedulers(self, input: i32) -> Self
pub fn schedulers(self, input: i32) -> Self
The number of Apache Airflow schedulers that run in your Amazon MWAA environment.
Sourcepub fn set_schedulers(self, input: Option<i32>) -> Self
pub fn set_schedulers(self, input: Option<i32>) -> Self
The number of Apache Airflow schedulers that run in your Amazon MWAA environment.
Sourcepub fn get_schedulers(&self) -> &Option<i32>
pub fn get_schedulers(&self) -> &Option<i32>
The number of Apache Airflow schedulers that run in your Amazon MWAA environment.
Sourcepub fn webserver_vpc_endpoint_service(self, input: impl Into<String>) -> Self
pub fn webserver_vpc_endpoint_service(self, input: impl Into<String>) -> Self
The VPC endpoint for the environment's web server.
Sourcepub fn set_webserver_vpc_endpoint_service(self, input: Option<String>) -> Self
pub fn set_webserver_vpc_endpoint_service(self, input: Option<String>) -> Self
The VPC endpoint for the environment's web server.
Sourcepub fn get_webserver_vpc_endpoint_service(&self) -> &Option<String>
pub fn get_webserver_vpc_endpoint_service(&self) -> &Option<String>
The VPC endpoint for the environment's web server.
Sourcepub fn database_vpc_endpoint_service(self, input: impl Into<String>) -> Self
pub fn database_vpc_endpoint_service(self, input: impl Into<String>) -> Self
The VPC endpoint for the environment's Amazon RDS database.
Sourcepub fn set_database_vpc_endpoint_service(self, input: Option<String>) -> Self
pub fn set_database_vpc_endpoint_service(self, input: Option<String>) -> Self
The VPC endpoint for the environment's Amazon RDS database.
Sourcepub fn get_database_vpc_endpoint_service(&self) -> &Option<String>
pub fn get_database_vpc_endpoint_service(&self) -> &Option<String>
The VPC endpoint for the environment's Amazon RDS database.
Sourcepub fn celery_executor_queue(self, input: impl Into<String>) -> Self
pub fn celery_executor_queue(self, input: impl Into<String>) -> Self
The queue ARN for the environment's Celery Executor. Amazon MWAA uses a Celery Executor to distribute tasks across multiple workers. When you create an environment in a shared VPC, you must provide access to the Celery Executor queue from your VPC.
Sourcepub fn set_celery_executor_queue(self, input: Option<String>) -> Self
pub fn set_celery_executor_queue(self, input: Option<String>) -> Self
The queue ARN for the environment's Celery Executor. Amazon MWAA uses a Celery Executor to distribute tasks across multiple workers. When you create an environment in a shared VPC, you must provide access to the Celery Executor queue from your VPC.
Sourcepub fn get_celery_executor_queue(&self) -> &Option<String>
pub fn get_celery_executor_queue(&self) -> &Option<String>
The queue ARN for the environment's Celery Executor. Amazon MWAA uses a Celery Executor to distribute tasks across multiple workers. When you create an environment in a shared VPC, you must provide access to the Celery Executor queue from your VPC.
Sourcepub fn endpoint_management(self, input: EndpointManagement) -> Self
pub fn endpoint_management(self, input: EndpointManagement) -> Self
Defines whether the VPC endpoints configured for the environment are created, and managed, by the customer or by Amazon MWAA. If set to SERVICE
, Amazon MWAA will create and manage the required VPC endpoints in your VPC. If set to CUSTOMER
, you must create, and manage, the VPC endpoints in your VPC.
Sourcepub fn set_endpoint_management(self, input: Option<EndpointManagement>) -> Self
pub fn set_endpoint_management(self, input: Option<EndpointManagement>) -> Self
Defines whether the VPC endpoints configured for the environment are created, and managed, by the customer or by Amazon MWAA. If set to SERVICE
, Amazon MWAA will create and manage the required VPC endpoints in your VPC. If set to CUSTOMER
, you must create, and manage, the VPC endpoints in your VPC.
Sourcepub fn get_endpoint_management(&self) -> &Option<EndpointManagement>
pub fn get_endpoint_management(&self) -> &Option<EndpointManagement>
Defines whether the VPC endpoints configured for the environment are created, and managed, by the customer or by Amazon MWAA. If set to SERVICE
, Amazon MWAA will create and manage the required VPC endpoints in your VPC. If set to CUSTOMER
, you must create, and manage, the VPC endpoints in your VPC.
Sourcepub fn min_webservers(self, input: i32) -> Self
pub fn min_webservers(self, input: i32) -> Self
The minimum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. As the transaction-per-second rate, and the network load, decrease, Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn set_min_webservers(self, input: Option<i32>) -> Self
pub fn set_min_webservers(self, input: Option<i32>) -> Self
The minimum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. As the transaction-per-second rate, and the network load, decrease, Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn get_min_webservers(&self) -> &Option<i32>
pub fn get_min_webservers(&self) -> &Option<i32>
The minimum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. As the transaction-per-second rate, and the network load, decrease, Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn max_webservers(self, input: i32) -> Self
pub fn max_webservers(self, input: i32) -> Self
The maximum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. For example, in scenarios where your workload requires network calls to the Apache Airflow REST API with a high transaction-per-second (TPS) rate, Amazon MWAA will increase the number of web servers up to the number set in MaxWebserers
. As TPS rates decrease Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn set_max_webservers(self, input: Option<i32>) -> Self
pub fn set_max_webservers(self, input: Option<i32>) -> Self
The maximum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. For example, in scenarios where your workload requires network calls to the Apache Airflow REST API with a high transaction-per-second (TPS) rate, Amazon MWAA will increase the number of web servers up to the number set in MaxWebserers
. As TPS rates decrease Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn get_max_webservers(&self) -> &Option<i32>
pub fn get_max_webservers(&self) -> &Option<i32>
The maximum number of web servers that you want to run in your environment. Amazon MWAA scales the number of Apache Airflow web servers up to the number you specify for MaxWebservers
when you interact with your Apache Airflow environment using Apache Airflow REST API, or the Apache Airflow CLI. For example, in scenarios where your workload requires network calls to the Apache Airflow REST API with a high transaction-per-second (TPS) rate, Amazon MWAA will increase the number of web servers up to the number set in MaxWebserers
. As TPS rates decrease Amazon MWAA disposes of the additional web servers, and scales down to the number set in MinxWebserers
.
Valid values: For environments larger than mw1.micro, accepts values from 2
to 5
. Defaults to 2
for all environment sizes except mw1.micro, which defaults to 1
.
Sourcepub fn build(self) -> Environment
pub fn build(self) -> Environment
Consumes the builder and constructs a Environment
.
Trait Implementations§
Source§impl Clone for EnvironmentBuilder
impl Clone for EnvironmentBuilder
Source§fn clone(&self) -> EnvironmentBuilder
fn clone(&self) -> EnvironmentBuilder
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for EnvironmentBuilder
impl Debug for EnvironmentBuilder
Source§impl Default for EnvironmentBuilder
impl Default for EnvironmentBuilder
Source§fn default() -> EnvironmentBuilder
fn default() -> EnvironmentBuilder
Source§impl PartialEq for EnvironmentBuilder
impl PartialEq for EnvironmentBuilder
impl StructuralPartialEq for EnvironmentBuilder
Auto Trait Implementations§
impl Freeze for EnvironmentBuilder
impl RefUnwindSafe for EnvironmentBuilder
impl Send for EnvironmentBuilder
impl Sync for EnvironmentBuilder
impl Unpin for EnvironmentBuilder
impl UnwindSafe for EnvironmentBuilder
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 moreSource§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
Source§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self
with the foreground set to
value
.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red()
and
green()
, which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg()
:
use yansi::{Paint, Color};
painted.fg(Color::White);
Set foreground color to white using white()
.
use yansi::Paint;
painted.white();
Source§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
Source§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
Source§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
Source§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
Source§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
Source§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
Source§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
Source§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
Source§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self
with the background set to
value
.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red()
and
on_green()
, which have the same functionality but
are pithier.
§Example
Set background color to red using fg()
:
use yansi::{Paint, Color};
painted.bg(Color::Red);
Set background color to red using on_red()
.
use yansi::Paint;
painted.on_red();
Source§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
Source§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
Source§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
Source§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
Source§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
Source§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
Source§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
Source§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
Source§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
Source§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
Source§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling Attribute
value
.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold()
and
underline()
, which have the same functionality
but are pithier.
§Example
Make text bold using attr()
:
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);
Make text bold using using bold()
.
use yansi::Paint;
painted.bold();
Source§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
Source§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi
Quirk
value
.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask()
and
wrap()
, which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk()
:
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);
Enable wrapping using wrap()
.
use yansi::Paint;
painted.wrap();
Source§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting()
due to conflicts with Vec::clear()
.
The clear()
method will be removed in a future release.
fn clear(&self) -> Painted<&T>
resetting()
due to conflicts with Vec::clear()
.
The clear()
method will be removed in a future release.Source§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the Condition
value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted
only when both stdout
and stderr
are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);