Struct MongoCheckpointer 

pub struct MongoCheckpointer { /* private fields */ }

MongoDB-backed graph checkpointer.

Stores graph state checkpoints in a MongoDB collection, suitable for distributed deployments where multiple processes share checkpointed state.

Example

use synaptic_mongodb::MongoCheckpointer;

let client = mongodb::Client::with_uri_str("mongodb://localhost:27017").await?;
let db = client.database("myapp");
let checkpointer = MongoCheckpointer::new(&db, "graph_checkpoints").await?;

Implementations

impl MongoCheckpointer

pub async fn new( db: &Database, collection_name: &str, ) -> Result<Self, SynapticError>

Create a new MongoCheckpointer backed by the given MongoDB database and collection.

Creates a compound index on (thread_id, checkpoint_id) and a secondary index on (thread_id, seq) for efficient ordered retrieval.

Trait Implementations

impl Checkpointer for MongoCheckpointer

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, config: &'life1 CheckpointConfig, checkpoint: &'life2 Checkpoint, ) -> Pin<Box<dyn Future<Output = Result<(), SynapticError>> + Send + 'async_trait>>

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

Save a checkpoint for the given thread.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 CheckpointConfig, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint>, SynapticError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a checkpoint. If config.checkpoint_id is set, returns that specific checkpoint; otherwise returns the latest checkpoint for the thread.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 CheckpointConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<Checkpoint>, SynapticError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all checkpoints for a thread, ordered oldest to newest.