aws_sdk_lambda/operation/get_durable_execution_state/
builders.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2pub use crate::operation::get_durable_execution_state::_get_durable_execution_state_output::GetDurableExecutionStateOutputBuilder;
3
4pub use crate::operation::get_durable_execution_state::_get_durable_execution_state_input::GetDurableExecutionStateInputBuilder;
5
6impl crate::operation::get_durable_execution_state::builders::GetDurableExecutionStateInputBuilder {
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::get_durable_execution_state::GetDurableExecutionStateOutput,
13        ::aws_smithy_runtime_api::client::result::SdkError<
14            crate::operation::get_durable_execution_state::GetDurableExecutionStateError,
15            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
16        >,
17    > {
18        let mut fluent_builder = client.get_durable_execution_state();
19        fluent_builder.inner = self;
20        fluent_builder.send().await
21    }
22}
23/// Fluent builder constructing a request to `GetDurableExecutionState`.
24///
25/// <p>Retrieves the current execution state required for the replay process during <a href="https://docs.aws.amazon.com/lambda/latest/dg/durable-functions.html">durable function</a> execution. This API is used by the Lambda durable functions SDK to get state information needed for replay. You typically don't need to call this API directly as the SDK handles state management automatically.</p>
26/// <p>The response contains operations ordered by start sequence number in ascending order. Completed operations with children don't include child operation details since they don't need to be replayed.</p>
27#[derive(::std::clone::Clone, ::std::fmt::Debug)]
28pub struct GetDurableExecutionStateFluentBuilder {
29    handle: ::std::sync::Arc<crate::client::Handle>,
30    inner: crate::operation::get_durable_execution_state::builders::GetDurableExecutionStateInputBuilder,
31    config_override: ::std::option::Option<crate::config::Builder>,
32}
33impl
34    crate::client::customize::internal::CustomizableSend<
35        crate::operation::get_durable_execution_state::GetDurableExecutionStateOutput,
36        crate::operation::get_durable_execution_state::GetDurableExecutionStateError,
37    > for GetDurableExecutionStateFluentBuilder
38{
39    fn send(
40        self,
41        config_override: crate::config::Builder,
42    ) -> crate::client::customize::internal::BoxFuture<
43        crate::client::customize::internal::SendResult<
44            crate::operation::get_durable_execution_state::GetDurableExecutionStateOutput,
45            crate::operation::get_durable_execution_state::GetDurableExecutionStateError,
46        >,
47    > {
48        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
49    }
50}
51impl GetDurableExecutionStateFluentBuilder {
52    /// Creates a new `GetDurableExecutionStateFluentBuilder`.
53    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
54        Self {
55            handle,
56            inner: ::std::default::Default::default(),
57            config_override: ::std::option::Option::None,
58        }
59    }
60    /// Access the GetDurableExecutionState as a reference.
61    pub fn as_input(&self) -> &crate::operation::get_durable_execution_state::builders::GetDurableExecutionStateInputBuilder {
62        &self.inner
63    }
64    /// Sends the request and returns the response.
65    ///
66    /// If an error occurs, an `SdkError` will be returned with additional details that
67    /// can be matched against.
68    ///
69    /// By default, any retryable failures will be retried twice. Retry behavior
70    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
71    /// set when configuring the client.
72    pub async fn send(
73        self,
74    ) -> ::std::result::Result<
75        crate::operation::get_durable_execution_state::GetDurableExecutionStateOutput,
76        ::aws_smithy_runtime_api::client::result::SdkError<
77            crate::operation::get_durable_execution_state::GetDurableExecutionStateError,
78            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
79        >,
80    > {
81        let input = self
82            .inner
83            .build()
84            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
85        let runtime_plugins = crate::operation::get_durable_execution_state::GetDurableExecutionState::operation_runtime_plugins(
86            self.handle.runtime_plugins.clone(),
87            &self.handle.conf,
88            self.config_override,
89        );
90        crate::operation::get_durable_execution_state::GetDurableExecutionState::orchestrate(&runtime_plugins, input).await
91    }
92
93    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
94    pub fn customize(
95        self,
96    ) -> crate::client::customize::CustomizableOperation<
97        crate::operation::get_durable_execution_state::GetDurableExecutionStateOutput,
98        crate::operation::get_durable_execution_state::GetDurableExecutionStateError,
99        Self,
100    > {
101        crate::client::customize::CustomizableOperation::new(self)
102    }
103    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
104        self.set_config_override(::std::option::Option::Some(config_override.into()));
105        self
106    }
107
108    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
109        self.config_override = config_override;
110        self
111    }
112    /// Create a paginator for this request
113    ///
114    /// Paginators are used by calling [`send().await`](crate::operation::get_durable_execution_state::paginator::GetDurableExecutionStatePaginator::send) which returns a [`PaginationStream`](aws_smithy_async::future::pagination_stream::PaginationStream).
115    pub fn into_paginator(self) -> crate::operation::get_durable_execution_state::paginator::GetDurableExecutionStatePaginator {
116        crate::operation::get_durable_execution_state::paginator::GetDurableExecutionStatePaginator::new(self.handle, self.inner)
117    }
118    /// <p>The Amazon Resource Name (ARN) of the durable execution.</p>
119    pub fn durable_execution_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
120        self.inner = self.inner.durable_execution_arn(input.into());
121        self
122    }
123    /// <p>The Amazon Resource Name (ARN) of the durable execution.</p>
124    pub fn set_durable_execution_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
125        self.inner = self.inner.set_durable_execution_arn(input);
126        self
127    }
128    /// <p>The Amazon Resource Name (ARN) of the durable execution.</p>
129    pub fn get_durable_execution_arn(&self) -> &::std::option::Option<::std::string::String> {
130        self.inner.get_durable_execution_arn()
131    }
132    /// <p>A checkpoint token that identifies the current state of the execution. This token is provided by the Lambda runtime and ensures that state retrieval is consistent with the current execution context.</p>
133    pub fn checkpoint_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
134        self.inner = self.inner.checkpoint_token(input.into());
135        self
136    }
137    /// <p>A checkpoint token that identifies the current state of the execution. This token is provided by the Lambda runtime and ensures that state retrieval is consistent with the current execution context.</p>
138    pub fn set_checkpoint_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
139        self.inner = self.inner.set_checkpoint_token(input);
140        self
141    }
142    /// <p>A checkpoint token that identifies the current state of the execution. This token is provided by the Lambda runtime and ensures that state retrieval is consistent with the current execution context.</p>
143    pub fn get_checkpoint_token(&self) -> &::std::option::Option<::std::string::String> {
144        self.inner.get_checkpoint_token()
145    }
146    /// <p>If <code>NextMarker</code> was returned from a previous request, use this value to retrieve the next page of operations. Each pagination token expires after 24 hours.</p>
147    pub fn marker(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
148        self.inner = self.inner.marker(input.into());
149        self
150    }
151    /// <p>If <code>NextMarker</code> was returned from a previous request, use this value to retrieve the next page of operations. Each pagination token expires after 24 hours.</p>
152    pub fn set_marker(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
153        self.inner = self.inner.set_marker(input);
154        self
155    }
156    /// <p>If <code>NextMarker</code> was returned from a previous request, use this value to retrieve the next page of operations. Each pagination token expires after 24 hours.</p>
157    pub fn get_marker(&self) -> &::std::option::Option<::std::string::String> {
158        self.inner.get_marker()
159    }
160    /// <p>The maximum number of operations to return per call. You can use <code>Marker</code> to retrieve additional pages of results. The default is 100 and the maximum allowed is 1000. A value of 0 uses the default.</p>
161    pub fn max_items(mut self, input: i32) -> Self {
162        self.inner = self.inner.max_items(input);
163        self
164    }
165    /// <p>The maximum number of operations to return per call. You can use <code>Marker</code> to retrieve additional pages of results. The default is 100 and the maximum allowed is 1000. A value of 0 uses the default.</p>
166    pub fn set_max_items(mut self, input: ::std::option::Option<i32>) -> Self {
167        self.inner = self.inner.set_max_items(input);
168        self
169    }
170    /// <p>The maximum number of operations to return per call. You can use <code>Marker</code> to retrieve additional pages of results. The default is 100 and the maximum allowed is 1000. A value of 0 uses the default.</p>
171    pub fn get_max_items(&self) -> &::std::option::Option<i32> {
172        self.inner.get_max_items()
173    }
174}
aws_sdk_lambda/operation/get_durable_execution_state/builders.rs

aws_sdk_lambda/operation/get_durable_execution_state/
builders.rs
