atomr-patterns 0.9.2

DDD/CQRS pattern library for atomr — aggregates, readers, projections, sagas, outbox, ACL.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! [`Repository`] — public dispatch surface for commands.
//!
//! The `Repository` is what application code holds. It hides the
//! routing (which actor gets the command, whether it's local or
//! sharded) and surfaces a clean async fn the user invokes per command.

use async_trait::async_trait;

use atomr_persistence::Eventsourced;

use crate::{AggregateRoot, PatternError};

/// Send commands to an aggregate; receive the events that resulted (or
/// the typed domain error if the command was rejected).
///
/// Implementations are produced by `CqrsPattern::builder().build().materialize()`
/// — users don't normally implement this trait by hand.
#[async_trait]
pub trait Repository: Send + Sync {
    /// The aggregate this repository routes commands to.
    type Aggregate: AggregateRoot;

    /// Dispatch a command. Returns the events produced (and persisted)
    /// on success, or a [`PatternError`] wrapping the domain error / a
    /// transport / journal failure.
    async fn send(
        &self,
        cmd: <Self::Aggregate as Eventsourced>::Command,
    ) -> Result<
        Vec<<Self::Aggregate as Eventsourced>::Event>,
        PatternError<<Self::Aggregate as Eventsourced>::Error>,
    >;
}