Skip to main content

WindowStore

reifydb_core::window::store

Trait WindowStore 

Source 
pub trait WindowStore {

Show 15 methods    // Required methods
    fn state_get<V: DeserializeOwned>(
        &mut self,
        key: &EncodedKey,
    ) -> Result<Option<V>>;
    fn state_get_many_visit<V: DeserializeOwned>(
        &mut self,
        keys: &[EncodedKey],
        visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
    ) -> Result<()>;
    fn state_set<V: Serialize>(
        &mut self,
        key: &EncodedKey,
        value: &V,
    ) -> Result<()>;
    fn state_remove(&mut self, key: &EncodedKey) -> Result<()>;
    fn state_drop(&mut self, key: &EncodedKey) -> Result<()>;
    fn internal_get<V: DeserializeOwned>(
        &mut self,
        key: &EncodedKey,
    ) -> Result<Option<V>>;
    fn internal_get_many_visit<V: DeserializeOwned>(
        &mut self,
        keys: &[EncodedKey],
        visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
    ) -> Result<()>;
    fn internal_set<V: Serialize>(
        &mut self,
        key: &EncodedKey,
        value: &V,
    ) -> Result<()>;
    fn internal_remove(&mut self, key: &EncodedKey) -> Result<()>;
    fn internal_drop(&mut self, key: &EncodedKey) -> Result<()>;
    fn internal_range_visit<V: DeserializeOwned>(
        &mut self,
        range: EncodedKeyRange,
        visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
    ) -> Result<()>;
    fn get_or_create_row_number(
        &mut self,
        key: &EncodedKey,
    ) -> Result<(RowNumber, bool)>;
    fn get_or_create_row_numbers(
        &mut self,
        keys: &[EncodedKey],
    ) -> Result<Vec<(RowNumber, bool)>>;
    fn allocate_row_numbers(&mut self, count: u64) -> Result<RowNumber>;
    fn clock_now_nanos(&self) -> u64;

}

Required Methods§

Source

fn state_get<V: DeserializeOwned>( &mut self, key: &EncodedKey, ) -> Result<Option<V>>

Source

fn state_get_many_visit<V: DeserializeOwned>( &mut self, keys: &[EncodedKey], visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>, ) -> Result<()>

Source

fn state_set<V: Serialize>(&mut self, key: &EncodedKey, value: &V) -> Result<()>

Source

fn state_remove(&mut self, key: &EncodedKey) -> Result<()>

Source

fn state_drop(&mut self, key: &EncodedKey) -> Result<()>

Source

fn internal_get<V: DeserializeOwned>( &mut self, key: &EncodedKey, ) -> Result<Option<V>>

Source

fn internal_get_many_visit<V: DeserializeOwned>( &mut self, keys: &[EncodedKey], visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>, ) -> Result<()>

Source

fn internal_set<V: Serialize>( &mut self, key: &EncodedKey, value: &V, ) -> Result<()>

Source

fn internal_remove(&mut self, key: &EncodedKey) -> Result<()>

Source

fn internal_drop(&mut self, key: &EncodedKey) -> Result<()>

Source

fn internal_range_visit<V: DeserializeOwned>( &mut self, range: EncodedKeyRange, visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>, ) -> Result<()>

Source

fn get_or_create_row_number( &mut self, key: &EncodedKey, ) -> Result<(RowNumber, bool)>

Source

fn get_or_create_row_numbers( &mut self, keys: &[EncodedKey], ) -> Result<Vec<(RowNumber, bool)>>

Source

fn allocate_row_numbers(&mut self, count: u64) -> Result<RowNumber>

Source

fn clock_now_nanos(&self) -> u64

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§