pub struct LambdaHistoryApiClient { /* private fields */ }Expand description
Real implementation of HistoryApiClient that calls the durable execution
state API via a LambdaDurableServiceClient.
Wraps a LambdaClient and creates an internal service client to make
signed HTTP calls to the GetDurableExecutionHistory API endpoint.
Implementations§
Source§impl LambdaHistoryApiClient
impl LambdaHistoryApiClient
Sourcepub fn from_aws_config(aws_config: &SdkConfig) -> Result<Self, TestError>
pub fn from_aws_config(aws_config: &SdkConfig) -> Result<Self, TestError>
Creates a new LambdaHistoryApiClient from an AWS SDK config.
The config is used to construct a LambdaDurableServiceClient that
makes signed HTTP calls to the durable execution state API.
§Arguments
aws_config- The AWS SDK configuration (same one used to create theLambdaClient)
Sourcepub fn from_service_client(service_client: LambdaDurableServiceClient) -> Self
pub fn from_service_client(service_client: LambdaDurableServiceClient) -> Self
Creates a new LambdaHistoryApiClient from an existing LambdaDurableServiceClient.
Useful when a service client is already available.
Trait Implementations§
Source§impl HistoryApiClient for LambdaHistoryApiClient
impl HistoryApiClient for LambdaHistoryApiClient
Source§fn get_history<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
arn: &'life1 str,
marker: Option<&'life2 str>,
) -> Pin<Box<dyn Future<Output = Result<HistoryPage, TestError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn get_history<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
arn: &'life1 str,
marker: Option<&'life2 str>,
) -> Pin<Box<dyn Future<Output = Result<HistoryPage, TestError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Retrieves a single page of execution history by calling the durable execution state API.
Detects terminal state by examining EXECUTION-type operations: when an execution operation has a terminal status (Succeeded, Failed, Cancelled, TimedOut), the page is marked as terminal with the corresponding status, result, and error.
Auto Trait Implementations§
impl Freeze for LambdaHistoryApiClient
impl !RefUnwindSafe for LambdaHistoryApiClient
impl Send for LambdaHistoryApiClient
impl Sync for LambdaHistoryApiClient
impl Unpin for LambdaHistoryApiClient
impl UnsafeUnpin for LambdaHistoryApiClient
impl !UnwindSafe for LambdaHistoryApiClient
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more