Struct Watermark 

pub struct Watermark {
    pub last_rowid: i64,
}

Persisted high-water ROWID for the inbound reader.

Serialized as {"last_rowid": <i64>} JSON, written atomically (temp + rename) under an INJECTABLE base dir so tests never touch the real ~/.car/.

Fields

last_rowid: i64

Implementations

impl Watermark

pub fn new(last_rowid: i64) -> Self

pub fn path_in(base_dir: &Path) -> PathBuf

Resolve the watermark JSON file inside base_dir (the ~/.car/ equivalent). The file lives at <base_dir>/messages-inbound-watermark.json.

pub fn load(base_dir: &Path) -> Result<Option<Self>, IntegrationError>

Load the watermark from disk. Returns Ok(None) when no file exists (fresh boot — caller seeds to MAX(ROWID)).

pub fn persist(&self, base_dir: &Path) -> Result<(), IntegrationError>

Persist the watermark atomically under base_dir.

Mirrors the car-server-core atomic_write_sync / supervisor.rs write_json_atomic shape — create_dir_all + write a unique temp file in the same dir + rename(2) (atomic on the same filesystem). NOT a plain non-atomic fs::write; NOT Swift UserDefaults. car-server-core’s atomic_write_sync is private to that crate and not reachable from car-integrations, so the shape is mirrored locally per the plan.

Trait Implementations

impl Clone for Watermark

fn clone(&self) -> Watermark

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Watermark

impl Debug for Watermark

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Watermark

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Watermark

impl PartialEq for Watermark

fn eq(&self, other: &Watermark) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Watermark

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Watermark