class
Movie::Persistence::TransactionalProjectionRunner
- Movie::Persistence::TransactionalProjectionRunner
- Movie::Persistence::AbstractTransactionalProjectionRunner
- Reference
- Object
Overview
Runs bounded journal pages and commits each handler invocation atomically with its checkpoint.
Defined in:
movie/persistence/projection_runner.crConstructors
Instance methods inherited from class Movie::Persistence::AbstractTransactionalProjectionRunner
id : ProjectionId
id,
run_once(progress : ProjectionProgressHandler | Nil = nil) : ProjectionRunResult
run_once
Constructor methods inherited from class Movie::Persistence::AbstractTransactionalProjectionRunner
new(database : Movie::DatabaseExtension, id : ProjectionId, page_size : Int32)
new
Constructor Detail
def self.new(database : Movie::DatabaseExtension, projection : EventProjection, page_size : Int32 = 100, persistence_id : String | Nil = nil)
#