1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
///
/// Fluent builder for the `project_version_running` waiter.
///
/// This builder is intended to be used similar to the other fluent builders for
/// normal operations on the client. However, instead of a `send` method, it has
/// a `wait` method that takes a maximum amount of time to wait.
///
/// Construct this fluent builder using the client by importing the
/// [`Waiters`](crate::client::Waiters) trait and calling the methods
/// prefixed with `wait_until`.
///
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
pub struct ProjectVersionRunningFluentBuilder {
handle: ::std::sync::Arc<crate::client::Handle>,
inner: crate::operation::describe_project_versions::builders::DescribeProjectVersionsInputBuilder,
}
impl ProjectVersionRunningFluentBuilder {
/// Creates a new `ProjectVersionRunningFluentBuilder`.
pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
Self {
handle,
inner: ::std::default::Default::default(),
}
}
/// Access the DescribeProjectVersions as a reference.
pub fn as_input(&self) -> &crate::operation::describe_project_versions::builders::DescribeProjectVersionsInputBuilder {
&self.inner
}
/// Wait until the ProjectVersion is running.
pub async fn wait(
self,
max_wait: ::std::time::Duration,
) -> ::std::result::Result<
crate::waiters::project_version_running::ProjectVersionRunningFinalPoll,
crate::waiters::project_version_running::WaitUntilProjectVersionRunningError,
> {
let input = self
.inner
.build()
.map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
let runtime_plugins = crate::operation::describe_project_versions::DescribeProjectVersions::operation_runtime_plugins(
self.handle.runtime_plugins.clone(),
&self.handle.conf,
::std::option::Option::None,
);
let mut cfg = ::aws_smithy_types::config_bag::ConfigBag::base();
let runtime_components_builder = runtime_plugins
.apply_client_configuration(&mut cfg)
.map_err(::aws_smithy_runtime_api::client::waiters::error::WaiterError::construction_failure)?;
let time_components = runtime_components_builder.into_time_components();
let sleep_impl = time_components.sleep_impl().expect("a sleep impl is required by waiters");
let time_source = time_components.time_source().expect("a time source is required by waiters");
let acceptor = move |result: ::std::result::Result<
&crate::operation::describe_project_versions::DescribeProjectVersionsOutput,
&crate::operation::describe_project_versions::DescribeProjectVersionsError,
>| {
// Matches: {"output":{"path":"ProjectVersionDescriptions[].Status","expected":"RUNNING","comparator":"allStringEquals"}}
if crate::waiters::matchers::match_describe_project_versions_ecdc1939edd26defa(result) {
return ::aws_smithy_runtime::client::waiters::AcceptorState::Success;
}
// Matches: {"output":{"path":"ProjectVersionDescriptions[].Status","expected":"FAILED","comparator":"anyStringEquals"}}
if crate::waiters::matchers::match_describe_project_versions_372e6b6443f871a1d(result) {
return ::aws_smithy_runtime::client::waiters::AcceptorState::Failure;
}
::aws_smithy_runtime::client::waiters::AcceptorState::NoAcceptorsMatched
};
let operation = move || {
let input = input.clone();
let runtime_plugins = runtime_plugins.clone();
async move { crate::operation::describe_project_versions::DescribeProjectVersions::orchestrate(&runtime_plugins, input).await }
};
let orchestrator = ::aws_smithy_runtime::client::waiters::WaiterOrchestrator::builder()
.min_delay(::std::time::Duration::from_secs(30))
.max_delay(::std::time::Duration::from_secs(120))
.max_wait(max_wait)
.time_source(time_source)
.sleep_impl(sleep_impl)
.acceptor(acceptor)
.operation(operation)
.build();
::aws_smithy_runtime::client::waiters::attach_waiter_tracing_span(orchestrator.orchestrate()).await
}
/// <p>The Amazon Resource Name (ARN) of the project that contains the model/adapter you want to describe.</p>
pub fn project_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.project_arn(input.into());
self
}
/// <p>The Amazon Resource Name (ARN) of the project that contains the model/adapter you want to describe.</p>
pub fn set_project_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
self.inner = self.inner.set_project_arn(input);
self
}
/// <p>The Amazon Resource Name (ARN) of the project that contains the model/adapter you want to describe.</p>
pub fn get_project_arn(&self) -> &::std::option::Option<::std::string::String> {
self.inner.get_project_arn()
}
///
/// Appends an item to `VersionNames`.
///
/// To override the contents of this collection use [`set_version_names`](Self::set_version_names).
///
/// <p>A list of model or project version names that you want to describe. You can add up to 10 model or project version names to the list. If you don't specify a value, all project version descriptions are returned. A version name is part of a project version ARN. For example, <code>my-model.2020-01-21T09.10.15</code> is the version name in the following ARN. <code>arn:aws:rekognition:us-east-1:123456789012:project/getting-started/version/<i>my-model.2020-01-21T09.10.15</i>/1234567890123</code>.</p>
pub fn version_names(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.version_names(input.into());
self
}
/// <p>A list of model or project version names that you want to describe. You can add up to 10 model or project version names to the list. If you don't specify a value, all project version descriptions are returned. A version name is part of a project version ARN. For example, <code>my-model.2020-01-21T09.10.15</code> is the version name in the following ARN. <code>arn:aws:rekognition:us-east-1:123456789012:project/getting-started/version/<i>my-model.2020-01-21T09.10.15</i>/1234567890123</code>.</p>
pub fn set_version_names(mut self, input: ::std::option::Option<::std::vec::Vec<::std::string::String>>) -> Self {
self.inner = self.inner.set_version_names(input);
self
}
/// <p>A list of model or project version names that you want to describe. You can add up to 10 model or project version names to the list. If you don't specify a value, all project version descriptions are returned. A version name is part of a project version ARN. For example, <code>my-model.2020-01-21T09.10.15</code> is the version name in the following ARN. <code>arn:aws:rekognition:us-east-1:123456789012:project/getting-started/version/<i>my-model.2020-01-21T09.10.15</i>/1234567890123</code>.</p>
pub fn get_version_names(&self) -> &::std::option::Option<::std::vec::Vec<::std::string::String>> {
self.inner.get_version_names()
}
/// <p>If the previous response was incomplete (because there is more results to retrieve), Amazon Rekognition returns a pagination token in the response. You can use this pagination token to retrieve the next set of results.</p>
pub fn next_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.next_token(input.into());
self
}
/// <p>If the previous response was incomplete (because there is more results to retrieve), Amazon Rekognition returns a pagination token in the response. You can use this pagination token to retrieve the next set of results.</p>
pub fn set_next_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
self.inner = self.inner.set_next_token(input);
self
}
/// <p>If the previous response was incomplete (because there is more results to retrieve), Amazon Rekognition returns a pagination token in the response. You can use this pagination token to retrieve the next set of results.</p>
pub fn get_next_token(&self) -> &::std::option::Option<::std::string::String> {
self.inner.get_next_token()
}
/// <p>The maximum number of results to return per paginated call. The largest value you can specify is 100. If you specify a value greater than 100, a ValidationException error occurs. The default value is 100.</p>
pub fn max_results(mut self, input: i32) -> Self {
self.inner = self.inner.max_results(input);
self
}
/// <p>The maximum number of results to return per paginated call. The largest value you can specify is 100. If you specify a value greater than 100, a ValidationException error occurs. The default value is 100.</p>
pub fn set_max_results(mut self, input: ::std::option::Option<i32>) -> Self {
self.inner = self.inner.set_max_results(input);
self
}
/// <p>The maximum number of results to return per paginated call. The largest value you can specify is 100. If you specify a value greater than 100, a ValidationException error occurs. The default value is 100.</p>
pub fn get_max_results(&self) -> &::std::option::Option<i32> {
self.inner.get_max_results()
}
}
/// Successful return type for the `project_version_running` waiter.
pub type ProjectVersionRunningFinalPoll = ::aws_smithy_runtime_api::client::waiters::FinalPoll<
crate::operation::describe_project_versions::DescribeProjectVersionsOutput,
::aws_smithy_runtime_api::client::result::SdkError<
crate::operation::describe_project_versions::DescribeProjectVersionsError,
::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
>,
>;
/// Error type for the `project_version_running` waiter.
pub type WaitUntilProjectVersionRunningError = ::aws_smithy_runtime_api::client::waiters::error::WaiterError<
crate::operation::describe_project_versions::DescribeProjectVersionsOutput,
crate::operation::describe_project_versions::DescribeProjectVersionsError,
>;