Struct Capability 

pub struct Capability { /* private fields */ }

Implementations

impl Capability

pub fn insert<T: Serialize>(&self, value: T) -> Result<String>

pub fn insert_with_key<T: Serialize>(&self, key: &str, value: T) -> Result<()>

pub fn update<T: Serialize>(&self, key: &str, value: T) -> Result<()>

pub fn delete(&self, key: &str) -> Result<()>

pub fn get<T: DeserializeOwned>(&self, key: &str) -> Result<Option<T>>

pub fn find<T, F>(&self, predicate: F) -> Result<Vec<T>>

where T: DeserializeOwned, F: Fn(&T) -> bool,

pub async fn live_find<T, F>( &self, predicate: F, ) -> Result<LiveCapabilitySubscription<T>>

where T: DeserializeOwned + Send + Sync + 'static, F: Fn(&T) -> bool + Send + Sync + 'static,

Creates a live query subscription scoped to this capability.

The subscription returns initial matching results from this capability only, and streams updates whenever records within this capability matching the predicate are inserted or updated.

Example

use feltdb::open;
let db = open("app.data")?;
let users = db.capability("users");
let mut subscription = users.live_find::<User, _>(|u| u.active).await?;
let initial_users = subscription.initial_results();

while let Some(users) = subscription.next().await {
    println!("Active users: {:?}", users);
}

Trait Implementations

impl Clone for Capability

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.