module Movie::Persistence

Defined in:

movie/persistence/connection_worker.cr
movie/persistence/migrations.cr
movie/persistence/postgres.cr
movie/persistence/protocol.cr
movie/persistence/resilience.cr
movie/persistence/runtime.cr
movie/persistence/sql_backend.cr
movie/persistence/sql_fencing.cr
movie/persistence/sql_journal.cr
movie/persistence/sql_outbox.cr
movie/persistence/sql_query.cr
movie/persistence/sql_retention.cr
movie/persistence/sql_schema.cr
movie/persistence/sql_state.cr
movie/persistence/sqlite_backend.cr
movie/persistence/storage.cr
movie/persistence/telemetry.cr

Constant Summary

CURRENT_SCHEMA_VERSION = SCHEMA_MIGRATIONS.last.version
SCHEMA_MIGRATIONS = [SchemaMigration.new(1_i64, "core-persistence-schema", Digest::SHA256.hexdigest("movie:persistence:migration:1:core-persistence-schema:v1")), SchemaMigration.new(2_i64, "event-query-and-projection-schema", Digest::SHA256.hexdigest("movie:persistence:migration:2:event-query-and-projection-schema:v1")), SchemaMigration.new(3_i64, "transactional-outbox-schema", Digest::SHA256.hexdigest("movie:persistence:migration:3:transactional-outbox-schema:v1")), SchemaMigration.new(4_i64, "cluster-shard-fencing-schema", Digest::SHA256.hexdigest("movie:persistence:migration:4:cluster-shard-fencing-schema:v1"))]

Class Method Summary

Class Method Detail

def self.entity_name(id : Id) : String #

[View source]
def self.id(type : T.class, entity_id : String) : Id forall T #

[View source]