Struct HistoryPoller 

pub struct HistoryPoller<C: HistoryApiClient> { /* private fields */ }

Polls GetDurableExecutionHistory and feeds results into OperationStorage.

The HistoryPoller periodically calls the history API, handles pagination within each poll cycle, and retries transient errors with exponential backoff.

Implementations

impl<C: HistoryApiClient> HistoryPoller<C>

pub fn new(api_client: C, arn: String, poll_interval: Duration) -> Self

Creates a new HistoryPoller.

Arguments

• api_client - The client used to call the history API
• arn - The Durable Execution ARN identifying the execution to poll
• poll_interval - Duration to wait between page requests within a poll cycle

pub async fn poll_once(&mut self) -> Result<PollResult, TestError>

Executes one poll cycle, exhausting all pages via pagination.

Starting from self.last_marker, this method calls the history API and follows next_marker pagination tokens until no more pages remain. Between each page request, it waits poll_interval to avoid throttling.

After the cycle completes, self.last_marker is updated to the last page’s next_marker so the next poll cycle starts where this one left off.

Returns

A PollResult containing all operations and events aggregated across all pages, plus any terminal state detected during the cycle.