Method persistence

crates/engine/src/persistence.rs:225–258

(&self, database: &Database, replica_id: u64)

#[async_trait]
impl PersistenceProvider for LocalPersistenceProvider {
    async fn persistence(&self, database: &Database, replica_id: u64) -> anyhow::Result<Persistence> {
        let database_identity = database.database_identity;
        let replica_dir = self.data_dir.replica(replica_id);
        let snapshot_dir = replica_dir.snapshots();
        let runtime = Handle::tokio_current();

        let snapshot_worker = asyncify(&runtime, move || {
            relational_db::open_snapshot_repo(snapshot_dir, database_identity, replica_id)
        })
        .await
        .map(|repo| SnapshotWorker::new(repo, snapshot::Compression::Enabled, runtime.clone()))?;
        let (durability, disk_size) = relational_db::local_durability_with_options(
            replica_dir,
            runtime.clone(),
            Some(&snapshot_worker),
            self.durability.into_options(),
        )
        .await?;

        runtime.spawn(relational_db::snapshot_watching_commitlog_compressor(
            snapshot_worker.subscribe(),
            None,
            None,
            durability.clone(),
            runtime.clone(),
        ));

        Ok(Persistence {
            durability,
            disk_size,
            snapshots: Some(snapshot_worker),
            runtime,
        })
    }
}