Struct EventLog 

pub struct EventLog { /* private fields */ }

Implementations

impl EventLog

pub fn new(pool: SqlitePool) -> Self

pub async fn append(&self, event: &mut EventRecord) -> KernelResult<()>

Appends an event, assigning a monotonic log_index and computing event_hash in place. Wraps in an internal transaction for atomicity.

pub async fn append_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, event: &mut EventRecord, ) -> KernelResult<()>

pub async fn list_recent(&self, limit: i64) -> KernelResult<Vec<EventRecord>>

pub async fn list_by_actor( &self, actor_id: &str, limit: i64, ) -> KernelResult<Vec<EventRecord>>

List events filtered by actor_id, ordered by log_index descending.

pub async fn query( &self, actor_id: Option<&str>, before_index: Option<i64>, after_index: Option<i64>, limit: i64, ) -> KernelResult<Vec<EventRecord>>

General-purpose event query with composable filters.

All filter fields are optional and combined with AND logic:

• actor_id: restrict to a specific actor
• before_index: only events with log_index < value (for backward pagination)
• after_index: only events with log_index > value (for forward pagination)
• limit: max results (clamped by caller; this method does not clamp)

Returns events ordered by log_index descending (newest first).

pub async fn count(&self) -> KernelResult<i64>

Trait Implementations

impl Clone for EventLog

fn clone(&self) -> EventLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.