class Movie::Persistence::EventStoreClient

• Movie::Persistence::EventStoreClient
• Reference
• Object

Defined in:

movie/persistence/storage.cr

Constructors

• .new(ref : Movie::ActorRef(EventStoreMessage), timeout : Time::Span = 5.seconds, fence : ShardLeaseToken | Nil = nil)

Instance Method Summary

• #append(ctx : Movie::ActorContext(U), persistence_id : String, expected_revision : Int64, operation_id : OperationId, events : Array(SerializedEvent), outbox : Array(OutboxEntry) = [] of OutboxEntry) : WriteResult forall U
• #delete_events_to(ctx : Movie::ActorContext(U), persistence_id : String, sequence_nr : Int64) : RetentionResult forall U
• #delete_snapshot(ctx : Movie::ActorContext(U), persistence_id : String) : Bool forall U
• #fenced(fence : ShardLeaseToken) : self
• #load_snapshot(ctx : Movie::ActorContext(U), persistence_id : String) : SnapshotRecord | Nil forall U
• #read(ctx : Movie::ActorContext(U), persistence_id : String, after_sequence_nr : Int64 = 0_i64) : Array(StoredEvent) forall U
• #run_maintenance(ctx : Movie::ActorContext(U)) : MaintenanceResult forall U
• #save_snapshot(ctx : Movie::ActorContext(U), persistence_id : String, snapshot : SnapshotRecord) : Bool forall U

Constructor Detail

Instance Method Detail