Struct ProjectionRegistry 

pub struct ProjectionRegistry<E: Event, B: EventStoreBackend<E>> { /* private fields */ }

Available on crate feature cqrs only.

Projection Registry for managing multiple projections

Implementations

impl<E: Event, B: EventStoreBackend<E>> ProjectionRegistry<E, B>

pub fn new(event_store: EventStore<E, B>) -> Self

Create a new projection registry

pub async fn register<P: Projection<Event = E> + 'static>( &self, name: impl Into<String>, projection: P, )

Register a projection with automatic event subscription

pub async fn get<P: Projection<Event = E> + 'static>( &self, _name: &str, ) -> Option<Arc<RwLock<P>>>

Get a projection by name

pub async fn rebuild(&self, name: &str) -> Result<(), String>

Rebuild a specific projection from scratch

pub async fn rebuild_all(&self) -> Result<(), String>

Rebuild all projections from scratch

pub async fn get_metadata(&self, name: &str) -> Option<ProjectionMetadata>

Get metadata for a projection

pub async fn get_all_metadata(&self) -> Vec<ProjectionMetadata>

Get metadata for all projections

pub async fn start_subscription(&self) -> Result<(), String>

Subscribe projections to new events

pub async fn count(&self) -> usize

Get number of registered projections

Trait Implementations

impl<E: Event, B: EventStoreBackend<E>> Clone for ProjectionRegistry<E, B>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.