Method pre_commit

src/models/collection_transaction.rs:42–60

(self, collection: &Collection, config: &Config)

    }

    pub fn pre_commit(self, collection: &Collection, config: &Config) -> Result<(), WaCustomError> {
        if let Some(hnsw_index) = &*collection.hnsw_index.read() {
            hnsw_index.pre_commit_transaction(collection, self.version, config)?;
        }
        if let Some(inverted_index) = &*collection.inverted_index.read() {
            inverted_index.pre_commit_transaction(collection, self.version, config)?;
        }
        if let Some(tf_idf_index) = &*collection.tf_idf_index.read() {
            tf_idf_index.pre_commit_transaction(collection, self.version, config)?;
        }
        if let Some(key_value_index) = &*collection.key_value_index.read() {
            key_value_index.pre_commit_transaction(collection, self.version, config)?;
        }
        if let Some(usv_index) = &*collection.usv_index.read() {
            usv_index.pre_commit_transaction(collection, self.version, config)?;
        }
        collection.flush()?;
        Ok(())
    }
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]