struct Movie::Persistence::AppendEvents

Included Modules

Defined in:

movie/persistence/protocol.cr

Constructors

Instance Method Summary

Instance methods inherited from module Movie::Persistence::RetryableConnectionRequest(Movie::Persistence::WriteResult)

retryable_after_connection_loss? : Bool retryable_after_connection_loss?

Instance methods inherited from module Movie::Persistence::TypedConnectionRequest(Movie::Persistence::WriteResult)

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(persistence_id : String, expected_revision : Int64, operation_id : OperationId, events : Array(SerializedEvent), outbox : Array(OutboxEntry) = [] of OutboxEntry, fence : ShardLeaseToken | Nil = nil) #

[View source]

Instance Method Detail

def events : Array(SerializedEvent) #

[View source]
def execute(connection : BackendConnection) : WriteResult #

[View source]
def expected_revision : Int64 #

[View source]
def fence : ShardLeaseToken | Nil #

[View source]
def operation_id : OperationId #

[View source]
def outbox : Array(OutboxEntry) #

[View source]
def persistence_id : String #

[View source]