class
Movie::Persistence::ConnectionPool
- Movie::Persistence::ConnectionPool
- 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
Pool that routes DB messages to connection actors in round-robin order.
Defined in:
movie/persistence/storage.crConstructors
Class Method Summary
- .behavior(backend : Backend, pool_size : Int32, queue_capacity : Int32 = 256, telemetry : Telemetry = Telemetry.new, resilience : ResiliencePolicy = ResiliencePolicy.disabled)
- .behavior(db_uri : String, pool_size : Int32, 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
Class Method Detail
def self.behavior(backend : Backend, pool_size : Int32, queue_capacity : Int32 = 256, telemetry : Telemetry = Telemetry.new, resilience : ResiliencePolicy = ResiliencePolicy.disabled)
#