Struct darkbird::Storage

pub struct Storage<K, Doc: Document> { /* private fields */ }

Implementations

impl<K, Doc> Storage<K, Doc>where Doc: Serialize + DeserializeOwned + Clone + Send + 'static + Document, K: Serialize + DeserializeOwned + PartialOrd + Ord + PartialEq + Eq + Hash + Clone + Send + Sync + 'static,

pub async fn open<'a>(ops: Options<'a>) -> Result<Self, String>

pub async fn subscribe( &self, sender: Sender<Event<K, Doc>> ) -> Result<(), SessionResult>

subscribe to Reporter

pub async fn insert(&self, key: K, doc: Doc) -> Result<(), SessionResult>

insert to storage and persist to disk

pub async fn remove(&self, key: K) -> Result<(), SessionResult>

remove from storage and persist to disk

pub fn gets(&self, list: Vec<&K>) -> Vec<Ref<'_, K, Doc>>

gets documents

pub fn range( &self, field_name: &str, from: String, to: String ) -> Vec<Ref<'_, K, Doc>>

fetch document by range hash_index

pub fn lookup(&self, key: &K) -> Option<Ref<'_, K, Doc>>

lookup by key

pub fn lookup_by_index(&self, index_key: &str) -> Option<Ref<'_, K, Doc>>

lookup by hash_index

pub fn lookup_by_tag(&self, tag: &str) -> Vec<Ref<'_, K, Doc>>

lookup by tag

pub fn fetch_view(&self, view_name: &str) -> Vec<Ref<'_, K, Doc>>

fetch view

pub fn search(&self, text: String) -> Vec<Ref<'_, K, Doc>>

search by text

pub fn iter(&self) -> Iter<'_, K, Doc>

return Iter (Safe for mutation)

pub fn iter_index(&self) -> Iter<'_, String, K>

return Iter (Safe for mutation)

pub fn iter_tags(&self) -> Iter<'_, String, DashSet<K>>

return Iter (Safe for mutation)

pub fn collection_len(self) -> usize