Struct EventLog 

pub struct EventLog { /* private fields */ }

Sqlite-backed historical event store. Wraps a [Connection] in a Mutex so it can be shared across the connector + axum tasks without unsafe juggling. Reads are fast; writes serialise.

Implementations

impl EventLog

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

Open or create a sqlite database at path. Runs the schema migration on first call (idempotent).

pub fn open_in_memory() -> Result<Self>

Open an in-memory database — used by tests.

pub fn path(&self) -> &Path

Path the log was opened against.

pub fn append(&self, event: &ObservedEvent) -> Result<i64>

Append an event. Returns the row id.

pub fn query_since( &self, topic: &str, since_ts: &str, limit: usize, ) -> Result<Vec<ObservedEvent>>

Read events for a topic since since_ts (ISO 8601). Newest-last.

pub fn prune(&self, policy: &RetentionPolicy) -> Result<usize>

Drop events older than the topic’s retention cutoff. Returns total rows deleted across all topics.

pub fn high_water(&self) -> Result<Option<(u64, u64)>>

The largest (cursor, reset_epoch) ever logged, or None for an empty log. A restarting connector seeds above both so its cursors and epoch never fall back below what a client may still hold, even when the host clock came up behind the previous run.

pub fn count(&self) -> Result<usize>

Total row count. Used by tests + diagnostics.

Trait Implementations

impl Debug for EventLog

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

Formats the value using the given formatter.