Method new

src/models/collection_transaction.rs:155–170

(collection: &Collection, config: &Config)

impl ExplicitTransaction {
    pub fn new(collection: &Collection, config: &Config) -> Result<Self, WaCustomError> {
        let mut current_implicit_txn = collection.current_implicit_transaction.write();
        mem::take(&mut *current_implicit_txn).pre_commit(collection, config)?;
        let id = ExplicitTransactionID(random());
        collection.transaction_status_map.insert(
            *collection.current_version.read(),
            &id,
            RwLock::new(TransactionStatus::NotStarted {
                last_updated: Utc::now(),
            }),
        );
        Ok(Self {
            id,
            wal: WALFile::new()?,
        })
    }

    pub fn pre_commit(
        self,