Struct MaterializedView

pub struct MaterializedView<S, E, Repository, View, Error>
where
    Repository: ViewStateRepository<E, S, Error>,
    View: ViewStateComputation<E, S>,
{ /* private fields */ }

Materialized View.

It is using a View / ViewStateComputation to compute new state based on the current state and the event. It is using a ViewStateRepository to fetch the current state and to save the new state.

Generic parameters:

• S - State
• E - Event
• Repository - View State repository
• View - View
• Error - Error

Implementations

impl<S, E, Repository, View, Error> MaterializedView<S, E, Repository, View, Error>

where Repository: ViewStateRepository<E, S, Error> + Sync, View: ViewStateComputation<E, S> + Sync, E: Sync, S: Sync, Error: Sync,

pub fn new(repository: Repository, view: View) -> Self

Creates a new instance of MaterializedView.

pub async fn handle(&self, event: &E) -> Result<S, Error>

Handles the event by fetching the state from the repository, computing new state based on the current state and the event, and saving the new state to the repository.

Trait Implementations

impl<S, E, Repository, View, Error> ViewStateComputation<E, S> for MaterializedView<S, E, Repository, View, Error>

where Repository: ViewStateRepository<E, S, Error>, View: ViewStateComputation<E, S>,

fn compute_new_state(&self, current_state: Option<S>, events: &[&E]) -> S

Computes new state based on the current state and the events.

impl<S, E, Repository, View, Error> ViewStateRepository<E, S, Error> for MaterializedView<S, E, Repository, View, Error>

where Repository: ViewStateRepository<E, S, Error> + Sync, View: ViewStateComputation<E, S> + Sync, E: Sync, S: Sync, Error: Sync,

async fn fetch_state(&self, event: &E) -> Result<Option<S>, Error>

Fetches current state, based on the event.

async fn save(&self, state: &S) -> Result<S, Error>

Saves the new state.