Struct PrefixState 

pub struct PrefixState {
    pub prefix: String,
    pub latest_event_id: AtomicI64,
    pub ready: AtomicBool,
    pub notify: Sender<()>,
    /* private fields */
}

State for one watched prefix: the cache subtree, the watch cursor, and a notifier that wakes long-pollers whenever anything under this prefix changes.

Fields

prefix: String

latest_event_id: AtomicI64

ready: AtomicBool

notify: Sender<()>

Sends a () whenever any item under this prefix changes (set, delete, or snapshot replace). Long-pollers subscribe to this and re-check after each notification.

Implementations

impl PrefixState

pub fn new(prefix: String) -> Self

pub fn get(&self, key: &str) -> Option<CacheEntry>

pub fn list(&self) -> Vec<(String, CacheEntry)>

pub fn upsert(&self, key: String, value: Value, event_id: i64)

pub fn remove(&self, key: &str, event_id: i64)

pub fn replace_snapshot( &self, items: HashMap<String, CacheEntry>, latest_event_id: i64, )