1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub use crate::operation::describe_table_statistics::_describe_table_statistics_output::DescribeTableStatisticsOutputBuilder;
pub use crate::operation::describe_table_statistics::_describe_table_statistics_input::DescribeTableStatisticsInputBuilder;
/// Fluent builder constructing a request to `DescribeTableStatistics`.
///
/// <p>Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.</p>
/// <p>Note that the "last updated" column the DMS console only indicates the time that DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.</p>
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct DescribeTableStatisticsFluentBuilder {
handle: std::sync::Arc<crate::client::Handle>,
inner:
crate::operation::describe_table_statistics::builders::DescribeTableStatisticsInputBuilder,
}
impl DescribeTableStatisticsFluentBuilder {
/// Creates a new `DescribeTableStatistics`.
pub(crate) fn new(handle: std::sync::Arc<crate::client::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::client::customize::CustomizableOperation<
crate::operation::describe_table_statistics::DescribeTableStatistics,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<
crate::operation::describe_table_statistics::DescribeTableStatisticsError,
>,
> {
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::client::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::operation::describe_table_statistics::DescribeTableStatisticsOutput,
aws_smithy_http::result::SdkError<
crate::operation::describe_table_statistics::DescribeTableStatisticsError,
>,
> {
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::operation::describe_table_statistics::paginator::DescribeTableStatisticsPaginator::send) which returns a `Stream`.
pub fn into_paginator(
self,
) -> crate::operation::describe_table_statistics::paginator::DescribeTableStatisticsPaginator
{
crate::operation::describe_table_statistics::paginator::DescribeTableStatisticsPaginator::new(self.handle, self.inner)
}
/// <p>The Amazon Resource Name (ARN) of the replication task.</p>
pub fn replication_task_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.replication_task_arn(input.into());
self
}
/// <p>The Amazon Resource Name (ARN) of the replication task.</p>
pub fn set_replication_task_arn(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_replication_task_arn(input);
self
}
/// <p> The maximum number of records to include in the response. If more records exist than the specified <code>MaxRecords</code> value, a pagination token called a marker is included in the response so that the remaining results can be retrieved. </p>
/// <p>Default: 100</p>
/// <p>Constraints: Minimum 20, maximum 500.</p>
pub fn max_records(mut self, input: i32) -> Self {
self.inner = self.inner.max_records(input);
self
}
/// <p> The maximum number of records to include in the response. If more records exist than the specified <code>MaxRecords</code> value, a pagination token called a marker is included in the response so that the remaining results can be retrieved. </p>
/// <p>Default: 100</p>
/// <p>Constraints: Minimum 20, maximum 500.</p>
pub fn set_max_records(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_max_records(input);
self
}
/// <p> An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by <code>MaxRecords</code>. </p>
pub fn marker(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.marker(input.into());
self
}
/// <p> An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by <code>MaxRecords</code>. </p>
pub fn set_marker(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_marker(input);
self
}
/// Appends an item to `Filters`.
///
/// To override the contents of this collection use [`set_filters`](Self::set_filters).
///
/// <p>Filters applied to table statistics.</p>
/// <p>Valid filter names: schema-name | table-name | table-state</p>
/// <p>A combination of filters creates an AND condition where each record matches all specified filters.</p>
pub fn filters(mut self, input: crate::types::Filter) -> Self {
self.inner = self.inner.filters(input);
self
}
/// <p>Filters applied to table statistics.</p>
/// <p>Valid filter names: schema-name | table-name | table-state</p>
/// <p>A combination of filters creates an AND condition where each record matches all specified filters.</p>
pub fn set_filters(
mut self,
input: std::option::Option<std::vec::Vec<crate::types::Filter>>,
) -> Self {
self.inner = self.inner.set_filters(input);
self
}
}