Struct StoreEventDurability 

pub struct StoreEventDurability { /* private fields */ }

REL-14 (#249): concrete EventDurability backed by the SQLite StateStore. The dataplane owns both the store and the event bus, so it provides this adapter to the events module’s trait. The implementation is best-effort: a SQLite error is logged but does not block the emit path (the event still goes to the in-memory channel).

Implementations

impl StoreEventDurability

pub fn new(store: Arc<StateStore>) -> Self

Trait Implementations

impl Debug for StoreEventDurability

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

Formats the value using the given formatter.

impl EventDurability for StoreEventDurability

fn append(&self, event: &Event)

Persist a critical event to the WAL before emission. Called synchronously on the emit path; a failure is logged but does not block the emit (best-effort durability).

fn ack(&self, id: &str)

Mark an event as delivered (acked). Called by the webhook deliverer after the event has been dispatched to matching targets.

fn unacked(&self) -> Vec<Event>

Load all un-acked events from the WAL, ordered oldest-first. Called on startup to replay events that were not delivered before the previous process exited.