Struct ProjectionManager 

pub struct ProjectionManager { /* private fields */ }

Projection manager handles multiple projections

Implementations

impl ProjectionManager

pub fn new() -> Self

pub fn with_metrics(metrics: Arc<MetricsRegistry>) -> Self

pub fn with_checkpoint_config( self, config: CheckpointConfig, dir: PathBuf, ) -> Self

Set checkpoint configuration and directory.

pub fn register(&mut self, projection: Arc<dyn Projection>)

Register a new projection. If a checkpoint file exists on disk, restore from it so that only events newer than last_event_timestamp need to be replayed.

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

Process an event through all projections. Events at or before a projection’s restored checkpoint timestamp are skipped (they were already folded into the restored state).

pub fn checkpoint_all(&self) -> Result<()>

Checkpoint all projections that support snapshotting.

pub fn get_projection(&self, name: &str) -> Option<Arc<dyn Projection>>

Get a projection by name

pub fn list_projections(&self) -> Vec<(String, Arc<dyn Projection>)>

List all projections

pub fn clear_all(&self)

Clear all projections

pub fn restored_up_to(&self, name: &str) -> Option<DateTime<Utc>>

Return the restored-up-to timestamp for a given projection (if any). Useful in tests to verify that a checkpoint was restored.

Trait Implementations

impl Default for ProjectionManager

fn default() -> Self

Returns the “default value” for a type.