Struct Projector 

pub struct Projector<C, P>
where
    C: CanonicalStore,
    P: ProjectionStore,
{ /* private fields */ }

Projector: consumes events from canonical store and applies to projection

Implementations

impl<C, P> Projector<C, P>

where C: CanonicalStore, P: ProjectionStore,

pub fn new( canonical: Arc<C>, projection: Arc<P>, config: ProjectorConfig, ) -> Self

pub fn with_event_notify(self, notify: Arc<Notify>) -> Self

Attach an event notification handle for push-based projection.

When set, run_continuous() awaits this notification instead of sleeping for poll_interval_ms when caught up, giving near-zero latency event processing with zero idle CPU usage.

pub fn run_once(&self) -> Result<ProjectorStats>

Run one iteration of the projector loop

pub async fn run_continuous(&self) -> Result<()>

Run the projector continuously until shutdown.

When an event_notify handle is set (via Self::with_event_notify), the projector awaits the notification instead of polling, giving near-zero-latency projection with zero CPU waste when idle. Falls back to poll_interval_ms sleep if no notifier is present.

pub fn shutdown(&self)

Signal graceful shutdown

pub fn get_lag(&self) -> Result<u64>

Check lag (events behind)