Struct RedisCheckpointer

pub struct RedisCheckpointer { /* private fields */ }

Redis-backed checkpointer with connection pooling and TTL support.

Examples

use agents_persistence::RedisCheckpointer;
use std::time::Duration;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Basic usage
    let checkpointer = RedisCheckpointer::new("redis://127.0.0.1:6379").await?;

    // With namespace and TTL
    let checkpointer = RedisCheckpointer::builder()
        .url("redis://127.0.0.1:6379")
        .namespace("myapp")
        .ttl(Duration::from_secs(86400)) // 24 hours
        .build()
        .await?;

    Ok(())
}

Implementations

impl RedisCheckpointer

pub async fn new(url: &str) -> Result<RedisCheckpointer, Error>

Create a new Redis checkpointer with the default namespace.

Arguments

• url - Redis connection URL (e.g., “redis://127.0.0.1:6379”)

pub fn builder() -> RedisCheckpointerBuilder

Create a builder for configuring the Redis checkpointer.

Trait Implementations

impl Checkpointer for RedisCheckpointer

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, RedisCheckpointer: '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, RedisCheckpointer: '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, RedisCheckpointer: '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, RedisCheckpointer: 'async_trait,

List all thread IDs that have saved state.

impl Clone for RedisCheckpointer

fn clone(&self) -> RedisCheckpointer

Returns a duplicate of the value.

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

Performs copy-assignment from source.