Struct aws_sdk_memorydb::Client

source ·

pub struct Client { /* private fields */ }

Expand description

Client for Amazon MemoryDB

Client for invoking operations on Amazon MemoryDB. Each operation on Amazon MemoryDB 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

    // 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_memorydb::Client::new(&shared_config);
    // invoke an operation
    /* let rsp = client
        .<operation_name>().
        .<param>("some value")
        .send().await; */

Constructing a client with custom configuration

use aws_config::retry::RetryConfig;
let shared_config = aws_config::load_from_env().await;
let config = aws_sdk_memorydb::config::Builder::from(&shared_config)
  .retry_config(RetryConfig::disabled())
  .build();
let client = aws_sdk_memorydb::Client::from_conf(config);

Implementations§

source §

impl Client

source

pub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self

Creates a client with the given service configuration.

source

pub fn conf(&self) -> &Config

Returns the client’s configuration.

source §

impl Client

source

pub fn batch_update_cluster(&self) -> BatchUpdateCluster

Constructs a fluent builder for the BatchUpdateCluster operation.

The fluent builder is configurable:
- cluster_names(Vec<String>) / set_cluster_names(Option<Vec<String>>):
 The cluster names to apply the updates.
- service_update(ServiceUpdateRequest) / set_service_update(Option<ServiceUpdateRequest>):
 The unique ID of the service update
On success, responds with BatchUpdateClusterOutput with field(s):
- processed_clusters(Option<Vec<Cluster>>):
 The list of clusters that have been updated.
- unprocessed_clusters(Option<Vec<UnprocessedCluster>>):
 The list of clusters where updates have not been applied.
On failure, responds with SdkError<BatchUpdateClusterError>

source

pub fn copy_snapshot(&self) -> CopySnapshot

Constructs a fluent builder for the CopySnapshot operation.

The fluent builder is configurable:
- source_snapshot_name(impl Into<String>) / set_source_snapshot_name(Option<String>):
 The name of an existing snapshot from which to make a copy.
- target_snapshot_name(impl Into<String>) / set_target_snapshot_name(Option<String>):
 A name for the snapshot copy. MemoryDB does not permit overwriting a snapshot, therefore this name must be unique within its context - MemoryDB or an Amazon S3 bucket if exporting.
- target_bucket(impl Into<String>) / set_target_bucket(Option<String>):
 The Amazon S3 bucket to which the snapshot is exported. This parameter is used only when exporting a snapshot for external access. When using this parameter to export a snapshot, be sure MemoryDB has the needed permissions to this S3 bucket. For more information, see Step 2: Grant MemoryDB Access to Your Amazon S3 Bucket.
- kms_key_id(impl Into<String>) / set_kms_key_id(Option<String>):
 The ID of the KMS key used to encrypt the target snapshot.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CopySnapshotOutput with field(s):
- snapshot(Option<Snapshot>):
 Represents a copy of an entire cluster as of the time when the snapshot was taken.
On failure, responds with SdkError<CopySnapshotError>

source

pub fn create_acl(&self) -> CreateACL

Constructs a fluent builder for the CreateACL operation.

The fluent builder is configurable:
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The name of the Access Control List.
- user_names(Vec<String>) / set_user_names(Option<Vec<String>>):
 The list of users that belong to the Access Control List.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CreateAclOutput with field(s):
- acl(Option<Acl>):
 The newly-created Access Control List.
On failure, responds with SdkError<CreateACLError>

source

pub fn create_cluster(&self) -> CreateCluster

Constructs a fluent builder for the CreateCluster operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The name of the cluster. This value must be unique as it also serves as the cluster identifier.
- node_type(impl Into<String>) / set_node_type(Option<String>):
 The compute and memory capacity of the nodes in the cluster.
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group associated with the cluster.
- description(impl Into<String>) / set_description(Option<String>):
 An optional description of the cluster.
- num_shards(i32) / set_num_shards(Option<i32>):
 The number of shards the cluster will contain. The default value is 1.
- num_replicas_per_shard(i32) / set_num_replicas_per_shard(Option<i32>):
 The number of replicas to apply to each shard. The default value is 1. The maximum is 5.
- subnet_group_name(impl Into<String>) / set_subnet_group_name(Option<String>):
 The name of the subnet group to be used for the cluster.
- security_group_ids(Vec<String>) / set_security_group_ids(Option<Vec<String>>):
 A list of security group names to associate with this cluster.
- maintenance_window(impl Into<String>) / set_maintenance_window(Option<String>):
 Specifies the weekly time range during which maintenance on the cluster is performed. It is specified as a range in the format ddd:hh24:mi-ddd:hh24:mi (24H Clock UTC). The minimum maintenance window is a 60 minute period.
 
 Valid values for ddd are:
 - sun
 - mon
 - tue
 - wed
 - thu
 - fri
 - sat
 Example: sun:23:00-mon:01:30
- port(i32) / set_port(Option<i32>):
 The port number on which each of the nodes accepts connections.
- sns_topic_arn(impl Into<String>) / set_sns_topic_arn(Option<String>):
 The Amazon Resource Name (ARN) of the Amazon Simple Notification Service (SNS) topic to which notifications are sent.
- tls_enabled(bool) / set_tls_enabled(Option<bool>):
 A flag to enable in-transit encryption on the cluster.
- kms_key_id(impl Into<String>) / set_kms_key_id(Option<String>):
 The ID of the KMS key used to encrypt the cluster.
- snapshot_arns(Vec<String>) / set_snapshot_arns(Option<Vec<String>>):
 A list of Amazon Resource Names (ARN) that uniquely identify the RDB snapshot files stored in Amazon S3. The snapshot files are used to populate the new cluster. The Amazon S3 object name in the ARN cannot contain any commas.
- snapshot_name(impl Into<String>) / set_snapshot_name(Option<String>):
 The name of a snapshot from which to restore data into the new cluster. The snapshot status changes to restoring while the new cluster is being created.
- snapshot_retention_limit(i32) / set_snapshot_retention_limit(Option<i32>):
 The number of days for which MemoryDB retains automatic snapshots before deleting them. For example, if you set SnapshotRetentionLimit to 5, a snapshot that was taken today is retained for 5 days before being deleted.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. Tags are comma-separated key,value pairs (e.g. Key=myKey, Value=myKeyValue. You can include multiple tags as shown following: Key=myKey, Value=myKeyValue Key=mySecondKey, Value=mySecondKeyValue.
- snapshot_window(impl Into<String>) / set_snapshot_window(Option<String>):
 The daily time range (in UTC) during which MemoryDB begins taking a daily snapshot of your shard.
 
 Example: 05:00-09:00
 
 If you do not specify this parameter, MemoryDB automatically chooses an appropriate time range.
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The name of the Access Control List to associate with the cluster.
- engine_version(impl Into<String>) / set_engine_version(Option<String>):
 The version number of the Redis engine to be used for the cluster.
- auto_minor_version_upgrade(bool) / set_auto_minor_version_upgrade(Option<bool>):
 When set to true, the cluster will automatically receive minor engine version upgrades after launch.
- data_tiering(bool) / set_data_tiering(Option<bool>):
 Enables data tiering. Data tiering is only supported for clusters using the r6gd node type. This parameter must be set when using r6gd nodes. For more information, see Data tiering.
On success, responds with CreateClusterOutput with field(s):
- cluster(Option<Cluster>):
 The newly-created cluster.
On failure, responds with SdkError<CreateClusterError>

source

pub fn create_parameter_group(&self) -> CreateParameterGroup

Constructs a fluent builder for the CreateParameterGroup operation.

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group.
- family(impl Into<String>) / set_family(Option<String>):
 The name of the parameter group family that the parameter group can be used with.
- description(impl Into<String>) / set_description(Option<String>):
 An optional description of the parameter group.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CreateParameterGroupOutput with field(s):
- parameter_group(Option<ParameterGroup>):
 The newly-created parameter group.
On failure, responds with SdkError<CreateParameterGroupError>

source

pub fn create_snapshot(&self) -> CreateSnapshot

Constructs a fluent builder for the CreateSnapshot operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The snapshot is created from this cluster.
- snapshot_name(impl Into<String>) / set_snapshot_name(Option<String>):
 A name for the snapshot being created.
- kms_key_id(impl Into<String>) / set_kms_key_id(Option<String>):
 The ID of the KMS key used to encrypt the snapshot.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CreateSnapshotOutput with field(s):
- snapshot(Option<Snapshot>):
 The newly-created snapshot.
On failure, responds with SdkError<CreateSnapshotError>

source

pub fn create_subnet_group(&self) -> CreateSubnetGroup

Constructs a fluent builder for the CreateSubnetGroup operation.

The fluent builder is configurable:
- subnet_group_name(impl Into<String>) / set_subnet_group_name(Option<String>):
 The name of the subnet group.
- description(impl Into<String>) / set_description(Option<String>):
 A description for the subnet group.
- subnet_ids(Vec<String>) / set_subnet_ids(Option<Vec<String>>):
 A list of VPC subnet IDs for the subnet group.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CreateSubnetGroupOutput with field(s):
- subnet_group(Option<SubnetGroup>):
 The newly-created subnet group
On failure, responds with SdkError<CreateSubnetGroupError>

source

pub fn create_user(&self) -> CreateUser

Constructs a fluent builder for the CreateUser operation.

The fluent builder is configurable:
- user_name(impl Into<String>) / set_user_name(Option<String>):
 The name of the user. This value must be unique as it also serves as the user identifier.
- authentication_mode(AuthenticationMode) / set_authentication_mode(Option<AuthenticationMode>):
 Denotes the user’s authentication properties, such as whether it requires a password to authenticate.
- access_string(impl Into<String>) / set_access_string(Option<String>):
 Access permissions string used for this user.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with CreateUserOutput with field(s):
- user(Option<User>):
 The newly-created user.
On failure, responds with SdkError<CreateUserError>

source

pub fn delete_acl(&self) -> DeleteACL

Constructs a fluent builder for the DeleteACL operation.

The fluent builder is configurable:
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The name of the Access Control List to delete
On success, responds with DeleteAclOutput with field(s):
- acl(Option<Acl>):
 The Access Control List object that has been deleted.
On failure, responds with SdkError<DeleteACLError>

source

pub fn delete_cluster(&self) -> DeleteCluster

Constructs a fluent builder for the DeleteCluster operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The name of the cluster to be deleted
- final_snapshot_name(impl Into<String>) / set_final_snapshot_name(Option<String>):
 The user-supplied name of a final cluster snapshot. This is the unique name that identifies the snapshot. MemoryDB creates the snapshot, and then deletes the cluster immediately afterward.
On success, responds with DeleteClusterOutput with field(s):
- cluster(Option<Cluster>):
 The cluster object that has been deleted
On failure, responds with SdkError<DeleteClusterError>

source

pub fn delete_parameter_group(&self) -> DeleteParameterGroup

Constructs a fluent builder for the DeleteParameterGroup operation.

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group to delete.
On success, responds with DeleteParameterGroupOutput with field(s):
- parameter_group(Option<ParameterGroup>):
 The parameter group that has been deleted.
On failure, responds with SdkError<DeleteParameterGroupError>

source

pub fn delete_snapshot(&self) -> DeleteSnapshot

Constructs a fluent builder for the DeleteSnapshot operation.

The fluent builder is configurable:
- snapshot_name(impl Into<String>) / set_snapshot_name(Option<String>):
 The name of the snapshot to delete
On success, responds with DeleteSnapshotOutput with field(s):
- snapshot(Option<Snapshot>):
 The snapshot object that has been deleted.
On failure, responds with SdkError<DeleteSnapshotError>

source

pub fn delete_subnet_group(&self) -> DeleteSubnetGroup

Constructs a fluent builder for the DeleteSubnetGroup operation.

The fluent builder is configurable:
- subnet_group_name(impl Into<String>) / set_subnet_group_name(Option<String>):
 The name of the subnet group to delete
On success, responds with DeleteSubnetGroupOutput with field(s):
- subnet_group(Option<SubnetGroup>):
 The subnet group object that has been deleted.
On failure, responds with SdkError<DeleteSubnetGroupError>

source

pub fn delete_user(&self) -> DeleteUser

Constructs a fluent builder for the DeleteUser operation.

The fluent builder is configurable:
- user_name(impl Into<String>) / set_user_name(Option<String>):
 The name of the user to delete
On success, responds with DeleteUserOutput with field(s):
- user(Option<User>):
 The user object that has been deleted.
On failure, responds with SdkError<DeleteUserError>

source

pub fn describe_ac_ls(&self) -> DescribeACLs

Constructs a fluent builder for the DescribeACLs operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The name of the ACL
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeAcLsOutput with field(s):
- ac_ls(Option<Vec<Acl>>):
 The list of ACLs
- next_token(Option<String>):
 If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On failure, responds with SdkError<DescribeACLsError>

source

pub fn describe_clusters(&self) -> DescribeClusters

Constructs a fluent builder for the DescribeClusters operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The name of the cluster
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- show_shard_details(bool) / set_show_shard_details(Option<bool>):
 An optional flag that can be included in the request to retrieve information about the individual shard(s).
On success, responds with DescribeClustersOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- clusters(Option<Vec<Cluster>>):
 A list of clusters
On failure, responds with SdkError<DescribeClustersError>

source

pub fn describe_engine_versions(&self) -> DescribeEngineVersions

Constructs a fluent builder for the DescribeEngineVersions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- engine_version(impl Into<String>) / set_engine_version(Option<String>):
 The Redis engine version
- parameter_group_family(impl Into<String>) / set_parameter_group_family(Option<String>):
 The name of a specific parameter group family to return details for.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- default_only(bool) / set_default_only(bool):
 If true, specifies that only the default version of the specified engine or engine and major version combination is to be returned.
On success, responds with DescribeEngineVersionsOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- engine_versions(Option<Vec<EngineVersionInfo>>):
 A list of engine version details. Each element in the list contains detailed information about one engine version.
On failure, responds with SdkError<DescribeEngineVersionsError>

source

pub fn describe_events(&self) -> DescribeEvents

Constructs a fluent builder for the DescribeEvents operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- source_name(impl Into<String>) / set_source_name(Option<String>):
 The identifier of the event source for which events are returned. If not specified, all sources are included in the response.
- source_type(SourceType) / set_source_type(Option<SourceType>):
 The event source to retrieve events for. If no value is specified, all events are returned.
- start_time(DateTime) / set_start_time(Option<DateTime>):
 The beginning of the time interval to retrieve events for, specified in ISO 8601 format. Example: 2017-03-30T07:03:49.555Z
- end_time(DateTime) / set_end_time(Option<DateTime>):
 The end of the time interval for which to retrieve events, specified in ISO 8601 format. Example: 2017-03-30T07:03:49.555Z
- duration(i32) / set_duration(Option<i32>):
 The number of minutes worth of events to retrieve.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeEventsOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- events(Option<Vec<Event>>):
 A list of events. Each element in the list contains detailed information about one event.
On failure, responds with SdkError<DescribeEventsError>

source

pub fn describe_parameter_groups(&self) -> DescribeParameterGroups

Constructs a fluent builder for the DescribeParameterGroups operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of a specific parameter group to return details for.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeParameterGroupsOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- parameter_groups(Option<Vec<ParameterGroup>>):
 A list of parameter groups. Each element in the list contains detailed information about one parameter group.
On failure, responds with SdkError<DescribeParameterGroupsError>

source

pub fn describe_parameters(&self) -> DescribeParameters

Constructs a fluent builder for the DescribeParameters operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 he name of a specific parameter group to return details for.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeParametersOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- parameters(Option<Vec<Parameter>>):
 A list of parameters specific to a particular parameter group. Each element in the list contains detailed information about one parameter.
On failure, responds with SdkError<DescribeParametersError>

source

pub fn describe_reserved_nodes(&self) -> DescribeReservedNodes

Constructs a fluent builder for the DescribeReservedNodes operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- reservation_id(impl Into<String>) / set_reservation_id(Option<String>):
 The reserved node identifier filter value. Use this parameter to show only the reservation that matches the specified reservation ID.
- reserved_nodes_offering_id(impl Into<String>) / set_reserved_nodes_offering_id(Option<String>):
 The offering identifier filter value. Use this parameter to show only purchased reservations matching the specified offering identifier.
- node_type(impl Into<String>) / set_node_type(Option<String>):
 The node type filter value. Use this parameter to show only those reservations matching the specified node type. For more information, see Supported node types.
- duration(impl Into<String>) / set_duration(Option<String>):
 The duration filter value, specified in years or seconds. Use this parameter to show only reservations for this duration.
- offering_type(impl Into<String>) / set_offering_type(Option<String>):
 The offering type filter value. Use this parameter to show only the available offerings matching the specified offering type. Valid values: “All Upfront”|“Partial Upfront”| “No Upfront”
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a marker is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional marker returned from a prior request. Use this marker for pagination of results from this operation. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
On success, responds with DescribeReservedNodesOutput with field(s):
- next_token(Option<String>):
 An optional marker returned from a prior request. Use this marker for pagination of results from this operation. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
- reserved_nodes(Option<Vec<ReservedNode>>):
 Returns information about reserved nodes for this account, or about a specified reserved node.
On failure, responds with SdkError<DescribeReservedNodesError>

source

pub fn describe_reserved_nodes_offerings(
&self
) -> DescribeReservedNodesOfferings

Constructs a fluent builder for the DescribeReservedNodesOfferings operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- reserved_nodes_offering_id(impl Into<String>) / set_reserved_nodes_offering_id(Option<String>):
 The offering identifier filter value. Use this parameter to show only the available offering that matches the specified reservation identifier.
- node_type(impl Into<String>) / set_node_type(Option<String>):
 The node type for the reserved nodes. For more information, see Supported node types.
- duration(impl Into<String>) / set_duration(Option<String>):
 Duration filter value, specified in years or seconds. Use this parameter to show only reservations for a given duration.
- offering_type(impl Into<String>) / set_offering_type(Option<String>):
 The offering type filter value. Use this parameter to show only the available offerings matching the specified offering type. Valid values: “All Upfront”|“Partial Upfront”| “No Upfront”
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a marker is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional marker returned from a prior request. Use this marker for pagination of results from this operation. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
On success, responds with DescribeReservedNodesOfferingsOutput with field(s):
- next_token(Option<String>):
 An optional marker returned from a prior request. Use this marker for pagination of results from this operation. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
- reserved_nodes_offerings(Option<Vec<ReservedNodesOffering>>):
 Lists available reserved node offerings.
On failure, responds with SdkError<DescribeReservedNodesOfferingsError>

source

pub fn describe_service_updates(&self) -> DescribeServiceUpdates

Constructs a fluent builder for the DescribeServiceUpdates operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- service_update_name(impl Into<String>) / set_service_update_name(Option<String>):
 The unique ID of the service update to describe.
- cluster_names(Vec<String>) / set_cluster_names(Option<Vec<String>>):
 The list of cluster names to identify service updates to apply
- status(Vec<ServiceUpdateStatus>) / set_status(Option<Vec<ServiceUpdateStatus>>):
 The status(es) of the service updates to filter on
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeServiceUpdatesOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- service_updates(Option<Vec<ServiceUpdate>>):
 A list of service updates
On failure, responds with SdkError<DescribeServiceUpdatesError>

source

pub fn describe_snapshots(&self) -> DescribeSnapshots

Constructs a fluent builder for the DescribeSnapshots operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 A user-supplied cluster identifier. If this parameter is specified, only snapshots associated with that specific cluster are described.
- snapshot_name(impl Into<String>) / set_snapshot_name(Option<String>):
 A user-supplied name of the snapshot. If this parameter is specified, only this named snapshot is described.
- source(impl Into<String>) / set_source(Option<String>):
 If set to system, the output shows snapshots that were automatically created by MemoryDB. If set to user the output shows snapshots that were manually created. If omitted, the output shows both automatically and manually created snapshots.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- show_detail(bool) / set_show_detail(Option<bool>):
 A Boolean value which if true, the shard configuration is included in the snapshot description.
On success, responds with DescribeSnapshotsOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- snapshots(Option<Vec<Snapshot>>):
 A list of snapshots. Each item in the list contains detailed information about one snapshot.
On failure, responds with SdkError<DescribeSnapshotsError>

source

pub fn describe_subnet_groups(&self) -> DescribeSubnetGroups

Constructs a fluent builder for the DescribeSubnetGroups operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- subnet_group_name(impl Into<String>) / set_subnet_group_name(Option<String>):
 The name of the subnet group to return details for.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeSubnetGroupsOutput with field(s):
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
- subnet_groups(Option<Vec<SubnetGroup>>):
 A list of subnet groups. Each element in the list contains detailed information about one group.
On failure, responds with SdkError<DescribeSubnetGroupsError>

source

pub fn describe_users(&self) -> DescribeUsers

Constructs a fluent builder for the DescribeUsers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- user_name(impl Into<String>) / set_user_name(Option<String>):
 The name of the user
- filters(Vec<Filter>) / set_filters(Option<Vec<Filter>>):
 Filter to determine the list of users to return.
- max_results(i32) / set_max_results(Option<i32>):
 The maximum number of records to include in the response. If more records exist than the specified MaxResults value, a token is included in the response so that the remaining results can be retrieved.
- next_token(impl Into<String>) / set_next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On success, responds with DescribeUsersOutput with field(s):
- users(Option<Vec<User>>):
 A list of users.
- next_token(Option<String>):
 An optional argument to pass in case the total number of records exceeds the value of MaxResults. If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged.
On failure, responds with SdkError<DescribeUsersError>

source

pub fn failover_shard(&self) -> FailoverShard

Constructs a fluent builder for the FailoverShard operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The cluster being failed over
- shard_name(impl Into<String>) / set_shard_name(Option<String>):
 The name of the shard
On success, responds with FailoverShardOutput with field(s):
- cluster(Option<Cluster>):
 The cluster being failed over
On failure, responds with SdkError<FailoverShardError>

source

pub fn list_allowed_node_type_updates(&self) -> ListAllowedNodeTypeUpdates

Constructs a fluent builder for the ListAllowedNodeTypeUpdates operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The name of the cluster you want to scale. MemoryDB uses the cluster name to identify the current node type being used by this cluster, and from that to create a list of node types you can scale up to.
On success, responds with ListAllowedNodeTypeUpdatesOutput with field(s):
- scale_up_node_types(Option<Vec<String>>):
 A list node types which you can use to scale up your cluster.
- scale_down_node_types(Option<Vec<String>>):
 A list node types which you can use to scale down your cluster.
On failure, responds with SdkError<ListAllowedNodeTypeUpdatesError>

Constructs a fluent builder for the ListTags operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The Amazon Resource Name (ARN) of the resource for which you want the list of tags
On success, responds with ListTagsOutput with field(s):
- tag_list(Option<Vec<Tag>>):
 A list of tags as key-value pairs.
On failure, responds with SdkError<ListTagsError>

source

pub fn purchase_reserved_nodes_offering(&self) -> PurchaseReservedNodesOffering

Constructs a fluent builder for the PurchaseReservedNodesOffering operation.

The fluent builder is configurable:
- reserved_nodes_offering_id(impl Into<String>) / set_reserved_nodes_offering_id(Option<String>):
 The ID of the reserved node offering to purchase.
- reservation_id(impl Into<String>) / set_reservation_id(Option<String>):
 A customer-specified identifier to track this reservation.
- node_count(i32) / set_node_count(Option<i32>):
 The number of node instances to reserve.
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with PurchaseReservedNodesOfferingOutput with field(s):
- reserved_node(Option<ReservedNode>):
 Represents the output of a PurchaseReservedNodesOffering operation.
On failure, responds with SdkError<PurchaseReservedNodesOfferingError>

source

pub fn reset_parameter_group(&self) -> ResetParameterGroup

Constructs a fluent builder for the ResetParameterGroup operation.

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group to reset.
- all_parameters(bool) / set_all_parameters(bool):
 If true, all parameters in the parameter group are reset to their default values. If false, only the parameters listed by ParameterNames are reset to their default values.
- parameter_names(Vec<String>) / set_parameter_names(Option<Vec<String>>):
 An array of parameter names to reset to their default values. If AllParameters is true, do not use ParameterNames. If AllParameters is false, you must specify the name of at least one parameter to reset.
On success, responds with ResetParameterGroupOutput with field(s):
- parameter_group(Option<ParameterGroup>):
 The parameter group being reset.
On failure, responds with SdkError<ResetParameterGroupError>

source

pub fn tag_resource(&self) -> TagResource

Constructs a fluent builder for the TagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The Amazon Resource Name (ARN) of the resource to which the tags are to be added
- tags(Vec<Tag>) / set_tags(Option<Vec<Tag>>):
 A list of tags to be added to this resource. A tag is a key-value pair. A tag key must be accompanied by a tag value, although null is accepted.
On success, responds with TagResourceOutput with field(s):
- tag_list(Option<Vec<Tag>>):
 A list of tags as key-value pairs.
On failure, responds with SdkError<TagResourceError>

source

pub fn untag_resource(&self) -> UntagResource

Constructs a fluent builder for the UntagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
 The Amazon Resource Name (ARN) of the resource to which the tags are to be removed
- tag_keys(Vec<String>) / set_tag_keys(Option<Vec<String>>):
 The list of keys of the tags that are to be removed
On success, responds with UntagResourceOutput with field(s):
- tag_list(Option<Vec<Tag>>):
 The list of tags removed
On failure, responds with SdkError<UntagResourceError>

source

pub fn update_acl(&self) -> UpdateACL

Constructs a fluent builder for the UpdateACL operation.

The fluent builder is configurable:
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The name of the Access Control List
- user_names_to_add(Vec<String>) / set_user_names_to_add(Option<Vec<String>>):
 The list of users to add to the Access Control List
- user_names_to_remove(Vec<String>) / set_user_names_to_remove(Option<Vec<String>>):
 The list of users to remove from the Access Control List
On success, responds with UpdateAclOutput with field(s):
- acl(Option<Acl>):
 The updated Access Control List
On failure, responds with SdkError<UpdateACLError>

source

pub fn update_cluster(&self) -> UpdateCluster

Constructs a fluent builder for the UpdateCluster operation.

The fluent builder is configurable:
- cluster_name(impl Into<String>) / set_cluster_name(Option<String>):
 The name of the cluster to update
- description(impl Into<String>) / set_description(Option<String>):
 The description of the cluster to update
- security_group_ids(Vec<String>) / set_security_group_ids(Option<Vec<String>>):
 The SecurityGroupIds to update
- maintenance_window(impl Into<String>) / set_maintenance_window(Option<String>):
 Specifies the weekly time range during which maintenance on the cluster is performed. It is specified as a range in the format ddd:hh24:mi-ddd:hh24:mi (24H Clock UTC). The minimum maintenance window is a 60 minute period.
 
 Valid values for ddd are:
 - sun
 - mon
 - tue
 - wed
 - thu
 - fri
 - sat
 Example: sun:23:00-mon:01:30
- sns_topic_arn(impl Into<String>) / set_sns_topic_arn(Option<String>):
 The SNS topic ARN to update
- sns_topic_status(impl Into<String>) / set_sns_topic_status(Option<String>):
 The status of the Amazon SNS notification topic. Notifications are sent only if the status is active.
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group to update
- snapshot_window(impl Into<String>) / set_snapshot_window(Option<String>):
 The daily time range (in UTC) during which MemoryDB begins taking a daily snapshot of your cluster.
- snapshot_retention_limit(i32) / set_snapshot_retention_limit(Option<i32>):
 The number of days for which MemoryDB retains automatic cluster snapshots before deleting them. For example, if you set SnapshotRetentionLimit to 5, a snapshot that was taken today is retained for 5 days before being deleted.
- node_type(impl Into<String>) / set_node_type(Option<String>):
 A valid node type that you want to scale this cluster up or down to.
- engine_version(impl Into<String>) / set_engine_version(Option<String>):
 The upgraded version of the engine to be run on the nodes. You can upgrade to a newer engine version, but you cannot downgrade to an earlier engine version. If you want to use an earlier engine version, you must delete the existing cluster and create it anew with the earlier engine version.
- replica_configuration(ReplicaConfigurationRequest) / set_replica_configuration(Option<ReplicaConfigurationRequest>):
 The number of replicas that will reside in each shard
- shard_configuration(ShardConfigurationRequest) / set_shard_configuration(Option<ShardConfigurationRequest>):
 The number of shards in the cluster
- acl_name(impl Into<String>) / set_acl_name(Option<String>):
 The Access Control List that is associated with the cluster
On success, responds with UpdateClusterOutput with field(s):
- cluster(Option<Cluster>):
 The updated cluster
On failure, responds with SdkError<UpdateClusterError>

source

pub fn update_parameter_group(&self) -> UpdateParameterGroup

Constructs a fluent builder for the UpdateParameterGroup operation.

The fluent builder is configurable:
- parameter_group_name(impl Into<String>) / set_parameter_group_name(Option<String>):
 The name of the parameter group to update.
- parameter_name_values(Vec<ParameterNameValue>) / set_parameter_name_values(Option<Vec<ParameterNameValue>>):
 An array of parameter names and values for the parameter update. You must supply at least one parameter name and value; subsequent arguments are optional. A maximum of 20 parameters may be updated per request.
On success, responds with UpdateParameterGroupOutput with field(s):
- parameter_group(Option<ParameterGroup>):
 The updated parameter group
On failure, responds with SdkError<UpdateParameterGroupError>

source

pub fn update_subnet_group(&self) -> UpdateSubnetGroup

Constructs a fluent builder for the UpdateSubnetGroup operation.

The fluent builder is configurable:
- subnet_group_name(impl Into<String>) / set_subnet_group_name(Option<String>):
 The name of the subnet group
- description(impl Into<String>) / set_description(Option<String>):
 A description of the subnet group
- subnet_ids(Vec<String>) / set_subnet_ids(Option<Vec<String>>):
 The EC2 subnet IDs for the subnet group.
On success, responds with UpdateSubnetGroupOutput with field(s):
- subnet_group(Option<SubnetGroup>):
 The updated subnet group
On failure, responds with SdkError<UpdateSubnetGroupError>

source

pub fn update_user(&self) -> UpdateUser

Constructs a fluent builder for the UpdateUser operation.

The fluent builder is configurable:
- user_name(impl Into<String>) / set_user_name(Option<String>):
 The name of the user
- authentication_mode(AuthenticationMode) / set_authentication_mode(Option<AuthenticationMode>):
 Denotes the user’s authentication properties, such as whether it requires a password to authenticate.
- access_string(impl Into<String>) / set_access_string(Option<String>):
 Access permissions string used for this user.
On success, responds with UpdateUserOutput with field(s):
- user(Option<User>):
 The updated user
On failure, responds with SdkError<UpdateUserError>

source §

impl Client

source

pub fn new(sdk_config: &SdkConfig) -> Self

Creates a new client from an SDK Config.

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.

source

pub fn from_conf(conf: Config) -> Self

Creates a new client from the service 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.