aws_sdk_pipes/operation/list_pipes/
builders.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2pub use crate::operation::list_pipes::_list_pipes_output::ListPipesOutputBuilder;
3
4pub use crate::operation::list_pipes::_list_pipes_input::ListPipesInputBuilder;
5
6impl crate::operation::list_pipes::builders::ListPipesInputBuilder {
7    /// Sends a request with this input using the given client.
8    pub async fn send_with(
9        self,
10        client: &crate::Client,
11    ) -> ::std::result::Result<
12        crate::operation::list_pipes::ListPipesOutput,
13        ::aws_smithy_runtime_api::client::result::SdkError<
14            crate::operation::list_pipes::ListPipesError,
15            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
16        >,
17    > {
18        let mut fluent_builder = client.list_pipes();
19        fluent_builder.inner = self;
20        fluent_builder.send().await
21    }
22}
23/// Fluent builder constructing a request to `ListPipes`.
24///
25/// <p>Get the pipes associated with this account. For more information about pipes, see <a href="https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html">Amazon EventBridge Pipes</a> in the Amazon EventBridge User Guide.</p>
26#[derive(::std::clone::Clone, ::std::fmt::Debug)]
27pub struct ListPipesFluentBuilder {
28    handle: ::std::sync::Arc<crate::client::Handle>,
29    inner: crate::operation::list_pipes::builders::ListPipesInputBuilder,
30    config_override: ::std::option::Option<crate::config::Builder>,
31}
32impl crate::client::customize::internal::CustomizableSend<crate::operation::list_pipes::ListPipesOutput, crate::operation::list_pipes::ListPipesError>
33    for ListPipesFluentBuilder
34{
35    fn send(
36        self,
37        config_override: crate::config::Builder,
38    ) -> crate::client::customize::internal::BoxFuture<
39        crate::client::customize::internal::SendResult<crate::operation::list_pipes::ListPipesOutput, crate::operation::list_pipes::ListPipesError>,
40    > {
41        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
42    }
43}
44impl ListPipesFluentBuilder {
45    /// Creates a new `ListPipesFluentBuilder`.
46    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
47        Self {
48            handle,
49            inner: ::std::default::Default::default(),
50            config_override: ::std::option::Option::None,
51        }
52    }
53    /// Access the ListPipes as a reference.
54    pub fn as_input(&self) -> &crate::operation::list_pipes::builders::ListPipesInputBuilder {
55        &self.inner
56    }
57    /// Sends the request and returns the response.
58    ///
59    /// If an error occurs, an `SdkError` will be returned with additional details that
60    /// can be matched against.
61    ///
62    /// By default, any retryable failures will be retried twice. Retry behavior
63    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
64    /// set when configuring the client.
65    pub async fn send(
66        self,
67    ) -> ::std::result::Result<
68        crate::operation::list_pipes::ListPipesOutput,
69        ::aws_smithy_runtime_api::client::result::SdkError<
70            crate::operation::list_pipes::ListPipesError,
71            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
72        >,
73    > {
74        let input = self
75            .inner
76            .build()
77            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
78        let runtime_plugins = crate::operation::list_pipes::ListPipes::operation_runtime_plugins(
79            self.handle.runtime_plugins.clone(),
80            &self.handle.conf,
81            self.config_override,
82        );
83        crate::operation::list_pipes::ListPipes::orchestrate(&runtime_plugins, input).await
84    }
85
86    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
87    pub fn customize(
88        self,
89    ) -> crate::client::customize::CustomizableOperation<
90        crate::operation::list_pipes::ListPipesOutput,
91        crate::operation::list_pipes::ListPipesError,
92        Self,
93    > {
94        crate::client::customize::CustomizableOperation::new(self)
95    }
96    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
97        self.set_config_override(::std::option::Option::Some(config_override.into()));
98        self
99    }
100
101    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
102        self.config_override = config_override;
103        self
104    }
105    /// Create a paginator for this request
106    ///
107    /// Paginators are used by calling [`send().await`](crate::operation::list_pipes::paginator::ListPipesPaginator::send) which returns a [`PaginationStream`](aws_smithy_async::future::pagination_stream::PaginationStream).
108    pub fn into_paginator(self) -> crate::operation::list_pipes::paginator::ListPipesPaginator {
109        crate::operation::list_pipes::paginator::ListPipesPaginator::new(self.handle, self.inner)
110    }
111    /// <p>A value that will return a subset of the pipes associated with this account. For example, <code>"NamePrefix": "ABC"</code> will return all endpoints with "ABC" in the name.</p>
112    pub fn name_prefix(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
113        self.inner = self.inner.name_prefix(input.into());
114        self
115    }
116    /// <p>A value that will return a subset of the pipes associated with this account. For example, <code>"NamePrefix": "ABC"</code> will return all endpoints with "ABC" in the name.</p>
117    pub fn set_name_prefix(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
118        self.inner = self.inner.set_name_prefix(input);
119        self
120    }
121    /// <p>A value that will return a subset of the pipes associated with this account. For example, <code>"NamePrefix": "ABC"</code> will return all endpoints with "ABC" in the name.</p>
122    pub fn get_name_prefix(&self) -> &::std::option::Option<::std::string::String> {
123        self.inner.get_name_prefix()
124    }
125    /// <p>The state the pipe should be in.</p>
126    pub fn desired_state(mut self, input: crate::types::RequestedPipeState) -> Self {
127        self.inner = self.inner.desired_state(input);
128        self
129    }
130    /// <p>The state the pipe should be in.</p>
131    pub fn set_desired_state(mut self, input: ::std::option::Option<crate::types::RequestedPipeState>) -> Self {
132        self.inner = self.inner.set_desired_state(input);
133        self
134    }
135    /// <p>The state the pipe should be in.</p>
136    pub fn get_desired_state(&self) -> &::std::option::Option<crate::types::RequestedPipeState> {
137        self.inner.get_desired_state()
138    }
139    /// <p>The state the pipe is in.</p>
140    pub fn current_state(mut self, input: crate::types::PipeState) -> Self {
141        self.inner = self.inner.current_state(input);
142        self
143    }
144    /// <p>The state the pipe is in.</p>
145    pub fn set_current_state(mut self, input: ::std::option::Option<crate::types::PipeState>) -> Self {
146        self.inner = self.inner.set_current_state(input);
147        self
148    }
149    /// <p>The state the pipe is in.</p>
150    pub fn get_current_state(&self) -> &::std::option::Option<crate::types::PipeState> {
151        self.inner.get_current_state()
152    }
153    /// <p>The prefix matching the pipe source.</p>
154    pub fn source_prefix(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
155        self.inner = self.inner.source_prefix(input.into());
156        self
157    }
158    /// <p>The prefix matching the pipe source.</p>
159    pub fn set_source_prefix(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
160        self.inner = self.inner.set_source_prefix(input);
161        self
162    }
163    /// <p>The prefix matching the pipe source.</p>
164    pub fn get_source_prefix(&self) -> &::std::option::Option<::std::string::String> {
165        self.inner.get_source_prefix()
166    }
167    /// <p>The prefix matching the pipe target.</p>
168    pub fn target_prefix(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
169        self.inner = self.inner.target_prefix(input.into());
170        self
171    }
172    /// <p>The prefix matching the pipe target.</p>
173    pub fn set_target_prefix(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
174        self.inner = self.inner.set_target_prefix(input);
175        self
176    }
177    /// <p>The prefix matching the pipe target.</p>
178    pub fn get_target_prefix(&self) -> &::std::option::Option<::std::string::String> {
179        self.inner.get_target_prefix()
180    }
181    /// <p>If <code>nextToken</code> is returned, there are more results available. The value of <code>nextToken</code> is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged. Each pagination token expires after 24 hours. Using an expired pagination token will return an HTTP 400 InvalidToken error.</p>
182    pub fn next_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
183        self.inner = self.inner.next_token(input.into());
184        self
185    }
186    /// <p>If <code>nextToken</code> is returned, there are more results available. The value of <code>nextToken</code> is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged. Each pagination token expires after 24 hours. Using an expired pagination token will return an HTTP 400 InvalidToken error.</p>
187    pub fn set_next_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
188        self.inner = self.inner.set_next_token(input);
189        self
190    }
191    /// <p>If <code>nextToken</code> is returned, there are more results available. The value of <code>nextToken</code> is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged. Each pagination token expires after 24 hours. Using an expired pagination token will return an HTTP 400 InvalidToken error.</p>
192    pub fn get_next_token(&self) -> &::std::option::Option<::std::string::String> {
193        self.inner.get_next_token()
194    }
195    /// <p>The maximum number of pipes to include in the response.</p>
196    pub fn limit(mut self, input: i32) -> Self {
197        self.inner = self.inner.limit(input);
198        self
199    }
200    /// <p>The maximum number of pipes to include in the response.</p>
201    pub fn set_limit(mut self, input: ::std::option::Option<i32>) -> Self {
202        self.inner = self.inner.set_limit(input);
203        self
204    }
205    /// <p>The maximum number of pipes to include in the response.</p>
206    pub fn get_limit(&self) -> &::std::option::Option<i32> {
207        self.inner.get_limit()
208    }
209}
aws_sdk_pipes/operation/list_pipes/builders.rs

aws_sdk_pipes/operation/list_pipes/
builders.rs
