Struct DynamoDbCheckpointer

pub struct DynamoDbCheckpointer { /* private fields */ }

DynamoDB-backed checkpointer for serverless AWS deployments.

Examples

use agents_aws::DynamoDbCheckpointer;
use std::time::Duration;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Using default AWS configuration
    let checkpointer = DynamoDbCheckpointer::new("agent-checkpoints").await?;

    // With custom configuration and TTL
    let checkpointer = DynamoDbCheckpointer::builder()
        .table_name("my-agents")
        .ttl(Duration::from_secs(86400 * 7)) // 7 days
        .build()
        .await?;

    Ok(())
}

Implementations

impl DynamoDbCheckpointer

pub async fn new( table_name: impl Into<String>, ) -> Result<DynamoDbCheckpointer, Error>

Create a new DynamoDB checkpointer with default AWS configuration.

This will use the default AWS credential chain (environment variables, IAM roles, AWS config files, etc.).

Arguments

• table_name - The name of the DynamoDB table

pub fn builder() -> DynamoDbCheckpointerBuilder

Create a builder for configuring the DynamoDB checkpointer.

Trait Implementations

impl Checkpointer for DynamoDbCheckpointer

fn save_state<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, thread_id: &'life1 String, state: &'life2 AgentStateSnapshot, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DynamoDbCheckpointer: 'async_trait,

Save the current agent state for a given thread.

fn load_state<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 String, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentStateSnapshot>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DynamoDbCheckpointer: 'async_trait,

Load the last saved state for a given thread. Returns None if no state exists for this thread.

fn delete_thread<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 String, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DynamoDbCheckpointer: 'async_trait,

Delete all saved state for a given thread.

fn list_threads<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, DynamoDbCheckpointer: 'async_trait,

List all thread IDs that have saved state.

impl Clone for DynamoDbCheckpointer

fn clone(&self) -> DynamoDbCheckpointer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.