Method remove

src/darkbird/storage.rs:179–224

(&self, key: K)

    /// remove from storage and persist to disk
    #[inline]
    pub async fn remove(&self, key: K) -> Result<(), SessionResult> {
        match self.collection.get(&key) {
            Some(doc) => {

                if !self.off_disk || !self.off_reporter {
                    let query = RQuery::<K, Doc>::Remove(key.clone());
        
                    if !self.off_disk {
                        if let Err(e) = self.wal_session.log(bincode::serialize(&query).unwrap()).await {
                            return Err(e);
                        }
                    }
        
                    if !self.off_reporter {
                        let _ = self.reporter_session.dispatch(Event::Query(query)).await;
                    }
                    
                }

                // remove from hash_index
                self.hash_index.remove(doc.value());

                // remove from view
                if let Some(view_name) = doc.filter() {
                    self.tag_index.remove_from_view(&view_name, &key)
                }

                // remove from invertedIndex
                if let Some(content) = doc.value().get_content() {
                    let _ = self.inverted_index.remove(key.clone(), content).await;
                }

                // remove from tag_index
                self.tag_index.remove(&key, doc.value());

                // remove to range
                self.range_index.remove(&key, doc.value());

            }
            None => return Ok(()),
        }

        self.collection.remove(&key);

        Ok(())
    }

    /// gets documents  
    #[inline]