Struct SnapshotManager 

pub struct SnapshotManager { /* private fields */ }

Manager for handling state snapshots.

Implementations

impl SnapshotManager

pub fn new(config: PersistenceConfig) -> Self

pub fn snapshot_path(&self) -> PathBuf

Get the path to the snapshot file.

pub fn legacy_profiles_path(&self) -> PathBuf

Get the path to the legacy profiles file (for migration).

pub fn is_enabled(&self) -> bool

Check if persistence is enabled.

pub fn start_background_saver<F>( self: Arc<Self>, fetch_snapshot: F, ) -> Result<()>

where F: Fn() -> WafSnapshot + Send + Sync + 'static,

Start the background saver task with unified snapshot.

Arguments

• fetch_snapshot - A closure that returns the current WAF state snapshot.

Returns

Ok(()) if the background saver started successfully, or an error if:

• Persistence is disabled (returns Ok with early return)
• Thread spawning failed

Errors

Returns io::Error if the background thread cannot be spawned.

pub fn save_snapshot(snapshot: &WafSnapshot, path: &Path) -> Result<()>

Save a unified snapshot to disk (Synchronous/Blocking).

Uses atomic write (temp file + rename) to prevent corruption.

pub fn load_snapshot(path: &Path) -> Result<Option<WafSnapshot>>

Load a unified snapshot from disk (Synchronous/Blocking).

pub fn load_on_startup(&self) -> Result<Option<WafSnapshot>>

Load snapshot on startup if configured.

Returns the loaded snapshot or None if loading is disabled or file doesn’t exist.

pub fn save_profiles(profiles: &[EndpointProfile], path: &Path) -> Result<()>

Save profiles to disk (Synchronous/Blocking). @deprecated Use save_snapshot instead.

pub fn load_profiles(path: &Path) -> Result<Vec<EndpointProfile>>

Load profiles from disk (Synchronous/Blocking). @deprecated Use load_snapshot instead.