Method flush

src/models/wal.rs:154–171

(self, root_path: &Path, version: VersionNumber)

    }

    pub fn flush(self, root_path: &Path, version: VersionNumber) -> Result<(), BufIoError> {
        let cursor = self.bufman.open_cursor()?;
        self.bufman
            .update_u32_with_cursor(cursor, self.records_upserted.load(Ordering::Acquire))?;
        self.bufman
            .update_u32_with_cursor(cursor, self.records_deleted.load(Ordering::Acquire))?;
        self.bufman
            .update_u32_with_cursor(cursor, self.total_operations.load(Ordering::Acquire))?;
        self.bufman.close_cursor(cursor)?;
        let file_path: Arc<Path> = root_path.join(format!("{}.wal", *version)).into();

        let mut file = OpenOptions::new()
            .write(true)
            .create(true)
            .truncate(false)
            .open(&file_path)?;
        self.bufman.flush(&mut file)
    }

    pub fn append(&self, op: VectorOp) -> Result<(), BufIoError> {
        let mut buf = Vec::new();