Struct aws_sdk_elasticache::client::fluent_builders::CreateReplicationGroup

source ·

pub struct CreateReplicationGroup { /* private fields */ }

Expand description

Fluent builder constructing a request to CreateReplicationGroup.

Creates a Redis (cluster mode disabled) or a Redis (cluster mode enabled) replication group.

This API can be used to create a standalone regional replication group or a secondary replication group associated with a Global datastore.

A Redis (cluster mode disabled) replication group is a collection of clusters, where one of the clusters is a read/write primary and the others are read-only replicas. Writes to the primary are asynchronously propagated to the replicas.

A Redis cluster-mode enabled cluster is comprised of from 1 to 90 shards (API/CLI: node groups). Each shard has a primary node and up to 5 read-only replica nodes. The configuration can range from 90 shards and 0 replicas to 15 shards and 5 replicas, which is the maximum number or replicas allowed.

The node or shard limit can be increased to a maximum of 500 per cluster if the Redis engine version is 5.0.6 or higher. For example, you can choose to configure a 500 node cluster that ranges between 83 shards (one primary and 5 replicas per shard) and 500 shards (single primary and no replicas). Make sure there are enough available IP addresses to accommodate the increase. Common pitfalls include the subnets in the subnet group have too small a CIDR range or the subnets are shared and heavily used by other clusters. For more information, see Creating a Subnet Group. For versions below 5.0.6, the limit is 250 per cluster.

To request a limit increase, see Amazon Service Limits and choose the limit type Nodes per cluster per instance type.

When a Redis (cluster mode disabled) replication group has been successfully created, you can add one or more read replicas to it, up to a total of 5 read replicas. If you need to increase or decrease the number of node groups (console: shards), you can avail yourself of ElastiCache for Redis' scaling. For more information, see Scaling ElastiCache for Redis Clusters in the ElastiCache User Guide.

This operation is valid for Redis only.

Struct aws_sdk_elasticache::client::fluent_builders::CreateReplicationGroup

Implementations§

impl CreateReplicationGroup

pub async fn customize( self) -> Result<CustomizableOperation<CreateReplicationGroup, AwsResponseRetryClassifier>, SdkError<CreateReplicationGroupError>>

pub async fn send( self) -> Result<CreateReplicationGroupOutput, SdkError<CreateReplicationGroupError>>

pub fn replication_group_id(self, input: impl Into<String>) -> Self

pub fn set_replication_group_id(self, input: Option<String>) -> Self

pub fn replication_group_description(self, input: impl Into<String>) -> Self

pub fn set_replication_group_description(self, input: Option<String>) -> Self

pub fn global_replication_group_id(self, input: impl Into<String>) -> Self

pub fn set_global_replication_group_id(self, input: Option<String>) -> Self

pub fn primary_cluster_id(self, input: impl Into<String>) -> Self

pub fn set_primary_cluster_id(self, input: Option<String>) -> Self

pub fn automatic_failover_enabled(self, input: bool) -> Self

pub fn set_automatic_failover_enabled(self, input: Option<bool>) -> Self

pub fn multi_az_enabled(self, input: bool) -> Self

pub fn set_multi_az_enabled(self, input: Option<bool>) -> Self

pub fn num_cache_clusters(self, input: i32) -> Self

pub fn set_num_cache_clusters(self, input: Option<i32>) -> Self

pub fn preferred_cache_cluster_a_zs(self, input: impl Into<String>) -> Self

pub fn set_preferred_cache_cluster_a_zs(self, input: Option<Vec<String>>) -> Self

pub fn num_node_groups(self, input: i32) -> Self

pub fn set_num_node_groups(self, input: Option<i32>) -> Self

pub fn replicas_per_node_group(self, input: i32) -> Self

pub fn set_replicas_per_node_group(self, input: Option<i32>) -> Self

pub fn node_group_configuration(self, input: NodeGroupConfiguration) -> Self

pub fn set_node_group_configuration( self, input: Option<Vec<NodeGroupConfiguration>>) -> Self

pub fn cache_node_type(self, input: impl Into<String>) -> Self

pub fn set_cache_node_type(self, input: Option<String>) -> Self

pub fn engine(self, input: impl Into<String>) -> Self

pub fn set_engine(self, input: Option<String>) -> Self

pub fn engine_version(self, input: impl Into<String>) -> Self

pub fn set_engine_version(self, input: Option<String>) -> Self

pub fn cache_parameter_group_name(self, input: impl Into<String>) -> Self

pub fn set_cache_parameter_group_name(self, input: Option<String>) -> Self

pub fn cache_subnet_group_name(self, input: impl Into<String>) -> Self

pub fn set_cache_subnet_group_name(self, input: Option<String>) -> Self

pub fn cache_security_group_names(self, input: impl Into<String>) -> Self

pub fn set_cache_security_group_names(self, input: Option<Vec<String>>) -> Self

pub fn security_group_ids(self, input: impl Into<String>) -> Self

pub fn set_security_group_ids(self, input: Option<Vec<String>>) -> Self

pub fn tags(self, input: Tag) -> Self

pub fn set_tags(self, input: Option<Vec<Tag>>) -> Self

pub fn snapshot_arns(self, input: impl Into<String>) -> Self

pub fn set_snapshot_arns(self, input: Option<Vec<String>>) -> Self

pub fn snapshot_name(self, input: impl Into<String>) -> Self

pub fn set_snapshot_name(self, input: Option<String>) -> Self

pub fn preferred_maintenance_window(self, input: impl Into<String>) -> Self

pub fn set_preferred_maintenance_window(self, input: Option<String>) -> Self

pub fn port(self, input: i32) -> Self

pub fn set_port(self, input: Option<i32>) -> Self

pub fn notification_topic_arn(self, input: impl Into<String>) -> Self

pub fn set_notification_topic_arn(self, input: Option<String>) -> Self

pub fn auto_minor_version_upgrade(self, input: bool) -> Self

pub fn set_auto_minor_version_upgrade(self, input: Option<bool>) -> Self

pub fn snapshot_retention_limit(self, input: i32) -> Self

pub fn set_snapshot_retention_limit(self, input: Option<i32>) -> Self

pub fn snapshot_window(self, input: impl Into<String>) -> Self

pub fn set_snapshot_window(self, input: Option<String>) -> Self

pub fn auth_token(self, input: impl Into<String>) -> Self

pub fn set_auth_token(self, input: Option<String>) -> Self

pub fn transit_encryption_enabled(self, input: bool) -> Self

pub fn set_transit_encryption_enabled(self, input: Option<bool>) -> Self

pub fn at_rest_encryption_enabled(self, input: bool) -> Self

pub fn set_at_rest_encryption_enabled(self, input: Option<bool>) -> Self

pub fn kms_key_id(self, input: impl Into<String>) -> Self

pub fn set_kms_key_id(self, input: Option<String>) -> Self

pub fn user_group_ids(self, input: impl Into<String>) -> Self

pub fn set_user_group_ids(self, input: Option<Vec<String>>) -> Self

pub fn log_delivery_configurations( self, input: LogDeliveryConfigurationRequest) -> Self

pub fn set_log_delivery_configurations( self, input: Option<Vec<LogDeliveryConfigurationRequest>>) -> Self

pub fn data_tiering_enabled(self, input: bool) -> Self

pub fn set_data_tiering_enabled(self, input: Option<bool>) -> Self

pub fn network_type(self, input: NetworkType) -> Self

pub fn set_network_type(self, input: Option<NetworkType>) -> Self

pub fn ip_discovery(self, input: IpDiscovery) -> Self

pub fn set_ip_discovery(self, input: Option<IpDiscovery>) -> Self

pub fn transit_encryption_mode(self, input: TransitEncryptionMode) -> Self

pub fn set_transit_encryption_mode( self, input: Option<TransitEncryptionMode>) -> Self

Trait Implementations§

pub async fn customize(
self
) -> Result<CustomizableOperation<CreateReplicationGroup, AwsResponseRetryClassifier>, SdkError<CreateReplicationGroupError>>

pub async fn send(
self
) -> Result<CreateReplicationGroupOutput, SdkError<CreateReplicationGroupError>>

pub fn set_node_group_configuration(
self,
input: Option<Vec<NodeGroupConfiguration>>
) -> Self

pub fn log_delivery_configurations(
self,
input: LogDeliveryConfigurationRequest
) -> Self

pub fn set_log_delivery_configurations(
self,
input: Option<Vec<LogDeliveryConfigurationRequest>>
) -> Self

pub fn set_transit_encryption_mode(
self,
input: Option<TransitEncryptionMode>
) -> Self

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T> ToOwned for Twhere
T: Clone,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,