pub fn register_update(
        &self,
        meta: UpdateMeta,
        content: Option<Uuid>,
        index_uuid: Uuid,
    ) -> heed::Result<Enqueued> {
        let mut txn = self.env.write_txn()?;

        let (global_id, update_id) = self.next_update_id(&mut txn, index_uuid)?;
        let meta = Enqueued::new(meta, update_id, content);

        self.pending_queue
            .put(&mut txn, &(global_id, index_uuid, update_id), &meta)?;

        txn.commit()?;

        self.notification_sender
            .blocking_send(())
            .expect("Update store loop exited.");
        Ok(meta)
    }
/// Registers the update content in the pending store and the meta
/// into the pending-meta store. Returns the new unique update id.
Registers the update content in the pending store and the meta
into the pending-meta store. Returns the new unique update id.
Registers the update content in the pending store and the meta into the pending - meta store . Returns the new unique update id .
pub fn register_update(
        &self,
        meta: UpdateMeta,
        content: Option<Uuid>,
        index_uuid: Uuid,
    ) -> heed::Result<Enqueued> {
        let mut txn = self.env.write_txn()?;
        let (global_id, update_id) = self.next_update_id(&mut txn, index_uuid)?;
        let meta = Enqueued::new(meta, update_id, content);
        self.pending_queue
            .put(&mut txn, &(global_id, index_uuid, update_id), &meta)?;
        txn.commit()?;
        self.notification_sender
            .blocking_send(())
            .expect("Update store loop exited.");
        Ok(meta)
    }
pub fn register_update ( & self , meta : UpdateMeta , content : Option < Uuid > , index_uuid : Uuid , ) -> heed :: Result < Enqueued > { let mut txn = self . env . write_txn ( ) ? ; let ( global_id , update_id ) = self . next_update_id ( & mut txn , index_uuid ) ? ; let meta = Enqueued :: new ( meta , update_id , content ) ; self . pending_queue . put ( & mut txn , & ( global_id , index_uuid , update_id ) , & meta ) ? ; txn . commit ( ) ? ; self . notification_sender . blocking_send ( ( ) ) . expect ( " " ) ; Ok ( meta ) }
Registers the update content in the pending store and the meta
into the pending-meta store.
Registers the update content in the pending store and the meta into the pending - meta store .
&self
meta
UpdateMeta
content
Option<Uuid>
index_uuid
Uuid
&self
meta
UpdateMeta
content
Option<Uuid>
index_uuid
Uuid