Struct SqlHlcStorage 

pub struct SqlHlcStorage { /* private fields */ }

Persistence for the clock register, scoped to a table-name prefix.

Implementations

impl SqlHlcStorage

pub async fn open(db: &dyn Db, prefix: &str) -> Result<Self, DbError>

Ensure the clock register exists and read its seed — the clock’s only read, done once at startup. prefix namespaces the table so multiple stores can share a database.

Trait Implementations

impl HlcStorage for SqlHlcStorage

fn load(&self) -> Result<Option<u64>, Self::Error>

Return the seed cached at open. No I/O — the read already happened.

fn save(&self, sink: &mut Self::Sink, raw: u64) -> Result<(), Self::Error>

Enqueue the clock-state upsert into sink. Durable when the caller commits the sink. The packed u64 occupies the full 64-bit width (48-bit millis << 16 | 16-bit counter), so DbValue::from_u64 rejects a value past i64::MAX rather than wrap it negative — which would also break the signed MAX-guard merge. The real clock stays far below that bound (millis below 2^47, ~year 6400).

type Error = DbError

Backend error type surfaced through the service’s results.

type Sink = dyn DbBatch

The transaction/batch save enqueues into (e.g. a DbBatch). ?Sized so a backend can use a trait object (dyn DbBatch).