Struct DeltaCheckpointer 

pub struct DeltaCheckpointer<C>
where
    C: Checkpointer,
{ /* private fields */ }

Available on crate feature graph only.

Wraps any Checkpointer with delta compression.

On save, the DeltaCheckpointer stores either a full state snapshot or an incremental delta depending on the step number and the configured DeltaConfig::full_snapshot_interval. On load, it reconstructs the full state by finding the nearest full snapshot and replaying deltas forward.

The DeltaCheckpointer exposes the same Checkpointer trait interface, making it a drop-in replacement for any existing checkpointer.

Example

use adk_graph::delta::{DeltaCheckpointer, DeltaConfig};
use adk_graph::checkpoint::MemoryCheckpointer;

let inner = MemoryCheckpointer::new();
let config = DeltaConfig { full_snapshot_interval: 5 };
let checkpointer = DeltaCheckpointer::new(inner, config);

// Use checkpointer as any other Checkpointer implementation

Implementations

impl<C> DeltaCheckpointer<C>

where C: Checkpointer,

pub fn new(inner: C, config: DeltaConfig) -> DeltaCheckpointer<C>

Available on crate feature delta-checkpoint only.

Create a new DeltaCheckpointer wrapping the given inner checkpointer.

Arguments

• inner - The underlying checkpointer used for actual storage.
• config - Configuration controlling full snapshot frequency.

pub fn inner(&self) -> &C

Available on crate feature delta-checkpoint only.

Returns a reference to the inner checkpointer.

pub fn config(&self) -> &DeltaConfig

Available on crate feature delta-checkpoint only.

Returns the delta configuration.

Trait Implementations

impl<C> Checkpointer for DeltaCheckpointer<C>

where C: Checkpointer,

fn save<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 Checkpoint, ) -> Pin<Box<dyn Future<Output = Result<String, GraphError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DeltaCheckpointer<C>: 'async_trait,

Save a checkpoint with delta compression.

If the step is a full snapshot boundary (step == 0 or step % full_snapshot_interval == 0), the full state is stored. Otherwise, the delta from the previous checkpoint is computed and stored, with the checkpoint’s state field set to an empty map to save space.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint>, GraphError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DeltaCheckpointer<C>: 'async_trait,

Load the latest checkpoint for a thread, reconstructing full state.

Finds the latest checkpoint, then reconstructs the full state by replaying deltas from the nearest full snapshot forward.

fn load_by_id<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint>, GraphError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DeltaCheckpointer<C>: 'async_trait,

Load a specific checkpoint by ID, reconstructing full state.

Finds the checkpoint by ID, determines its thread, then reconstructs the full state by replaying deltas from the nearest full snapshot.

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

where 'life0: 'async_trait, 'life1: 'async_trait, DeltaCheckpointer<C>: 'async_trait,

List all checkpoints for a thread.

Delegates directly to the inner checkpointer. Note that delta checkpoints in the list will have empty state fields — use load or load_by_id to get reconstructed state.

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

where 'life0: 'async_trait, 'life1: 'async_trait, DeltaCheckpointer<C>: 'async_trait,

Delete all checkpoints for a thread.

Delegates directly to the inner checkpointer.

fn prune<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _thread_id: &'life1 str, _policy: &'life2 RetentionPolicy, ) -> Pin<Box<dyn Future<Output = Result<usize, GraphError>> + Send + 'async_trait>>

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

Removes the checkpoints a retention policy discards, keeping the newest.