Struct KvMirror 

pub struct KvMirror {
    pub live: BTreeMap<String, KvEntry>,
    pub snapshot_done: bool,
}

The complete watcher obligation: apply updates, read live.

One mirror per subscription; a re-established connection means a new KV_OPEN, a new kv_id, and a fresh mirror (nothing survives, the fs-family rule).

Fields

live: BTreeMap<String, KvEntry>

snapshot_done: bool

True once the initial snapshot is complete (KV_UPDATE_SNAPSHOT_END).

Implementations

impl KvMirror

pub fn new() -> Self

pub fn apply_update(&mut self, msg: &[u8]) -> Option<u32>

Apply one KV_UPDATE message (starting at the opcode byte). Returns Some(update_id) to acknowledge, None if malformed.

Trait Implementations

impl Debug for KvMirror

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for KvMirror

fn default() -> KvMirror

Returns the “default value” for a type.