Struct SnapshotService 

pub struct SnapshotService { /* private fields */ }

Owns the store plus everything needed to dump and restore state. Created by Runtime::run when snapshots are enabled.

Implementations

impl SnapshotService

pub async fn initialize( config: SnapshotConfig, spec: &Spec, entity_cache: EntityCache, view_index: &ViewIndex, _mutations_tx: Sender<MutationBatch>, ) -> Result<Arc<Self>>

Build the store, then attempt a restore (any failure logs a warning and cold-starts — restore problems must never block startup).

pub fn config(&self) -> &SnapshotConfig

pub fn runtime(&self) -> SnapshotRuntime

Return the per-server coordination handle that must be shared with the matching parser, projector, and readiness endpoint.

pub fn spawn(self: &Arc<Self>) -> JoinHandle<()>

Spawn the periodic snapshot task.

pub async fn snapshot_now(&self, trigger: SnapshotTrigger) -> Result<bool>

Run one snapshot cycle. Returns Ok(false) when skipped (no VM registered yet, or too few mutations since the last snapshot).