Struct AppliedSet 

pub struct AppliedSet {
    pub last_applied: BTreeMap<String, u64>,
    pub schema_version: u32,
}

Per-origin “highest applied HLC” tracker.

Fields

last_applied: BTreeMap<String, u64>

node_id (as a UUID hyphenated string) → highest hlc applied from that origin.

schema_version: u32

On-disk schema version of this struct (currently 1).

Implementations

impl AppliedSet

pub fn load(data_dir: &Path) -> Result<Self>

Loads the AppliedSet from <data_dir>/_replication/state.json, returning AppliedSet::default() when the file is missing.

pub fn save(&self, data_dir: &Path) -> Result<()>

Persists the AppliedSet to <data_dir>/_replication/state.json. Creates the directory if it doesn’t exist. The write is best-effort atomic via tmp + rename.

pub fn observe(&mut self, origin: u128, hlc: Hlc) -> ObserveOutcome

Records that we have applied an HLC from a given origin. Returns New if hlc advanced our high-water mark, AlreadyApplied otherwise (idempotent replay).

pub fn high_water(&self, origin: u128) -> Hlc

Returns the highest-applied HLC for origin, or Hlc::ZERO if we have never observed it.

Trait Implementations

impl Clone for AppliedSet

fn clone(&self) -> AppliedSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AppliedSet

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

Formats the value using the given formatter.

impl Default for AppliedSet

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AppliedSet

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AppliedSet

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.