// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
#[derive(Debug)]
pub(crate) struct Handle {
pub(crate) client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
pub(crate) conf: crate::Config,
}
/// Client for Amazon DocumentDB Elastic Clusters
///
/// Client for invoking operations on Amazon DocumentDB Elastic Clusters. Each operation on Amazon DocumentDB Elastic Clusters is a method on this
/// this struct. `.send()` MUST be invoked on the generated operations to dispatch the request to the service.
///
/// # Examples
/// **Constructing a client and invoking an operation**
/// ```rust,no_run
/// # async fn docs() {
/// // create a shared configuration. This can be used & shared between multiple service clients.
/// let shared_config = aws_config::load_from_env().await;
/// let client = aws_sdk_docdbelastic::Client::new(&shared_config);
/// // invoke an operation
/// /* let rsp = client
/// .<operation_name>().
/// .<param>("some value")
/// .send().await; */
/// # }
/// ```
/// **Constructing a client with custom configuration**
/// ```rust,no_run
/// use aws_config::retry::RetryConfig;
/// # async fn docs() {
/// let shared_config = aws_config::load_from_env().await;
/// let config = aws_sdk_docdbelastic::config::Builder::from(&shared_config)
/// .retry_config(RetryConfig::disabled())
/// .build();
/// let client = aws_sdk_docdbelastic::Client::from_conf(config);
/// # }
#[derive(std::fmt::Debug)]
pub struct Client {
handle: std::sync::Arc<Handle>,
}
impl std::clone::Clone for Client {
fn clone(&self) -> Self {
Self {
handle: self.handle.clone(),
}
}
}
#[doc(inline)]
pub use aws_smithy_client::Builder;
impl
From<
aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
> for Client
{
fn from(
client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
) -> Self {
Self::with_config(client, crate::Config::builder().build())
}
}
impl Client {
/// Creates a client with the given service configuration.
pub fn with_config(
client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
conf: crate::Config,
) -> Self {
Self {
handle: std::sync::Arc::new(Handle { client, conf }),
}
}
/// Returns the client's configuration.
pub fn conf(&self) -> &crate::Config {
&self.handle.conf
}
}
impl Client {
/// Constructs a fluent builder for the [`CreateCluster`](crate::client::fluent_builders::CreateCluster) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_name(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::cluster_name) / [`set_cluster_name(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_cluster_name): <p>The name of the new Elastic DocumentDB cluster. This parameter is stored as a lowercase string.</p> <p> <i>Constraints</i>:</p> <ul> <li> <p>Must contain from 1 to 63 letters, numbers, or hyphens.</p> </li> <li> <p>The first character must be a letter.</p> </li> <li> <p>Cannot end with a hyphen or contain two consecutive hyphens.</p> </li> </ul> <p> <i>Example</i>: <code>my-cluster</code> </p>
/// - [`auth_type(Auth)`](crate::client::fluent_builders::CreateCluster::auth_type) / [`set_auth_type(Option<Auth>)`](crate::client::fluent_builders::CreateCluster::set_auth_type): <p>The authentication type for the Elastic DocumentDB cluster.</p>
/// - [`admin_user_name(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::admin_user_name) / [`set_admin_user_name(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_admin_user_name): <p>The name of the Elastic DocumentDB cluster administrator.</p> <p> <i>Constraints</i>:</p> <ul> <li> <p>Must be from 1 to 63 letters or numbers.</p> </li> <li> <p>The first character must be a letter.</p> </li> <li> <p>Cannot be a reserved word.</p> </li> </ul>
/// - [`admin_user_password(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::admin_user_password) / [`set_admin_user_password(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_admin_user_password): <p>The password for the Elastic DocumentDB cluster administrator and can contain any printable ASCII characters.</p> <p> <i>Constraints</i>:</p> <ul> <li> <p>Must contain from 8 to 100 characters.</p> </li> <li> <p>Cannot contain a forward slash (/), double quote ("), or the "at" symbol (@).</p> </li> </ul>
/// - [`shard_capacity(i32)`](crate::client::fluent_builders::CreateCluster::shard_capacity) / [`set_shard_capacity(Option<i32>)`](crate::client::fluent_builders::CreateCluster::set_shard_capacity): <p>The capacity of each shard in the new Elastic DocumentDB cluster.</p>
/// - [`shard_count(i32)`](crate::client::fluent_builders::CreateCluster::shard_count) / [`set_shard_count(Option<i32>)`](crate::client::fluent_builders::CreateCluster::set_shard_count): <p>The number of shards to create in the new Elastic DocumentDB cluster.</p>
/// - [`vpc_security_group_ids(Vec<String>)`](crate::client::fluent_builders::CreateCluster::vpc_security_group_ids) / [`set_vpc_security_group_ids(Option<Vec<String>>)`](crate::client::fluent_builders::CreateCluster::set_vpc_security_group_ids): <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
/// - [`subnet_ids(Vec<String>)`](crate::client::fluent_builders::CreateCluster::subnet_ids) / [`set_subnet_ids(Option<Vec<String>>)`](crate::client::fluent_builders::CreateCluster::set_subnet_ids): <p>The Amazon EC2 subnet IDs for the new Elastic DocumentDB cluster.</p>
/// - [`kms_key_id(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::kms_key_id) / [`set_kms_key_id(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_kms_key_id): <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p> <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p> <p>If an encryption key is not specified, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
/// - [`client_token(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::client_token) / [`set_client_token(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_client_token): <p>The client token for the Elastic DocumentDB cluster.</p>
/// - [`preferred_maintenance_window(impl Into<String>)`](crate::client::fluent_builders::CreateCluster::preferred_maintenance_window) / [`set_preferred_maintenance_window(Option<String>)`](crate::client::fluent_builders::CreateCluster::set_preferred_maintenance_window): <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p> <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p> <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p> <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p> <p> <i>Constraints</i>: Minimum 30-minute window.</p>
/// - [`tags(HashMap<String, String>)`](crate::client::fluent_builders::CreateCluster::tags) / [`set_tags(Option<HashMap<String, String>>)`](crate::client::fluent_builders::CreateCluster::set_tags): <p>The tags to be assigned to the new Elastic DocumentDB cluster.</p>
/// - On success, responds with [`CreateClusterOutput`](crate::output::CreateClusterOutput) with field(s):
/// - [`cluster(Option<Cluster>)`](crate::output::CreateClusterOutput::cluster): <p>The new Elastic DocumentDB cluster that has been created.</p>
/// - On failure, responds with [`SdkError<CreateClusterError>`](crate::error::CreateClusterError)
pub fn create_cluster(&self) -> fluent_builders::CreateCluster {
fluent_builders::CreateCluster::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`CreateClusterSnapshot`](crate::client::fluent_builders::CreateClusterSnapshot) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_arn(impl Into<String>)`](crate::client::fluent_builders::CreateClusterSnapshot::cluster_arn) / [`set_cluster_arn(Option<String>)`](crate::client::fluent_builders::CreateClusterSnapshot::set_cluster_arn): <p>The arn of the Elastic DocumentDB cluster that the snapshot will be taken from.</p>
/// - [`snapshot_name(impl Into<String>)`](crate::client::fluent_builders::CreateClusterSnapshot::snapshot_name) / [`set_snapshot_name(Option<String>)`](crate::client::fluent_builders::CreateClusterSnapshot::set_snapshot_name): <p>The name of the Elastic DocumentDB snapshot.</p>
/// - [`tags(HashMap<String, String>)`](crate::client::fluent_builders::CreateClusterSnapshot::tags) / [`set_tags(Option<HashMap<String, String>>)`](crate::client::fluent_builders::CreateClusterSnapshot::set_tags): <p>The tags to be assigned to the new Elastic DocumentDB snapshot.</p>
/// - On success, responds with [`CreateClusterSnapshotOutput`](crate::output::CreateClusterSnapshotOutput) with field(s):
/// - [`snapshot(Option<ClusterSnapshot>)`](crate::output::CreateClusterSnapshotOutput::snapshot): <p>Returns information about the new Elastic DocumentDB snapshot.</p>
/// - On failure, responds with [`SdkError<CreateClusterSnapshotError>`](crate::error::CreateClusterSnapshotError)
pub fn create_cluster_snapshot(&self) -> fluent_builders::CreateClusterSnapshot {
fluent_builders::CreateClusterSnapshot::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`DeleteCluster`](crate::client::fluent_builders::DeleteCluster) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_arn(impl Into<String>)`](crate::client::fluent_builders::DeleteCluster::cluster_arn) / [`set_cluster_arn(Option<String>)`](crate::client::fluent_builders::DeleteCluster::set_cluster_arn): <p>The arn of the Elastic DocumentDB cluster that is to be deleted.</p>
/// - On success, responds with [`DeleteClusterOutput`](crate::output::DeleteClusterOutput) with field(s):
/// - [`cluster(Option<Cluster>)`](crate::output::DeleteClusterOutput::cluster): <p>Returns information about the newly deleted Elastic DocumentDB cluster.</p>
/// - On failure, responds with [`SdkError<DeleteClusterError>`](crate::error::DeleteClusterError)
pub fn delete_cluster(&self) -> fluent_builders::DeleteCluster {
fluent_builders::DeleteCluster::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`DeleteClusterSnapshot`](crate::client::fluent_builders::DeleteClusterSnapshot) operation.
///
/// - The fluent builder is configurable:
/// - [`snapshot_arn(impl Into<String>)`](crate::client::fluent_builders::DeleteClusterSnapshot::snapshot_arn) / [`set_snapshot_arn(Option<String>)`](crate::client::fluent_builders::DeleteClusterSnapshot::set_snapshot_arn): <p>The arn of the Elastic DocumentDB snapshot that is to be deleted.</p>
/// - On success, responds with [`DeleteClusterSnapshotOutput`](crate::output::DeleteClusterSnapshotOutput) with field(s):
/// - [`snapshot(Option<ClusterSnapshot>)`](crate::output::DeleteClusterSnapshotOutput::snapshot): <p>Returns information about the newly deleted Elastic DocumentDB snapshot.</p>
/// - On failure, responds with [`SdkError<DeleteClusterSnapshotError>`](crate::error::DeleteClusterSnapshotError)
pub fn delete_cluster_snapshot(&self) -> fluent_builders::DeleteClusterSnapshot {
fluent_builders::DeleteClusterSnapshot::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`GetCluster`](crate::client::fluent_builders::GetCluster) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_arn(impl Into<String>)`](crate::client::fluent_builders::GetCluster::cluster_arn) / [`set_cluster_arn(Option<String>)`](crate::client::fluent_builders::GetCluster::set_cluster_arn): <p>The arn of the Elastic DocumentDB cluster.</p>
/// - On success, responds with [`GetClusterOutput`](crate::output::GetClusterOutput) with field(s):
/// - [`cluster(Option<Cluster>)`](crate::output::GetClusterOutput::cluster): <p>Returns information about a specific Elastic DocumentDB cluster.</p>
/// - On failure, responds with [`SdkError<GetClusterError>`](crate::error::GetClusterError)
pub fn get_cluster(&self) -> fluent_builders::GetCluster {
fluent_builders::GetCluster::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`GetClusterSnapshot`](crate::client::fluent_builders::GetClusterSnapshot) operation.
///
/// - The fluent builder is configurable:
/// - [`snapshot_arn(impl Into<String>)`](crate::client::fluent_builders::GetClusterSnapshot::snapshot_arn) / [`set_snapshot_arn(Option<String>)`](crate::client::fluent_builders::GetClusterSnapshot::set_snapshot_arn): <p>The arn of the Elastic DocumentDB snapshot.</p>
/// - On success, responds with [`GetClusterSnapshotOutput`](crate::output::GetClusterSnapshotOutput) with field(s):
/// - [`snapshot(Option<ClusterSnapshot>)`](crate::output::GetClusterSnapshotOutput::snapshot): <p>Returns information about a specific Elastic DocumentDB snapshot.</p>
/// - On failure, responds with [`SdkError<GetClusterSnapshotError>`](crate::error::GetClusterSnapshotError)
pub fn get_cluster_snapshot(&self) -> fluent_builders::GetClusterSnapshot {
fluent_builders::GetClusterSnapshot::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`ListClusters`](crate::client::fluent_builders::ListClusters) operation.
/// This operation supports pagination; See [`into_paginator()`](crate::client::fluent_builders::ListClusters::into_paginator).
///
/// - The fluent builder is configurable:
/// - [`next_token(impl Into<String>)`](crate::client::fluent_builders::ListClusters::next_token) / [`set_next_token(Option<String>)`](crate::client::fluent_builders::ListClusters::set_next_token): <p>The nextToken which is used the get the next page of data.</p>
/// - [`max_results(i32)`](crate::client::fluent_builders::ListClusters::max_results) / [`set_max_results(Option<i32>)`](crate::client::fluent_builders::ListClusters::set_max_results): <p>The maximum number of entries to recieve in the response.</p>
/// - On success, responds with [`ListClustersOutput`](crate::output::ListClustersOutput) with field(s):
/// - [`clusters(Option<Vec<ClusterInList>>)`](crate::output::ListClustersOutput::clusters): <p>A list of Elastic DocumentDB cluster.</p>
/// - [`next_token(Option<String>)`](crate::output::ListClustersOutput::next_token): <p>The response will provide a nextToken if there is more data beyond the maxResults.</p> <p>If there is no more data in the responce, the nextToken will not be returned.</p>
/// - On failure, responds with [`SdkError<ListClustersError>`](crate::error::ListClustersError)
pub fn list_clusters(&self) -> fluent_builders::ListClusters {
fluent_builders::ListClusters::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`ListClusterSnapshots`](crate::client::fluent_builders::ListClusterSnapshots) operation.
/// This operation supports pagination; See [`into_paginator()`](crate::client::fluent_builders::ListClusterSnapshots::into_paginator).
///
/// - The fluent builder is configurable:
/// - [`cluster_arn(impl Into<String>)`](crate::client::fluent_builders::ListClusterSnapshots::cluster_arn) / [`set_cluster_arn(Option<String>)`](crate::client::fluent_builders::ListClusterSnapshots::set_cluster_arn): <p>The arn of the Elastic DocumentDB cluster.</p>
/// - [`next_token(impl Into<String>)`](crate::client::fluent_builders::ListClusterSnapshots::next_token) / [`set_next_token(Option<String>)`](crate::client::fluent_builders::ListClusterSnapshots::set_next_token): <p>The nextToken which is used the get the next page of data.</p>
/// - [`max_results(i32)`](crate::client::fluent_builders::ListClusterSnapshots::max_results) / [`set_max_results(Option<i32>)`](crate::client::fluent_builders::ListClusterSnapshots::set_max_results): <p>The maximum number of entries to recieve in the response.</p>
/// - On success, responds with [`ListClusterSnapshotsOutput`](crate::output::ListClusterSnapshotsOutput) with field(s):
/// - [`snapshots(Option<Vec<ClusterSnapshotInList>>)`](crate::output::ListClusterSnapshotsOutput::snapshots): <p>A list of Elastic DocumentDB snapshots for a specified cluster.</p>
/// - [`next_token(Option<String>)`](crate::output::ListClusterSnapshotsOutput::next_token): <p>The response will provide a nextToken if there is more data beyond the maxResults.</p> <p>If there is no more data in the responce, the nextToken will not be returned.</p>
/// - On failure, responds with [`SdkError<ListClusterSnapshotsError>`](crate::error::ListClusterSnapshotsError)
pub fn list_cluster_snapshots(&self) -> fluent_builders::ListClusterSnapshots {
fluent_builders::ListClusterSnapshots::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`ListTagsForResource`](crate::client::fluent_builders::ListTagsForResource) operation.
///
/// - The fluent builder is configurable:
/// - [`resource_arn(impl Into<String>)`](crate::client::fluent_builders::ListTagsForResource::resource_arn) / [`set_resource_arn(Option<String>)`](crate::client::fluent_builders::ListTagsForResource::set_resource_arn): <p>The arn of the Elastic DocumentDB resource.</p>
/// - On success, responds with [`ListTagsForResourceOutput`](crate::output::ListTagsForResourceOutput) with field(s):
/// - [`tags(Option<HashMap<String, String>>)`](crate::output::ListTagsForResourceOutput::tags): <p>The list of tags for the specified Elastic DocumentDB resource.</p>
/// - On failure, responds with [`SdkError<ListTagsForResourceError>`](crate::error::ListTagsForResourceError)
pub fn list_tags_for_resource(&self) -> fluent_builders::ListTagsForResource {
fluent_builders::ListTagsForResource::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`RestoreClusterFromSnapshot`](crate::client::fluent_builders::RestoreClusterFromSnapshot) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_name(impl Into<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::cluster_name) / [`set_cluster_name(Option<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_cluster_name): <p>The name of the Elastic DocumentDB cluster.</p>
/// - [`snapshot_arn(impl Into<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::snapshot_arn) / [`set_snapshot_arn(Option<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_snapshot_arn): <p>The arn of the Elastic DocumentDB snapshot.</p>
/// - [`vpc_security_group_ids(Vec<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::vpc_security_group_ids) / [`set_vpc_security_group_ids(Option<Vec<String>>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_vpc_security_group_ids): <p>A list of EC2 VPC security groups to associate with the Elastic DocumentDB cluster.</p>
/// - [`subnet_ids(Vec<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::subnet_ids) / [`set_subnet_ids(Option<Vec<String>>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_subnet_ids): <p>The Amazon EC2 subnet IDs for the Elastic DocumentDB cluster.</p>
/// - [`kms_key_id(impl Into<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::kms_key_id) / [`set_kms_key_id(Option<String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_kms_key_id): <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p> <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p> <p>If an encryption key is not specified here, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
/// - [`tags(HashMap<String, String>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::tags) / [`set_tags(Option<HashMap<String, String>>)`](crate::client::fluent_builders::RestoreClusterFromSnapshot::set_tags): <p>A list of the tag names to be assigned to the restored DB cluster, in the form of an array of key-value pairs in which the key is the tag name and the value is the key value.</p>
/// - On success, responds with [`RestoreClusterFromSnapshotOutput`](crate::output::RestoreClusterFromSnapshotOutput) with field(s):
/// - [`cluster(Option<Cluster>)`](crate::output::RestoreClusterFromSnapshotOutput::cluster): <p>Returns information about a the restored Elastic DocumentDB cluster.</p>
/// - On failure, responds with [`SdkError<RestoreClusterFromSnapshotError>`](crate::error::RestoreClusterFromSnapshotError)
pub fn restore_cluster_from_snapshot(&self) -> fluent_builders::RestoreClusterFromSnapshot {
fluent_builders::RestoreClusterFromSnapshot::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`TagResource`](crate::client::fluent_builders::TagResource) operation.
///
/// - The fluent builder is configurable:
/// - [`resource_arn(impl Into<String>)`](crate::client::fluent_builders::TagResource::resource_arn) / [`set_resource_arn(Option<String>)`](crate::client::fluent_builders::TagResource::set_resource_arn): <p>The arn of the Elastic DocumentDB resource.</p>
/// - [`tags(HashMap<String, String>)`](crate::client::fluent_builders::TagResource::tags) / [`set_tags(Option<HashMap<String, String>>)`](crate::client::fluent_builders::TagResource::set_tags): <p>The tags to be assigned to the Elastic DocumentDB resource.</p>
/// - On success, responds with [`TagResourceOutput`](crate::output::TagResourceOutput)
/// - On failure, responds with [`SdkError<TagResourceError>`](crate::error::TagResourceError)
pub fn tag_resource(&self) -> fluent_builders::TagResource {
fluent_builders::TagResource::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`UntagResource`](crate::client::fluent_builders::UntagResource) operation.
///
/// - The fluent builder is configurable:
/// - [`resource_arn(impl Into<String>)`](crate::client::fluent_builders::UntagResource::resource_arn) / [`set_resource_arn(Option<String>)`](crate::client::fluent_builders::UntagResource::set_resource_arn): <p>The arn of the Elastic DocumentDB resource.</p>
/// - [`tag_keys(Vec<String>)`](crate::client::fluent_builders::UntagResource::tag_keys) / [`set_tag_keys(Option<Vec<String>>)`](crate::client::fluent_builders::UntagResource::set_tag_keys): <p>The tag keys to be removed from the Elastic DocumentDB resource.</p>
/// - On success, responds with [`UntagResourceOutput`](crate::output::UntagResourceOutput)
/// - On failure, responds with [`SdkError<UntagResourceError>`](crate::error::UntagResourceError)
pub fn untag_resource(&self) -> fluent_builders::UntagResource {
fluent_builders::UntagResource::new(self.handle.clone())
}
/// Constructs a fluent builder for the [`UpdateCluster`](crate::client::fluent_builders::UpdateCluster) operation.
///
/// - The fluent builder is configurable:
/// - [`cluster_arn(impl Into<String>)`](crate::client::fluent_builders::UpdateCluster::cluster_arn) / [`set_cluster_arn(Option<String>)`](crate::client::fluent_builders::UpdateCluster::set_cluster_arn): <p>The arn of the Elastic DocumentDB cluster.</p>
/// - [`auth_type(Auth)`](crate::client::fluent_builders::UpdateCluster::auth_type) / [`set_auth_type(Option<Auth>)`](crate::client::fluent_builders::UpdateCluster::set_auth_type): <p>The authentication type for the Elastic DocumentDB cluster.</p>
/// - [`shard_capacity(i32)`](crate::client::fluent_builders::UpdateCluster::shard_capacity) / [`set_shard_capacity(Option<i32>)`](crate::client::fluent_builders::UpdateCluster::set_shard_capacity): <p>The capacity of each shard in the Elastic DocumentDB cluster.</p>
/// - [`shard_count(i32)`](crate::client::fluent_builders::UpdateCluster::shard_count) / [`set_shard_count(Option<i32>)`](crate::client::fluent_builders::UpdateCluster::set_shard_count): <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
/// - [`vpc_security_group_ids(Vec<String>)`](crate::client::fluent_builders::UpdateCluster::vpc_security_group_ids) / [`set_vpc_security_group_ids(Option<Vec<String>>)`](crate::client::fluent_builders::UpdateCluster::set_vpc_security_group_ids): <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
/// - [`subnet_ids(Vec<String>)`](crate::client::fluent_builders::UpdateCluster::subnet_ids) / [`set_subnet_ids(Option<Vec<String>>)`](crate::client::fluent_builders::UpdateCluster::set_subnet_ids): <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
/// - [`admin_user_password(impl Into<String>)`](crate::client::fluent_builders::UpdateCluster::admin_user_password) / [`set_admin_user_password(Option<String>)`](crate::client::fluent_builders::UpdateCluster::set_admin_user_password): <p>The password for the Elastic DocumentDB cluster administrator. This password can contain any printable ASCII character except forward slash (/), double quote ("), or the "at" symbol (@).</p> <p> <i>Constraints</i>: Must contain from 8 to 100 characters.</p>
/// - [`client_token(impl Into<String>)`](crate::client::fluent_builders::UpdateCluster::client_token) / [`set_client_token(Option<String>)`](crate::client::fluent_builders::UpdateCluster::set_client_token): <p>The client token for the Elastic DocumentDB cluster.</p>
/// - [`preferred_maintenance_window(impl Into<String>)`](crate::client::fluent_builders::UpdateCluster::preferred_maintenance_window) / [`set_preferred_maintenance_window(Option<String>)`](crate::client::fluent_builders::UpdateCluster::set_preferred_maintenance_window): <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p> <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p> <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p> <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p> <p> <i>Constraints</i>: Minimum 30-minute window.</p>
/// - On success, responds with [`UpdateClusterOutput`](crate::output::UpdateClusterOutput) with field(s):
/// - [`cluster(Option<Cluster>)`](crate::output::UpdateClusterOutput::cluster): <p>Returns information about the updated Elastic DocumentDB cluster.</p>
/// - On failure, responds with [`SdkError<UpdateClusterError>`](crate::error::UpdateClusterError)
pub fn update_cluster(&self) -> fluent_builders::UpdateCluster {
fluent_builders::UpdateCluster::new(self.handle.clone())
}
}
pub mod fluent_builders {
//! Utilities to ergonomically construct a request to the service.
//!
//! Fluent builders are created through the [`Client`](crate::client::Client) by calling
//! one if its operation methods. After parameters are set using the builder methods,
//! the `send` method can be called to initiate the request.
/// Fluent builder constructing a request to `CreateCluster`.
///
/// <p>Creates a new Elastic DocumentDB cluster and returns its Cluster structure.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct CreateCluster {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::create_cluster_input::Builder,
}
impl CreateCluster {
/// Creates a new `CreateCluster`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::CreateCluster,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::CreateClusterError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::CreateClusterOutput,
aws_smithy_http::result::SdkError<crate::error::CreateClusterError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The name of the new Elastic DocumentDB cluster. This parameter is stored as a lowercase string.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must contain from 1 to 63 letters, numbers, or hyphens.</p> </li>
/// <li> <p>The first character must be a letter.</p> </li>
/// <li> <p>Cannot end with a hyphen or contain two consecutive hyphens.</p> </li>
/// </ul>
/// <p> <i>Example</i>: <code>my-cluster</code> </p>
pub fn cluster_name(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_name(input.into());
self
}
/// <p>The name of the new Elastic DocumentDB cluster. This parameter is stored as a lowercase string.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must contain from 1 to 63 letters, numbers, or hyphens.</p> </li>
/// <li> <p>The first character must be a letter.</p> </li>
/// <li> <p>Cannot end with a hyphen or contain two consecutive hyphens.</p> </li>
/// </ul>
/// <p> <i>Example</i>: <code>my-cluster</code> </p>
pub fn set_cluster_name(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_name(input);
self
}
/// <p>The authentication type for the Elastic DocumentDB cluster.</p>
pub fn auth_type(mut self, input: crate::model::Auth) -> Self {
self.inner = self.inner.auth_type(input);
self
}
/// <p>The authentication type for the Elastic DocumentDB cluster.</p>
pub fn set_auth_type(mut self, input: std::option::Option<crate::model::Auth>) -> Self {
self.inner = self.inner.set_auth_type(input);
self
}
/// <p>The name of the Elastic DocumentDB cluster administrator.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must be from 1 to 63 letters or numbers.</p> </li>
/// <li> <p>The first character must be a letter.</p> </li>
/// <li> <p>Cannot be a reserved word.</p> </li>
/// </ul>
pub fn admin_user_name(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.admin_user_name(input.into());
self
}
/// <p>The name of the Elastic DocumentDB cluster administrator.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must be from 1 to 63 letters or numbers.</p> </li>
/// <li> <p>The first character must be a letter.</p> </li>
/// <li> <p>Cannot be a reserved word.</p> </li>
/// </ul>
pub fn set_admin_user_name(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_admin_user_name(input);
self
}
/// <p>The password for the Elastic DocumentDB cluster administrator and can contain any printable ASCII characters.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must contain from 8 to 100 characters.</p> </li>
/// <li> <p>Cannot contain a forward slash (/), double quote ("), or the "at" symbol (@).</p> </li>
/// </ul>
pub fn admin_user_password(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.admin_user_password(input.into());
self
}
/// <p>The password for the Elastic DocumentDB cluster administrator and can contain any printable ASCII characters.</p>
/// <p> <i>Constraints</i>:</p>
/// <ul>
/// <li> <p>Must contain from 8 to 100 characters.</p> </li>
/// <li> <p>Cannot contain a forward slash (/), double quote ("), or the "at" symbol (@).</p> </li>
/// </ul>
pub fn set_admin_user_password(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_admin_user_password(input);
self
}
/// <p>The capacity of each shard in the new Elastic DocumentDB cluster.</p>
pub fn shard_capacity(mut self, input: i32) -> Self {
self.inner = self.inner.shard_capacity(input);
self
}
/// <p>The capacity of each shard in the new Elastic DocumentDB cluster.</p>
pub fn set_shard_capacity(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_shard_capacity(input);
self
}
/// <p>The number of shards to create in the new Elastic DocumentDB cluster.</p>
pub fn shard_count(mut self, input: i32) -> Self {
self.inner = self.inner.shard_count(input);
self
}
/// <p>The number of shards to create in the new Elastic DocumentDB cluster.</p>
pub fn set_shard_count(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_shard_count(input);
self
}
/// Appends an item to `vpcSecurityGroupIds`.
///
/// To override the contents of this collection use [`set_vpc_security_group_ids`](Self::set_vpc_security_group_ids).
///
/// <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
pub fn vpc_security_group_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.vpc_security_group_ids(input.into());
self
}
/// <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
pub fn set_vpc_security_group_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_vpc_security_group_ids(input);
self
}
/// Appends an item to `subnetIds`.
///
/// To override the contents of this collection use [`set_subnet_ids`](Self::set_subnet_ids).
///
/// <p>The Amazon EC2 subnet IDs for the new Elastic DocumentDB cluster.</p>
pub fn subnet_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.subnet_ids(input.into());
self
}
/// <p>The Amazon EC2 subnet IDs for the new Elastic DocumentDB cluster.</p>
pub fn set_subnet_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_subnet_ids(input);
self
}
/// <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p>
/// <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p>
/// <p>If an encryption key is not specified, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
pub fn kms_key_id(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.kms_key_id(input.into());
self
}
/// <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p>
/// <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p>
/// <p>If an encryption key is not specified, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
pub fn set_kms_key_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_kms_key_id(input);
self
}
/// <p>The client token for the Elastic DocumentDB cluster.</p>
pub fn client_token(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.client_token(input.into());
self
}
/// <p>The client token for the Elastic DocumentDB cluster.</p>
pub fn set_client_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_client_token(input);
self
}
/// <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p>
/// <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p>
/// <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p>
/// <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p>
/// <p> <i>Constraints</i>: Minimum 30-minute window.</p>
pub fn preferred_maintenance_window(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.preferred_maintenance_window(input.into());
self
}
/// <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p>
/// <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p>
/// <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p>
/// <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p>
/// <p> <i>Constraints</i>: Minimum 30-minute window.</p>
pub fn set_preferred_maintenance_window(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_preferred_maintenance_window(input);
self
}
/// Adds a key-value pair to `tags`.
///
/// To override the contents of this collection use [`set_tags`](Self::set_tags).
///
/// <p>The tags to be assigned to the new Elastic DocumentDB cluster.</p>
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.tags(k.into(), v.into());
self
}
/// <p>The tags to be assigned to the new Elastic DocumentDB cluster.</p>
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.inner = self.inner.set_tags(input);
self
}
}
/// Fluent builder constructing a request to `CreateClusterSnapshot`.
///
/// <p>Creates a snapshot of a cluster.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct CreateClusterSnapshot {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::create_cluster_snapshot_input::Builder,
}
impl CreateClusterSnapshot {
/// Creates a new `CreateClusterSnapshot`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::CreateClusterSnapshot,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::CreateClusterSnapshotError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::CreateClusterSnapshotOutput,
aws_smithy_http::result::SdkError<crate::error::CreateClusterSnapshotError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB cluster that the snapshot will be taken from.</p>
pub fn cluster_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB cluster that the snapshot will be taken from.</p>
pub fn set_cluster_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_arn(input);
self
}
/// <p>The name of the Elastic DocumentDB snapshot.</p>
pub fn snapshot_name(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.snapshot_name(input.into());
self
}
/// <p>The name of the Elastic DocumentDB snapshot.</p>
pub fn set_snapshot_name(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_snapshot_name(input);
self
}
/// Adds a key-value pair to `tags`.
///
/// To override the contents of this collection use [`set_tags`](Self::set_tags).
///
/// <p>The tags to be assigned to the new Elastic DocumentDB snapshot.</p>
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.tags(k.into(), v.into());
self
}
/// <p>The tags to be assigned to the new Elastic DocumentDB snapshot.</p>
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.inner = self.inner.set_tags(input);
self
}
}
/// Fluent builder constructing a request to `DeleteCluster`.
///
/// <p>Delete a Elastic DocumentDB cluster.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct DeleteCluster {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::delete_cluster_input::Builder,
}
impl DeleteCluster {
/// Creates a new `DeleteCluster`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::DeleteCluster,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::DeleteClusterError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::DeleteClusterOutput,
aws_smithy_http::result::SdkError<crate::error::DeleteClusterError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB cluster that is to be deleted.</p>
pub fn cluster_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB cluster that is to be deleted.</p>
pub fn set_cluster_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_arn(input);
self
}
}
/// Fluent builder constructing a request to `DeleteClusterSnapshot`.
///
/// <p>Delete a Elastic DocumentDB snapshot.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct DeleteClusterSnapshot {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::delete_cluster_snapshot_input::Builder,
}
impl DeleteClusterSnapshot {
/// Creates a new `DeleteClusterSnapshot`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::DeleteClusterSnapshot,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::DeleteClusterSnapshotError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::DeleteClusterSnapshotOutput,
aws_smithy_http::result::SdkError<crate::error::DeleteClusterSnapshotError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB snapshot that is to be deleted.</p>
pub fn snapshot_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.snapshot_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB snapshot that is to be deleted.</p>
pub fn set_snapshot_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_snapshot_arn(input);
self
}
}
/// Fluent builder constructing a request to `GetCluster`.
///
/// <p>Returns information about a specific Elastic DocumentDB cluster.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct GetCluster {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::get_cluster_input::Builder,
}
impl GetCluster {
/// Creates a new `GetCluster`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::GetCluster,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::GetClusterError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::GetClusterOutput,
aws_smithy_http::result::SdkError<crate::error::GetClusterError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn cluster_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn set_cluster_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_arn(input);
self
}
}
/// Fluent builder constructing a request to `GetClusterSnapshot`.
///
/// <p>Returns information about a specific Elastic DocumentDB snapshot</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct GetClusterSnapshot {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::get_cluster_snapshot_input::Builder,
}
impl GetClusterSnapshot {
/// Creates a new `GetClusterSnapshot`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::GetClusterSnapshot,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::GetClusterSnapshotError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::GetClusterSnapshotOutput,
aws_smithy_http::result::SdkError<crate::error::GetClusterSnapshotError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB snapshot.</p>
pub fn snapshot_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.snapshot_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB snapshot.</p>
pub fn set_snapshot_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_snapshot_arn(input);
self
}
}
/// Fluent builder constructing a request to `ListClusters`.
///
/// <p>Returns information about provisioned Elastic DocumentDB clusters.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct ListClusters {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::list_clusters_input::Builder,
}
impl ListClusters {
/// Creates a new `ListClusters`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::ListClusters,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::ListClustersError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::ListClustersOutput,
aws_smithy_http::result::SdkError<crate::error::ListClustersError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// Create a paginator for this request
///
/// Paginators are used by calling [`send().await`](crate::paginator::ListClustersPaginator::send) which returns a [`Stream`](tokio_stream::Stream).
pub fn into_paginator(self) -> crate::paginator::ListClustersPaginator {
crate::paginator::ListClustersPaginator::new(self.handle, self.inner)
}
/// <p>The nextToken which is used the get the next page of data.</p>
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.next_token(input.into());
self
}
/// <p>The nextToken which is used the get the next page of data.</p>
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_next_token(input);
self
}
/// <p>The maximum number of entries to recieve in the response.</p>
pub fn max_results(mut self, input: i32) -> Self {
self.inner = self.inner.max_results(input);
self
}
/// <p>The maximum number of entries to recieve in the response.</p>
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_max_results(input);
self
}
}
/// Fluent builder constructing a request to `ListClusterSnapshots`.
///
/// <p>Returns information about Elastic DocumentDB snapshots for a specified cluster.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct ListClusterSnapshots {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::list_cluster_snapshots_input::Builder,
}
impl ListClusterSnapshots {
/// Creates a new `ListClusterSnapshots`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::ListClusterSnapshots,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::ListClusterSnapshotsError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::ListClusterSnapshotsOutput,
aws_smithy_http::result::SdkError<crate::error::ListClusterSnapshotsError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// Create a paginator for this request
///
/// Paginators are used by calling [`send().await`](crate::paginator::ListClusterSnapshotsPaginator::send) which returns a [`Stream`](tokio_stream::Stream).
pub fn into_paginator(self) -> crate::paginator::ListClusterSnapshotsPaginator {
crate::paginator::ListClusterSnapshotsPaginator::new(self.handle, self.inner)
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn cluster_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn set_cluster_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_arn(input);
self
}
/// <p>The nextToken which is used the get the next page of data.</p>
pub fn next_token(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.next_token(input.into());
self
}
/// <p>The nextToken which is used the get the next page of data.</p>
pub fn set_next_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_next_token(input);
self
}
/// <p>The maximum number of entries to recieve in the response.</p>
pub fn max_results(mut self, input: i32) -> Self {
self.inner = self.inner.max_results(input);
self
}
/// <p>The maximum number of entries to recieve in the response.</p>
pub fn set_max_results(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_max_results(input);
self
}
}
/// Fluent builder constructing a request to `ListTagsForResource`.
///
/// <p>Lists all tags on a Elastic DocumentDB resource</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct ListTagsForResource {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::list_tags_for_resource_input::Builder,
}
impl ListTagsForResource {
/// Creates a new `ListTagsForResource`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::ListTagsForResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::ListTagsForResourceError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::ListTagsForResourceOutput,
aws_smithy_http::result::SdkError<crate::error::ListTagsForResourceError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.resource_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_resource_arn(input);
self
}
}
/// Fluent builder constructing a request to `RestoreClusterFromSnapshot`.
///
/// <p>Restores a Elastic DocumentDB cluster from a snapshot.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct RestoreClusterFromSnapshot {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::restore_cluster_from_snapshot_input::Builder,
}
impl RestoreClusterFromSnapshot {
/// Creates a new `RestoreClusterFromSnapshot`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::RestoreClusterFromSnapshot,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::RestoreClusterFromSnapshotError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::RestoreClusterFromSnapshotOutput,
aws_smithy_http::result::SdkError<crate::error::RestoreClusterFromSnapshotError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The name of the Elastic DocumentDB cluster.</p>
pub fn cluster_name(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_name(input.into());
self
}
/// <p>The name of the Elastic DocumentDB cluster.</p>
pub fn set_cluster_name(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_name(input);
self
}
/// <p>The arn of the Elastic DocumentDB snapshot.</p>
pub fn snapshot_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.snapshot_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB snapshot.</p>
pub fn set_snapshot_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_snapshot_arn(input);
self
}
/// Appends an item to `vpcSecurityGroupIds`.
///
/// To override the contents of this collection use [`set_vpc_security_group_ids`](Self::set_vpc_security_group_ids).
///
/// <p>A list of EC2 VPC security groups to associate with the Elastic DocumentDB cluster.</p>
pub fn vpc_security_group_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.vpc_security_group_ids(input.into());
self
}
/// <p>A list of EC2 VPC security groups to associate with the Elastic DocumentDB cluster.</p>
pub fn set_vpc_security_group_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_vpc_security_group_ids(input);
self
}
/// Appends an item to `subnetIds`.
///
/// To override the contents of this collection use [`set_subnet_ids`](Self::set_subnet_ids).
///
/// <p>The Amazon EC2 subnet IDs for the Elastic DocumentDB cluster.</p>
pub fn subnet_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.subnet_ids(input.into());
self
}
/// <p>The Amazon EC2 subnet IDs for the Elastic DocumentDB cluster.</p>
pub fn set_subnet_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_subnet_ids(input);
self
}
/// <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p>
/// <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p>
/// <p>If an encryption key is not specified here, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
pub fn kms_key_id(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.kms_key_id(input.into());
self
}
/// <p>The KMS key identifier to use to encrypt the new Elastic DocumentDB cluster.</p>
/// <p>The KMS key identifier is the Amazon Resource Name (ARN) for the KMS encryption key. If you are creating a cluster using the same Amazon account that owns this KMS encryption key, you can use the KMS key alias instead of the ARN as the KMS encryption key.</p>
/// <p>If an encryption key is not specified here, Elastic DocumentDB uses the default encryption key that KMS creates for your account. Your account has a different default encryption key for each Amazon Region.</p>
pub fn set_kms_key_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_kms_key_id(input);
self
}
/// Adds a key-value pair to `tags`.
///
/// To override the contents of this collection use [`set_tags`](Self::set_tags).
///
/// <p>A list of the tag names to be assigned to the restored DB cluster, in the form of an array of key-value pairs in which the key is the tag name and the value is the key value.</p>
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.tags(k.into(), v.into());
self
}
/// <p>A list of the tag names to be assigned to the restored DB cluster, in the form of an array of key-value pairs in which the key is the tag name and the value is the key value.</p>
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.inner = self.inner.set_tags(input);
self
}
}
/// Fluent builder constructing a request to `TagResource`.
///
/// <p>Adds metadata tags to a Elastic DocumentDB resource</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct TagResource {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::tag_resource_input::Builder,
}
impl TagResource {
/// Creates a new `TagResource`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::TagResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::TagResourceError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::TagResourceOutput,
aws_smithy_http::result::SdkError<crate::error::TagResourceError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.resource_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_resource_arn(input);
self
}
/// Adds a key-value pair to `tags`.
///
/// To override the contents of this collection use [`set_tags`](Self::set_tags).
///
/// <p>The tags to be assigned to the Elastic DocumentDB resource.</p>
pub fn tags(
mut self,
k: impl Into<std::string::String>,
v: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.tags(k.into(), v.into());
self
}
/// <p>The tags to be assigned to the Elastic DocumentDB resource.</p>
pub fn set_tags(
mut self,
input: std::option::Option<
std::collections::HashMap<std::string::String, std::string::String>,
>,
) -> Self {
self.inner = self.inner.set_tags(input);
self
}
}
/// Fluent builder constructing a request to `UntagResource`.
///
/// <p>Removes metadata tags to a Elastic DocumentDB resource</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct UntagResource {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::untag_resource_input::Builder,
}
impl UntagResource {
/// Creates a new `UntagResource`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::UntagResource,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::UntagResourceError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::UntagResourceOutput,
aws_smithy_http::result::SdkError<crate::error::UntagResourceError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn resource_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.resource_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB resource.</p>
pub fn set_resource_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_resource_arn(input);
self
}
/// Appends an item to `tagKeys`.
///
/// To override the contents of this collection use [`set_tag_keys`](Self::set_tag_keys).
///
/// <p>The tag keys to be removed from the Elastic DocumentDB resource.</p>
pub fn tag_keys(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.tag_keys(input.into());
self
}
/// <p>The tag keys to be removed from the Elastic DocumentDB resource.</p>
pub fn set_tag_keys(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_tag_keys(input);
self
}
}
/// Fluent builder constructing a request to `UpdateCluster`.
///
/// <p>Modifies a Elastic DocumentDB cluster. This includes updating admin-username/password, upgrading API version setting up a backup window and maintenance window</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct UpdateCluster {
handle: std::sync::Arc<super::Handle>,
inner: crate::input::update_cluster_input::Builder,
}
impl UpdateCluster {
/// Creates a new `UpdateCluster`.
pub(crate) fn new(handle: std::sync::Arc<super::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::operation::customize::CustomizableOperation<
crate::operation::UpdateCluster,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<crate::error::UpdateClusterError>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::operation::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::output::UpdateClusterOutput,
aws_smithy_http::result::SdkError<crate::error::UpdateClusterError>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn cluster_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cluster_arn(input.into());
self
}
/// <p>The arn of the Elastic DocumentDB cluster.</p>
pub fn set_cluster_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_cluster_arn(input);
self
}
/// <p>The authentication type for the Elastic DocumentDB cluster.</p>
pub fn auth_type(mut self, input: crate::model::Auth) -> Self {
self.inner = self.inner.auth_type(input);
self
}
/// <p>The authentication type for the Elastic DocumentDB cluster.</p>
pub fn set_auth_type(mut self, input: std::option::Option<crate::model::Auth>) -> Self {
self.inner = self.inner.set_auth_type(input);
self
}
/// <p>The capacity of each shard in the Elastic DocumentDB cluster.</p>
pub fn shard_capacity(mut self, input: i32) -> Self {
self.inner = self.inner.shard_capacity(input);
self
}
/// <p>The capacity of each shard in the Elastic DocumentDB cluster.</p>
pub fn set_shard_capacity(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_shard_capacity(input);
self
}
/// <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
pub fn shard_count(mut self, input: i32) -> Self {
self.inner = self.inner.shard_count(input);
self
}
/// <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
pub fn set_shard_count(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_shard_count(input);
self
}
/// Appends an item to `vpcSecurityGroupIds`.
///
/// To override the contents of this collection use [`set_vpc_security_group_ids`](Self::set_vpc_security_group_ids).
///
/// <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
pub fn vpc_security_group_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.vpc_security_group_ids(input.into());
self
}
/// <p>A list of EC2 VPC security groups to associate with the new Elastic DocumentDB cluster.</p>
pub fn set_vpc_security_group_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_vpc_security_group_ids(input);
self
}
/// Appends an item to `subnetIds`.
///
/// To override the contents of this collection use [`set_subnet_ids`](Self::set_subnet_ids).
///
/// <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
pub fn subnet_ids(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.subnet_ids(input.into());
self
}
/// <p>The number of shards to create in the Elastic DocumentDB cluster.</p>
pub fn set_subnet_ids(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_subnet_ids(input);
self
}
/// <p>The password for the Elastic DocumentDB cluster administrator. This password can contain any printable ASCII character except forward slash (/), double quote ("), or the "at" symbol (@).</p>
/// <p> <i>Constraints</i>: Must contain from 8 to 100 characters.</p>
pub fn admin_user_password(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.admin_user_password(input.into());
self
}
/// <p>The password for the Elastic DocumentDB cluster administrator. This password can contain any printable ASCII character except forward slash (/), double quote ("), or the "at" symbol (@).</p>
/// <p> <i>Constraints</i>: Must contain from 8 to 100 characters.</p>
pub fn set_admin_user_password(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_admin_user_password(input);
self
}
/// <p>The client token for the Elastic DocumentDB cluster.</p>
pub fn client_token(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.client_token(input.into());
self
}
/// <p>The client token for the Elastic DocumentDB cluster.</p>
pub fn set_client_token(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_client_token(input);
self
}
/// <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p>
/// <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p>
/// <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p>
/// <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p>
/// <p> <i>Constraints</i>: Minimum 30-minute window.</p>
pub fn preferred_maintenance_window(
mut self,
input: impl Into<std::string::String>,
) -> Self {
self.inner = self.inner.preferred_maintenance_window(input.into());
self
}
/// <p>The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).</p>
/// <p> <i>Format</i>: <code>ddd:hh24:mi-ddd:hh24:mi</code> </p>
/// <p> <i>Default</i>: a 30-minute window selected at random from an 8-hour block of time for each Amazon Web Services Region, occurring on a random day of the week.</p>
/// <p> <i>Valid days</i>: Mon, Tue, Wed, Thu, Fri, Sat, Sun</p>
/// <p> <i>Constraints</i>: Minimum 30-minute window.</p>
pub fn set_preferred_maintenance_window(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_preferred_maintenance_window(input);
self
}
}
}
impl Client {
/// Creates a new client from an [SDK Config](aws_types::sdk_config::SdkConfig).
///
/// # Panics
///
/// - This method will panic if the `sdk_config` is missing an async sleep implementation. If you experience this panic, set
/// the `sleep_impl` on the Config passed into this function to fix it.
/// - This method will panic if the `sdk_config` is missing an HTTP connector. If you experience this panic, set the
/// `http_connector` on the Config passed into this function to fix it.
pub fn new(sdk_config: &aws_types::sdk_config::SdkConfig) -> Self {
Self::from_conf(sdk_config.into())
}
/// Creates a new client from the service [`Config`](crate::Config).
///
/// # Panics
///
/// - This method will panic if the `conf` is missing an async sleep implementation. If you experience this panic, set
/// the `sleep_impl` on the Config passed into this function to fix it.
/// - This method will panic if the `conf` is missing an HTTP connector. If you experience this panic, set the
/// `http_connector` on the Config passed into this function to fix it.
pub fn from_conf(conf: crate::Config) -> Self {
let retry_config = conf
.retry_config()
.cloned()
.unwrap_or_else(aws_smithy_types::retry::RetryConfig::disabled);
let timeout_config = conf
.timeout_config()
.cloned()
.unwrap_or_else(aws_smithy_types::timeout::TimeoutConfig::disabled);
let sleep_impl = conf.sleep_impl();
if (retry_config.has_retry() || timeout_config.has_timeouts()) && sleep_impl.is_none() {
panic!("An async sleep implementation is required for retries or timeouts to work. \
Set the `sleep_impl` on the Config passed into this function to fix this panic.");
}
let connector = conf.http_connector().and_then(|c| {
let timeout_config = conf
.timeout_config()
.cloned()
.unwrap_or_else(aws_smithy_types::timeout::TimeoutConfig::disabled);
let connector_settings =
aws_smithy_client::http_connector::ConnectorSettings::from_timeout_config(
&timeout_config,
);
c.connector(&connector_settings, conf.sleep_impl())
});
let builder = aws_smithy_client::Builder::new();
let builder = match connector {
// Use provided connector
Some(c) => builder.connector(c),
None => {
#[cfg(any(feature = "rustls", feature = "native-tls"))]
{
// Use default connector based on enabled features
builder.dyn_https_connector(
aws_smithy_client::http_connector::ConnectorSettings::from_timeout_config(
&timeout_config,
),
)
}
#[cfg(not(any(feature = "rustls", feature = "native-tls")))]
{
panic!("No HTTP connector was available. Enable the `rustls` or `native-tls` crate feature or set a connector to fix this.");
}
}
};
let mut builder = builder
.middleware(aws_smithy_client::erase::DynMiddleware::new(
crate::middleware::DefaultMiddleware::new(),
))
.retry_config(retry_config.into())
.operation_timeout_config(timeout_config.into());
builder.set_sleep_impl(sleep_impl);
let client = builder.build();
Self {
handle: std::sync::Arc::new(Handle { client, conf }),
}
}
}