aws_sdk_dynamodb/waiters/
table_exists.rs1#[derive(::std::clone::Clone, ::std::fmt::Debug)]
15pub struct TableExistsFluentBuilder {
16 handle: ::std::sync::Arc<crate::client::Handle>,
17 inner: crate::operation::describe_table::builders::DescribeTableInputBuilder,
18 }
19impl TableExistsFluentBuilder {
20 pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
22 Self {
23 handle,
24 inner: ::std::default::Default::default(),
25 }
26 }
27 pub fn as_input(&self) -> &crate::operation::describe_table::builders::DescribeTableInputBuilder {
29 &self.inner
30 }
31 pub async fn wait(self, max_wait: ::std::time::Duration) -> ::std::result::Result<crate::waiters::table_exists::TableExistsFinalPoll, crate::waiters::table_exists::WaitUntilTableExistsError> {
33 let input = self.inner.build()
34 .map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
35 let runtime_plugins = crate::operation::describe_table::DescribeTable::operation_runtime_plugins(
36 self.handle.runtime_plugins.clone(),
37 &self.handle.conf,
38 ::std::option::Option::None,
39 ).with_operation_plugin(crate::sdk_feature_tracker::waiter::WaiterFeatureTrackerRuntimePlugin::new());
40 let mut cfg = ::aws_smithy_types::config_bag::ConfigBag::base();
41 let runtime_components_builder = runtime_plugins.apply_client_configuration(&mut cfg)
42 .map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
43 let time_components = runtime_components_builder.into_time_components();
44 let sleep_impl = time_components.sleep_impl().expect("a sleep impl is required by waiters");
45 let time_source = time_components.time_source().expect("a time source is required by waiters");
46
47 let acceptor = move |result: ::std::result::Result<&crate::operation::describe_table::DescribeTableOutput, &crate::operation::describe_table::DescribeTableError>| {
48 if crate::waiters::matchers::match_describe_table_0429b99996ae6dab6(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Success; }
50 if crate::waiters::matchers::match_describe_table_1cce2c05524fb92d4(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Retry; }
52 ::aws_smithy_runtime::client::waiters::AcceptorState::NoAcceptorsMatched
53 };
54 let operation = move || {
55 let input = input.clone();
56 let runtime_plugins = runtime_plugins.clone();
57 async move {
58 crate::operation::describe_table::DescribeTable::orchestrate(&runtime_plugins, input).await
59 }
60 };
61 let orchestrator = ::aws_smithy_runtime::client::waiters::WaiterOrchestrator::builder()
62 .min_delay(::std::time::Duration::from_secs(20))
63 .max_delay(::std::time::Duration::from_secs(120))
64 .max_wait(max_wait)
65 .time_source(time_source)
66 .sleep_impl(sleep_impl)
67 .acceptor(acceptor)
68 .operation(operation)
69 .build();
70 ::aws_smithy_runtime::client::waiters::attach_waiter_tracing_span(orchestrator.orchestrate()).await
71 }
72 pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
74 self.inner = self.inner.table_name(input.into());
75 self
76 }
77 pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
79 self.inner = self.inner.set_table_name(input);
80 self
81 }
82 pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
84 self.inner.get_table_name()
85 }
86}
87
88pub type TableExistsFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<crate::operation::describe_table::DescribeTableOutput, ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::describe_table::DescribeTableError, ::aws_smithy_runtime_api::client::orchestrator::HttpResponse>>;
90
91pub type WaitUntilTableExistsError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<crate::operation::describe_table::DescribeTableOutput, crate::operation::describe_table::DescribeTableError>;
93