Struct PersistenceEngine 

pub struct PersistenceEngine { /* private fields */ }

The persistence engine — wraps KanbanStore + RelationsStore with dirty tracking, atomic saves (via arrow-graph-git), and graph-native commits.

Implementations

impl PersistenceEngine

pub fn new(config: PersistenceConfig) -> Self

Create a new persistence engine with the given config.

pub fn mark_dirty(&mut self)

Mark state as dirty (a mutation occurred).

pub fn is_dirty(&self) -> bool

Whether the engine has unsaved changes.

pub fn periodic_save_due(&self) -> bool

Check if a periodic save is due.

pub fn git_backup_due(&self) -> bool

Check if a graph-native commit is due.

pub fn save( &mut self, store: &KanbanStore, relations: &RelationsStore, ) -> Result<SaveMetrics>

Save the kanban state to Parquet atomically.

Delegates to persist::save_all() which uses arrow-graph-git::save_named_batches() for crash-safe atomic writes with WAL protection.

pub fn git_backup(&mut self, item_count: usize) -> Result<GitBackupMetrics>

Create a graph-native commit for the audit trail.

Replaces shell git add + git commit with a CommitsTable entry persisted as JSON. History is queryable via commits().

pub fn load_commits(&mut self) -> Result<()>

Load commit history from disk (call after startup).

pub fn commits(&self) -> &CommitsTable

Get the commit history (graph-native audit trail).

pub fn check_wal_recovery(root: &Path) -> Result<bool>

Check for and recover from an incomplete save (WAL present on startup).

If a WAL file exists, the previous save was interrupted. The Parquet files may be in an inconsistent state. Since we use atomic file replacement (write .tmp then rename), the old files are still valid. Remove the WAL and proceed — the old state is correct.

pub fn shutdown( &mut self, store: &KanbanStore, relations: &RelationsStore, ) -> Result<()>

Graceful shutdown — save state before exit.

pub fn health( &self, store: &KanbanStore, relations: &RelationsStore, ) -> HealthMetrics

Get current health metrics.