struct
Movie::Persistence::CommitProjection
- Movie::Persistence::CommitProjection
- Struct
- Value
- Object
Included Modules
Defined in:
movie/persistence/protocol.crConstructors
Instance Method Summary
- #envelope : ProjectionEnvelope
- #execute(connection : BackendConnection) : ProjectionCommitResult
- #expected_offset : Int64
- #handler : ProjectionHandler
- #id : ProjectionId
- #projection : String
- #source : ProjectionSource
Instance methods inherited from module Movie::Persistence::RetryableConnectionRequest(Movie::Persistence::ProjectionCommitResult)
retryable_after_connection_loss? : Bool
retryable_after_connection_loss?
Instance methods inherited from module Movie::Persistence::TypedConnectionRequest(Movie::Persistence::ProjectionCommitResult)
dispatch(worker : ConnectionWorker, sender : Movie::ActorRefBase | Nil) : Nil
dispatch,
execute(connection : BackendConnection) : T
execute,
retryable_after_connection_loss? : Bool
retryable_after_connection_loss?
Instance methods inherited from module Movie::Persistence::ConnectionRequest
dispatch(worker : ConnectionWorker, sender : Movie::ActorRefBase | Nil) : Nil
dispatch
Constructor Detail
def self.new(projection : String, expected_offset : Int64, envelope : ProjectionEnvelope, handler : ProjectionHandler, source : ProjectionSource)
#