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 163
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub use crate::operation::describe_tasks::_describe_tasks_output::DescribeTasksOutputBuilder;
pub use crate::operation::describe_tasks::_describe_tasks_input::DescribeTasksInputBuilder;
impl DescribeTasksInputBuilder {
/// Sends a request with this input using the given client.
pub async fn send_with(
self,
client: &crate::Client,
) -> ::std::result::Result<
crate::operation::describe_tasks::DescribeTasksOutput,
::aws_smithy_runtime_api::client::result::SdkError<
crate::operation::describe_tasks::DescribeTasksError,
::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
>,
> {
let mut fluent_builder = client.describe_tasks();
fluent_builder.inner = self;
fluent_builder.send().await
}
}
/// Fluent builder constructing a request to `DescribeTasks`.
///
/// <p>Describes a specified task or tasks.</p>
/// <p>Currently, stopped tasks appear in the returned results for at least one hour.</p>
/// <p>If you have tasks with tags, and then delete the cluster, the tagged tasks are returned in the response. If you create a new cluster with the same name as the deleted cluster, the tagged tasks are not included in the response.</p>
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
pub struct DescribeTasksFluentBuilder {
handle: ::std::sync::Arc<crate::client::Handle>,
inner: crate::operation::describe_tasks::builders::DescribeTasksInputBuilder,
config_override: ::std::option::Option<crate::config::Builder>,
}
impl
crate::client::customize::internal::CustomizableSend<
crate::operation::describe_tasks::DescribeTasksOutput,
crate::operation::describe_tasks::DescribeTasksError,
> for DescribeTasksFluentBuilder
{
fn send(
self,
config_override: crate::config::Builder,
) -> crate::client::customize::internal::BoxFuture<
crate::client::customize::internal::SendResult<
crate::operation::describe_tasks::DescribeTasksOutput,
crate::operation::describe_tasks::DescribeTasksError,
>,
> {
::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
}
}
impl DescribeTasksFluentBuilder {
/// Creates a new `DescribeTasks`.
pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
Self {
handle,
inner: ::std::default::Default::default(),
config_override: ::std::option::Option::None,
}
}
/// Access the DescribeTasks as a reference.
pub fn as_input(&self) -> &crate::operation::describe_tasks::builders::DescribeTasksInputBuilder {
&self.inner
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> ::std::result::Result<
crate::operation::describe_tasks::DescribeTasksOutput,
::aws_smithy_runtime_api::client::result::SdkError<
crate::operation::describe_tasks::DescribeTasksError,
::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
>,
> {
let input = self
.inner
.build()
.map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
let runtime_plugins = crate::operation::describe_tasks::DescribeTasks::operation_runtime_plugins(
self.handle.runtime_plugins.clone(),
&self.handle.conf,
self.config_override,
);
crate::operation::describe_tasks::DescribeTasks::orchestrate(&runtime_plugins, input).await
}
/// Consumes this builder, creating a customizable operation that can be modified before being sent.
pub fn customize(
self,
) -> crate::client::customize::CustomizableOperation<
crate::operation::describe_tasks::DescribeTasksOutput,
crate::operation::describe_tasks::DescribeTasksError,
Self,
> {
crate::client::customize::CustomizableOperation::new(self)
}
pub(crate) fn config_override(mut self, config_override: impl Into<crate::config::Builder>) -> Self {
self.set_config_override(Some(config_override.into()));
self
}
pub(crate) fn set_config_override(&mut self, config_override: Option<crate::config::Builder>) -> &mut Self {
self.config_override = config_override;
self
}
/// <p>The short name or full Amazon Resource Name (ARN) of the cluster that hosts the task or tasks to describe. If you do not specify a cluster, the default cluster is assumed. This parameter is required if the task or tasks you are describing were launched in any cluster other than the default cluster.</p>
pub fn cluster(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.cluster(input.into());
self
}
/// <p>The short name or full Amazon Resource Name (ARN) of the cluster that hosts the task or tasks to describe. If you do not specify a cluster, the default cluster is assumed. This parameter is required if the task or tasks you are describing were launched in any cluster other than the default cluster.</p>
pub fn set_cluster(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
self.inner = self.inner.set_cluster(input);
self
}
/// <p>The short name or full Amazon Resource Name (ARN) of the cluster that hosts the task or tasks to describe. If you do not specify a cluster, the default cluster is assumed. This parameter is required if the task or tasks you are describing were launched in any cluster other than the default cluster.</p>
pub fn get_cluster(&self) -> &::std::option::Option<::std::string::String> {
self.inner.get_cluster()
}
/// Appends an item to `tasks`.
///
/// To override the contents of this collection use [`set_tasks`](Self::set_tasks).
///
/// <p>A list of up to 100 task IDs or full ARN entries.</p>
pub fn tasks(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.tasks(input.into());
self
}
/// <p>A list of up to 100 task IDs or full ARN entries.</p>
pub fn set_tasks(mut self, input: ::std::option::Option<::std::vec::Vec<::std::string::String>>) -> Self {
self.inner = self.inner.set_tasks(input);
self
}
/// <p>A list of up to 100 task IDs or full ARN entries.</p>
pub fn get_tasks(&self) -> &::std::option::Option<::std::vec::Vec<::std::string::String>> {
self.inner.get_tasks()
}
/// Appends an item to `include`.
///
/// To override the contents of this collection use [`set_include`](Self::set_include).
///
/// <p>Specifies whether you want to see the resource tags for the task. If <code>TAGS</code> is specified, the tags are included in the response. If this field is omitted, tags aren't included in the response.</p>
pub fn include(mut self, input: crate::types::TaskField) -> Self {
self.inner = self.inner.include(input);
self
}
/// <p>Specifies whether you want to see the resource tags for the task. If <code>TAGS</code> is specified, the tags are included in the response. If this field is omitted, tags aren't included in the response.</p>
pub fn set_include(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::TaskField>>) -> Self {
self.inner = self.inner.set_include(input);
self
}
/// <p>Specifies whether you want to see the resource tags for the task. If <code>TAGS</code> is specified, the tags are included in the response. If this field is omitted, tags aren't included in the response.</p>
pub fn get_include(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::TaskField>> {
self.inner.get_include()
}
}