Struct confitul::MemoryStore

pub struct MemoryStore<T, C>where
    T: Clone,
    C: Eq + Hash + Clone,{ /* private fields */ }

Implementations

impl<T, C> MemoryStore<T, C>where
    T: Clone,
    C: Eq + Hash + Clone,

pub fn new() -> Self

pub fn data_len(&self) -> usize

pub fn data_capacity(&self) -> usize

pub fn queue_len(&self) -> usize

pub fn queue_capacity(&self) -> usize

pub fn assign_data(&self, key: CKey, entry: Entry<T, C>) -> Option<Conflict<T, C>>

Examples found in repository

src/memory_store.rs (lines 80-86)

    pub fn assign_kill(&self, key: CKey, version: VClock<C>) -> Option<Conflict<T, C>> {
        self.assign_data(
            key,
            Entry {
                value: None,
                version,
            },
        )
    }

    pub fn suggest_data(&self, key: CKey, entry: Entry<T, C>) {
        if let Some(conflict) = self.assign_data(key, entry) {
            self.push_queue(conflict);
        }
    }

pub fn assign_kill(&self, key: CKey, version: VClock<C>) -> Option<Conflict<T, C>>

Examples found in repository

src/memory_store.rs (line 96)

    pub fn suggest_kill(&self, key: CKey, version: VClock<C>) {
        if let Some(conflict) = self.assign_kill(key, version) {
            self.push_queue(conflict);
        }
    }

pub fn suggest_data(&self, key: CKey, entry: Entry<T, C>)

pub fn suggest_kill(&self, key: CKey, version: VClock<C>)

pub fn query_data(&self, key: CKey) -> Option<Entry<T, C>>

pub fn push_queue(&self, conflict: Conflict<T, C>)

Examples found in repository

src/memory_store.rs (line 91)

    pub fn suggest_data(&self, key: CKey, entry: Entry<T, C>) {
        if let Some(conflict) = self.assign_data(key, entry) {
            self.push_queue(conflict);
        }
    }

    pub fn suggest_kill(&self, key: CKey, version: VClock<C>) {
        if let Some(conflict) = self.assign_kill(key, version) {
            self.push_queue(conflict);
        }
    }

pub fn pop_queue(&self) -> Option<Conflict<T, C>>

pub fn data_iter(&self) -> MemoryStoreDataIterator<T, C>