aws_sdk_dynamodb/waiters/
contributor_insights_enabled.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2
3///
4/// Fluent builder for the `contributor_insights_enabled` waiter.
5///
6/// This builder is intended to be used similar to the other fluent builders for
7/// normal operations on the client. However, instead of a `send` method, it has
8/// a `wait` method that takes a maximum amount of time to wait.
9///
10/// Construct this fluent builder using the client by importing the
11/// [`Waiters`](crate::client::Waiters) trait and calling the methods
12/// prefixed with `wait_until`.
13///
14#[derive(::std::clone::Clone, ::std::fmt::Debug)]
15pub struct ContributorInsightsEnabledFluentBuilder {
16                handle: ::std::sync::Arc<crate::client::Handle>,
17                inner: crate::operation::describe_contributor_insights::builders::DescribeContributorInsightsInputBuilder,
18            }
19impl ContributorInsightsEnabledFluentBuilder {
20    /// Creates a new `ContributorInsightsEnabledFluentBuilder`.
21                    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    /// Access the DescribeContributorInsights as a reference.
28                    pub fn as_input(&self) -> &crate::operation::describe_contributor_insights::builders::DescribeContributorInsightsInputBuilder {
29                        &self.inner
30                    }
31    /// Wait for `contributor_insights_enabled`
32    pub async fn wait(self, max_wait: ::std::time::Duration) -> ::std::result::Result<crate::waiters::contributor_insights_enabled::ContributorInsightsEnabledFinalPoll, crate::waiters::contributor_insights_enabled::WaitUntilContributorInsightsEnabledError> {
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_contributor_insights::DescribeContributorInsights::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_contributor_insights::DescribeContributorInsightsOutput, &crate::operation::describe_contributor_insights::DescribeContributorInsightsError>| {
48                    // Matches: {"output":{"path":"ContributorInsightsStatus","expected":"ENABLED","comparator":"stringEquals"}}
49                                if crate::waiters::matchers::match_describe_contributor_insights_57787899eaa02d958(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Success; }
50    // Matches: {"output":{"path":"ContributorInsightsStatus","expected":"FAILED","comparator":"stringEquals"}}
51                                if crate::waiters::matchers::match_describe_contributor_insights_5ba948784ca4cb322(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_contributor_insights::DescribeContributorInsights::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    /// <p>The name of the table to describe. You can also provide the Amazon Resource Name (ARN) of the table in this parameter.</p>
73    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    /// <p>The name of the table to describe. You can also provide the Amazon Resource Name (ARN) of the table in this parameter.</p>
78    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    /// <p>The name of the table to describe. You can also provide the Amazon Resource Name (ARN) of the table in this parameter.</p>
83    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
84                    self.inner.get_table_name()
85                }
86    /// <p>The name of the global secondary index to describe, if applicable.</p>
87    pub fn index_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
88                    self.inner = self.inner.index_name(input.into());
89                    self
90                }
91    /// <p>The name of the global secondary index to describe, if applicable.</p>
92    pub fn set_index_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
93                    self.inner = self.inner.set_index_name(input);
94                    self
95                }
96    /// <p>The name of the global secondary index to describe, if applicable.</p>
97    pub fn get_index_name(&self) -> &::std::option::Option<::std::string::String> {
98                    self.inner.get_index_name()
99                }
100}
101
102/// Successful return type for the `contributor_insights_enabled` waiter.
103pub type ContributorInsightsEnabledFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<crate::operation::describe_contributor_insights::DescribeContributorInsightsOutput, ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::describe_contributor_insights::DescribeContributorInsightsError, ::aws_smithy_runtime_api::client::orchestrator::HttpResponse>>;
104
105/// Error type for the `contributor_insights_enabled` waiter.
106pub type WaitUntilContributorInsightsEnabledError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<crate::operation::describe_contributor_insights::DescribeContributorInsightsOutput, crate::operation::describe_contributor_insights::DescribeContributorInsightsError>;
107
aws_sdk_dynamodb/waiters/contributor_insights_enabled.rs

aws_sdk_dynamodb/waiters/
contributor_insights_enabled.rs
