Struct Projector 

pub struct Projector<'conn> { /* private fields */ }

Replays events into the SQLite projection.

Create a Projector with a connection, then call [project_event] for each event or [project_batch] for a slice.

Implementations

impl<'conn> Projector<'conn>

pub fn new(conn: &'conn Connection) -> Self

Create a new projector backed by the given connection.

Ensures the projected_events tracking table exists before any projection work is attempted.

pub fn project_batch(&self, events: &[Event]) -> Result<ProjectionStats>

Project a batch of events, returning aggregate statistics.

Events are applied inside a single transaction for performance. Duplicate events (same event_hash) are silently skipped.

Errors

Returns an error if the transaction fails to commit. Individual event projection errors are counted in stats.errors but do not abort the batch.

pub fn project_event(&self, event: &Event) -> Result<bool>

Project a single event (outside of any managed transaction).

Returns true if the event was projected, false if it was a duplicate.

Errors

Returns an error if the projection fails.