Struct CommitBuilder 

pub struct CommitBuilder<'a, R> { /* private fields */ }

Builder for chaining multiple items into one transactional commit batch.

This is the single builder behind every commit entry point; staging state is the stream writes plus the [StagedOutboxSource]. aggregate hands back a StagedCommitBuilder, whose no-argument commit() finishes the same batch.

Implementations

impl<'a, R> CommitBuilder<'a, R>

pub fn new(repo: &'a R) -> Self

pub fn read_models(self, read_models: ReadModelWritePlanBuilder) -> Self

Add a read-model write plan builder to the commit.

pub fn outbox(self, msg: OutboxMessage) -> Self

Add an outbox message to the commit.

pub fn aggregate<A: Aggregate>( self, aggregate: &'a mut A, ) -> StagedCommitBuilder<'a, R>

Stage an aggregate and switch to a no-argument staged commit builder.

pub async fn commit<A: Aggregate + Send>( self, aggregate: &'a mut A, ) -> Result<(), RepositoryError>

where R: TransactionalCommit,

Commit all items plus the primary aggregate.

Sugar for aggregate(aggregate).commit().

pub async fn commit_many<'b, A: Aggregate + Send>( self, aggregates: &'a mut [&'b mut A], ) -> Result<(), RepositoryError>

where R: TransactionalCommit,

Commit multiple aggregates of the same type in one batch.

pub async fn commit_all(self) -> Result<(), RepositoryError>

where R: TransactionalCommit,

Commit without a primary aggregate.