aws_sdk_opsworks/waiters/
instance_online.rs1#[derive(::std::clone::Clone, ::std::fmt::Debug)]
15pub struct InstanceOnlineFluentBuilder {
16 handle: ::std::sync::Arc<crate::client::Handle>,
17 inner: crate::operation::describe_instances::builders::DescribeInstancesInputBuilder,
18}
19impl InstanceOnlineFluentBuilder {
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_instances::builders::DescribeInstancesInputBuilder {
29 &self.inner
30 }
31 pub async fn wait(
33 self,
34 max_wait: ::std::time::Duration,
35 ) -> ::std::result::Result<crate::waiters::instance_online::InstanceOnlineFinalPoll, crate::waiters::instance_online::WaitUntilInstanceOnlineError>
36 {
37 let input = self
38 .inner
39 .build()
40 .map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
41 let runtime_plugins = crate::operation::describe_instances::DescribeInstances::operation_runtime_plugins(
42 self.handle.runtime_plugins.clone(),
43 &self.handle.conf,
44 ::std::option::Option::None,
45 )
46 .with_operation_plugin(crate::sdk_feature_tracker::waiter::WaiterFeatureTrackerRuntimePlugin::new());
47 let mut cfg = ::aws_smithy_types::config_bag::ConfigBag::base();
48 let runtime_components_builder = runtime_plugins
49 .apply_client_configuration(&mut cfg)
50 .map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
51 let time_components = runtime_components_builder.into_time_components();
52 let sleep_impl = time_components.sleep_impl().expect("a sleep impl is required by waiters");
53 let time_source = time_components.time_source().expect("a time source is required by waiters");
54
55 let acceptor = move |result: ::std::result::Result<
56 &crate::operation::describe_instances::DescribeInstancesOutput,
57 &crate::operation::describe_instances::DescribeInstancesError,
58 >| {
59 if crate::waiters::matchers::match_describe_instances_879e5860f33174a71(result) {
61 return ::aws_smithy_runtime::client::waiters::AcceptorState::Success;
62 }
63 if crate::waiters::matchers::match_describe_instances_ae8d9fe9dcb532dd4(result) {
65 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
66 }
67 if crate::waiters::matchers::match_describe_instances_cb65e3427d01d7667(result) {
69 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
70 }
71 if crate::waiters::matchers::match_describe_instances_c942b3f1e73dfae7f(result) {
73 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
74 }
75 if crate::waiters::matchers::match_describe_instances_dad92608d71b243c3(result) {
77 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
78 }
79 if crate::waiters::matchers::match_describe_instances_6eb5e99b738450c30(result) {
81 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
82 }
83 if crate::waiters::matchers::match_describe_instances_f086d9d7330075a64(result) {
85 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
86 }
87 if crate::waiters::matchers::match_describe_instances_e88d0bb4db07224fa(result) {
89 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
90 }
91 if crate::waiters::matchers::match_describe_instances_8d7f49fcbbbfabdf5(result) {
93 return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
94 }
95 ::aws_smithy_runtime::client::waiters::AcceptorState::NoAcceptorsMatched
96 };
97 let operation = move || {
98 let input = input.clone();
99 let runtime_plugins = runtime_plugins.clone();
100 async move { crate::operation::describe_instances::DescribeInstances::orchestrate(&runtime_plugins, input).await }
101 };
102 let orchestrator = ::aws_smithy_runtime::client::waiters::WaiterOrchestrator::builder()
103 .min_delay(::std::time::Duration::from_secs(15))
104 .max_delay(::std::time::Duration::from_secs(120))
105 .max_wait(max_wait)
106 .time_source(time_source)
107 .sleep_impl(sleep_impl)
108 .acceptor(acceptor)
109 .operation(operation)
110 .build();
111 ::aws_smithy_runtime::client::waiters::attach_waiter_tracing_span(orchestrator.orchestrate()).await
112 }
113 pub fn stack_id(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
115 self.inner = self.inner.stack_id(input.into());
116 self
117 }
118 pub fn set_stack_id(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
120 self.inner = self.inner.set_stack_id(input);
121 self
122 }
123 pub fn get_stack_id(&self) -> &::std::option::Option<::std::string::String> {
125 self.inner.get_stack_id()
126 }
127 pub fn layer_id(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
129 self.inner = self.inner.layer_id(input.into());
130 self
131 }
132 pub fn set_layer_id(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
134 self.inner = self.inner.set_layer_id(input);
135 self
136 }
137 pub fn get_layer_id(&self) -> &::std::option::Option<::std::string::String> {
139 self.inner.get_layer_id()
140 }
141 pub fn instance_ids(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
148 self.inner = self.inner.instance_ids(input.into());
149 self
150 }
151 pub fn set_instance_ids(mut self, input: ::std::option::Option<::std::vec::Vec<::std::string::String>>) -> Self {
153 self.inner = self.inner.set_instance_ids(input);
154 self
155 }
156 pub fn get_instance_ids(&self) -> &::std::option::Option<::std::vec::Vec<::std::string::String>> {
158 self.inner.get_instance_ids()
159 }
160}
161
162pub type InstanceOnlineFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<
164 crate::operation::describe_instances::DescribeInstancesOutput,
165 ::aws_smithy_runtime_api::client::result::SdkError<
166 crate::operation::describe_instances::DescribeInstancesError,
167 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
168 >,
169>;
170
171pub type WaitUntilInstanceOnlineError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<
173 crate::operation::describe_instances::DescribeInstancesOutput,
174 crate::operation::describe_instances::DescribeInstancesError,
175>;