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 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

pub fn shutdown(&self)

Signal graceful shutdown

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

Check lag (events behind)