Juncture Checkpoint

Checkpoint persistence for Juncture state machine executions. Provides save/restore of complete execution state for time-travel debugging, crash recovery, and HITL workflows.

Features

• Multiple Storage Backends: Memory, SQLite, PostgreSQL
• Serialization Formats: JSON, MessagePack, JSON+ (with type info)
• Encryption: AES-GCM + PBKDF2 for sensitive checkpoints
• TTL Support: Automatic checkpoint expiration
• Delta Recovery: Recover from delta-only checkpoints

Usage

use juncture_checkpoint::{MemorySaver, SqliteSaver};

// In-memory checkpoint saver (for testing)
let saver = MemorySaver::new();

// SQLite checkpoint saver (for persistence)
let saver = SqliteSaver::new("checkpoints.db").await?;

// Use with graph compilation
let graph = state_graph
    .compile_with_checkpointer(saver);

Storage Backends

Serialization

• JsonSerializer - Standard JSON serialization
• MsgpackSerializer - Binary MessagePack format
• JsonPlusSerializer - JSON with type information
• EncryptedSerializer - AES-GCM encryption (feature encryption)

License

Licensed under Apache License, Version 2.0. See LICENSE for details.