Struct DeliveryIndex 

pub struct DeliveryIndex { /* private fields */ }

Implementations

impl DeliveryIndex

pub fn open(path: impl AsRef<Path>) -> Result<Self, DeliveryError>

Opens (creating if needed) the index at path, applying pending schema migrations (shared with the event log — same database).

Errors

Returns DeliveryError on any SQLite or migration failure.

pub fn decide( &self, request: &DeliveryRequest<'_>, ) -> Result<Delivery, DeliveryError>

Advances the scope’s emission counter and decides how to emit slice_key, recording the delivery only for complete emissions.

Errors

Returns DeliveryError::Storage on any SQLite failure.

pub fn clear(&self, session: &SessionId, cwd: &str) -> Result<(), DeliveryError>

Clears one (session, cwd) scope — the compaction hook (spec §7.3: the next reference re-emits in full).

Errors

Returns DeliveryError::Storage on any SQLite failure.