class
Movie::Persistence::ConnectionActor
- Movie::Persistence::ConnectionActor
- Movie::AbstractBehavior(Movie::Persistence::AcknowledgeOutbox | Movie::Persistence::AcquireShardLease | Movie::Persistence::AppendEvents | Movie::Persistence::ClaimOutbox | Movie::Persistence::DbExec | Movie::Persistence::DbExecLastId | Movie::Persistence::DbQueryString | Movie::Persistence::DbQueryStrings | Movie::Persistence::DeleteEventsTo | Movie::Persistence::DeleteProjectionOffset | Movie::Persistence::DeleteSnapshot | Movie::Persistence::DeleteState | Movie::Persistence::EnsureEventStore | Movie::Persistence::EnsureStateStore | Movie::Persistence::GetSchemaVersion | Movie::Persistence::LoadEvents | Movie::Persistence::LoadProjectionOffset | Movie::Persistence::LoadSnapshot | Movie::Persistence::LoadState | Movie::Persistence::QueryEvents | Movie::Persistence::ReleaseOutbox | Movie::Persistence::ReleaseShardLease | Movie::Persistence::RenewShardLease | Movie::Persistence::RunMaintenance | Movie::Persistence::SaveProjectionOffset | Movie::Persistence::SaveSnapshot | Movie::Persistence::SaveState)
- Reference
- Object
Overview
Actor that owns one backend connection worker and executes requests sequentially without exposing SQL to persistence behaviors.
Defined in:
movie/persistence/storage.crConstructors
- .new(backend : Backend, queue_capacity : Int32 = 256, telemetry : Telemetry = Telemetry.new, resilience : ResiliencePolicy = ResiliencePolicy.disabled)
- .new(db_uri : String, queue_capacity : Int32 = 256)
Instance Method Summary
Instance methods inherited from class Movie::AbstractBehavior(Movie::Persistence::AcknowledgeOutbox | Movie::Persistence::AcquireShardLease | Movie::Persistence::AppendEvents | Movie::Persistence::ClaimOutbox | Movie::Persistence::DbExec | Movie::Persistence::DbExecLastId | Movie::Persistence::DbQueryString | Movie::Persistence::DbQueryStrings | Movie::Persistence::DeleteEventsTo | Movie::Persistence::DeleteProjectionOffset | Movie::Persistence::DeleteSnapshot | Movie::Persistence::DeleteState | Movie::Persistence::EnsureEventStore | Movie::Persistence::EnsureStateStore | Movie::Persistence::GetSchemaVersion | Movie::Persistence::LoadEvents | Movie::Persistence::LoadProjectionOffset | Movie::Persistence::LoadSnapshot | Movie::Persistence::LoadState | Movie::Persistence::QueryEvents | Movie::Persistence::ReleaseOutbox | Movie::Persistence::ReleaseShardLease | Movie::Persistence::RenewShardLease | Movie::Persistence::RunMaintenance | Movie::Persistence::SaveProjectionOffset | Movie::Persistence::SaveSnapshot | Movie::Persistence::SaveState)
on_signal(signal : SystemMessage)
on_signal,
receive(message : T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T, context : ActorContext(T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T | T))
receive
Constructor Detail
def self.new(backend : Backend, queue_capacity : Int32 = 256, telemetry : Telemetry = Telemetry.new, resilience : ResiliencePolicy = ResiliencePolicy.disabled)
#