aws_sdk_dynamodb/waiters/
export_completed.rs1#[derive(::std::clone::Clone, ::std::fmt::Debug)]
15pub struct ExportCompletedFluentBuilder {
16 handle: ::std::sync::Arc<crate::client::Handle>,
17 inner: crate::operation::describe_export::builders::DescribeExportInputBuilder,
18 }
19impl ExportCompletedFluentBuilder {
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_export::builders::DescribeExportInputBuilder {
29 &self.inner
30 }
31 pub async fn wait(self, max_wait: ::std::time::Duration) -> ::std::result::Result<crate::waiters::export_completed::ExportCompletedFinalPoll, crate::waiters::export_completed::WaitUntilExportCompletedError> {
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_export::DescribeExport::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_export::DescribeExportOutput, &crate::operation::describe_export::DescribeExportError>| {
48 if crate::waiters::matchers::match_describe_export_a4219f96bc64309c4(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Success; }
50 if crate::waiters::matchers::match_describe_export_8d899fd0681b891e9(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure; }
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_export::DescribeExport::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 export_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
74 self.inner = self.inner.export_arn(input.into());
75 self
76 }
77 pub fn set_export_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
79 self.inner = self.inner.set_export_arn(input);
80 self
81 }
82 pub fn get_export_arn(&self) -> &::std::option::Option<::std::string::String> {
84 self.inner.get_export_arn()
85 }
86}
87
88pub type ExportCompletedFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<crate::operation::describe_export::DescribeExportOutput, ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::describe_export::DescribeExportError, ::aws_smithy_runtime_api::client::orchestrator::HttpResponse>>;
90
91pub type WaitUntilExportCompletedError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<crate::operation::describe_export::DescribeExportOutput, crate::operation::describe_export::DescribeExportError>;
93