aws_sdk_dynamodb/waiters/
kinesis_streaming_destination_active.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2
3///
4/// Fluent builder for the `kinesis_streaming_destination_active` 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 KinesisStreamingDestinationActiveFluentBuilder {
16                handle: ::std::sync::Arc<crate::client::Handle>,
17                inner: crate::operation::describe_kinesis_streaming_destination::builders::DescribeKinesisStreamingDestinationInputBuilder,
18            }
19impl KinesisStreamingDestinationActiveFluentBuilder {
20    /// Creates a new `KinesisStreamingDestinationActiveFluentBuilder`.
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 DescribeKinesisStreamingDestination as a reference.
28                    pub fn as_input(&self) -> &crate::operation::describe_kinesis_streaming_destination::builders::DescribeKinesisStreamingDestinationInputBuilder {
29                        &self.inner
30                    }
31    /// Wait for `kinesis_streaming_destination_active`
32    pub async fn wait(self, max_wait: ::std::time::Duration) -> ::std::result::Result<crate::waiters::kinesis_streaming_destination_active::KinesisStreamingDestinationActiveFinalPoll, crate::waiters::kinesis_streaming_destination_active::WaitUntilKinesisStreamingDestinationActiveError> {
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_kinesis_streaming_destination::DescribeKinesisStreamingDestination::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_kinesis_streaming_destination::DescribeKinesisStreamingDestinationOutput, &crate::operation::describe_kinesis_streaming_destination::DescribeKinesisStreamingDestinationError>| {
48                    // Matches: {"output":{"path":"KinesisDataStreamDestinations[].DestinationStatus","expected":"ACTIVE","comparator":"anyStringEquals"}}
49                                if crate::waiters::matchers::match_describe_kinesis_streaming_destination_56e18114fb2c2cf5a(result) { return ::aws_smithy_runtime::client::waiters::AcceptorState::Success; }
50    // Matches: {"output":{"path":"length(KinesisDataStreamDestinations) > `0`  && length(KinesisDataStreamDestinations[?DestinationStatus == 'DISABLED' || DestinationStatus == 'ENABLE_FAILED']) ==  length(KinesisDataStreamDestinations)","expected":"true","comparator":"booleanEquals"}}
51                                if crate::waiters::matchers::match_describe_kinesis_streaming_destination_ce975c8fb2b65f98f(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_kinesis_streaming_destination::DescribeKinesisStreamingDestination::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 being described. 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 being described. 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 being described. 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}
87
88/// Successful return type for the `kinesis_streaming_destination_active` waiter.
89pub type KinesisStreamingDestinationActiveFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<crate::operation::describe_kinesis_streaming_destination::DescribeKinesisStreamingDestinationOutput, ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::describe_kinesis_streaming_destination::DescribeKinesisStreamingDestinationError, ::aws_smithy_runtime_api::client::orchestrator::HttpResponse>>;
90
91/// Error type for the `kinesis_streaming_destination_active` waiter.
92pub type WaitUntilKinesisStreamingDestinationActiveError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<crate::operation::describe_kinesis_streaming_destination::DescribeKinesisStreamingDestinationOutput, crate::operation::describe_kinesis_streaming_destination::DescribeKinesisStreamingDestinationError>;
93
aws_sdk_dynamodb/waiters/kinesis_streaming_destination_active.rs

aws_sdk_dynamodb/waiters/
kinesis_streaming_destination_active.rs
