Method update_version_metadata

src/models/versioning.rs:282–306

(
        &self,
        version: VersionNumber,
        records_upserted: u32,
        records_deleted: u32,
        total_operations: u32,
    )

    }

    pub fn update_version_metadata(
        &self,
        version: VersionNumber,
        records_upserted: u32,
        records_deleted: u32,
        total_operations: u32,
    ) -> lmdb::Result<()> {
        let mut txn = self.env.begin_rw_txn()?;
        let version_key = key!(v:version);

        let bytes = txn.get(self.db, &version_key)?;
        let mut version_info = VersionInfo::deserialize(bytes).unwrap();
        version_info.records_upserted = records_upserted;
        version_info.records_deleted = records_deleted;
        version_info.total_operations = total_operations;
        txn.put(
            self.db,
            &version_key,
            &version_info.serialize(),
            WriteFlags::empty(),
        )?;

        txn.commit()?;
        Ok(())
    }

    pub fn get_version(&self, version: VersionNumber) -> lmdb::Result<VersionInfo> {
        let txn = self.env.begin_ro_txn()?;