abstract class Movie::Persistence::AbstractTransactionalProjectionRunner

• Movie::Persistence::AbstractTransactionalProjectionRunner
• Reference
• Object

Overview

Common offset/checkpoint loop for transactional SQL projection sources. Source-specific subclasses only provide bounded envelopes and dispatch.

Direct Known Subclasses

• Movie::Persistence::TransactionalDurableStateProjectionRunner
• Movie::Persistence::TransactionalProjectionRunner

Defined in:

movie/persistence/projection_runner.cr

Constructors

• .new(database : Movie::DatabaseExtension, id : ProjectionId, page_size : Int32)

Instance Method Summary

• #id : ProjectionId
• #run_once(progress : ProjectionProgressHandler | Nil = nil) : ProjectionRunResult

Constructor Detail

Instance Method Detail