pub fn register_raw_updates(
        &self,
        wtxn: &mut heed::RwTxn,
        update: &UpdateStatus,
        index_uuid: Uuid,
    ) -> heed::Result<()> {
        match update {
            UpdateStatus::Enqueued(enqueued) => {
                let (global_id, _update_id) = self.next_update_id(wtxn, index_uuid)?;
                self.pending_queue.remap_key_type::<PendingKeyCodec>().put(
                    wtxn,
                    &(global_id, index_uuid, enqueued.id()),
                    &enqueued,
                )?;
            }
            _ => {
                let _update_id = self.next_update_id_raw(wtxn, index_uuid)?;
                self.updates
                    .put(wtxn, &(index_uuid, update.id()), &update)?;
            }
        }
        Ok(())
    }
/// Push already processed update in the UpdateStore without triggering the notification
/// process. This is useful for the dumps.
Push already processed update in the UpdateStore without triggering the notification
process. This is useful for the dumps.
Push already processed update in the UpdateStore without triggering the notification process . This is useful for the dumps .
pub fn register_raw_updates(
        &self,
        wtxn: &mut heed::RwTxn,
        update: &UpdateStatus,
        index_uuid: Uuid,
    ) -> heed::Result<()> {
        match update {
            UpdateStatus::Enqueued(enqueued) => {
                let (global_id, _update_id) = self.next_update_id(wtxn, index_uuid)?;
                self.pending_queue.remap_key_type::<PendingKeyCodec>().put(
                    wtxn,
                    &(global_id, index_uuid, enqueued.id()),
                    &enqueued,
                )?;
            }
            _ => {
                let _update_id = self.next_update_id_raw(wtxn, index_uuid)?;
                self.updates
                    .put(wtxn, &(index_uuid, update.id()), &update)?;
            }
        }
        Ok(())
    }
pub fn register_raw_updates ( & self , wtxn : & mut heed :: RwTxn , update : & UpdateStatus , index_uuid : Uuid , ) -> heed :: Result < ( ) > { match update { UpdateStatus :: Enqueued ( enqueued ) => { let ( global_id , _update_id ) = self . next_update_id ( wtxn , index_uuid ) ? ; self . pending_queue . remap_key_type :: < PendingKeyCodec > ( ) . put ( wtxn , & ( global_id , index_uuid , enqueued . id ( ) ) , & enqueued , ) ? ; } _ => { let _update_id = self . next_update_id_raw ( wtxn , index_uuid ) ? ; self . updates . put ( wtxn , & ( index_uuid , update . id ( ) ) , & update ) ? ; } } Ok ( ( ) ) }
Push already processed update in the UpdateStore without triggering the notification
process.
Push already processed update in the UpdateStore without triggering the notification process .
&self
wtxn
&mut heed::RwTxn
update
&UpdateStatus
index_uuid
Uuid
&self
wtxn
&mut heed::RwTxn
update
&UpdateStatus
index_uuid
Uuid