Method durable

crates/engine/src/relational_db.rs:1926–1943

Create a [`TestDB`] which stores data in a local commitlog. Note that flushing the log is an asynchronous process. [`Self::reopen`] ensures all data has been flushed to disk before re-opening the database.

()

        /// ensures all data has been flushed to disk before re-opening the
        /// database.
        pub fn durable() -> Result<Self, DBError> {
            let dir = TempReplicaDir::new()?;
            let rt = TokioRuntimeBuilder::new_multi_thread().enable_all().build()?;
            // Enter the runtime so that `Self::durable_internal` can spawn a `SnapshotWorker`.
            let _rt = rt.enter();
            let (db, durability) = Self::durable_internal(&dir, rt.handle().clone(), true)?;
            let durable = DurableState {
                durability,
                rt,
                replica_dir: dir.into(),
            };

            Ok(Self {
                db: Arc::new(db),
                durable: Some(durable),
                want_snapshot_repo: true,
            })
        }

        pub fn durable_without_snapshot_repo() -> Result<Self, DBError> {
            let dir = TempReplicaDir::new()?;