struct
Movie::Persistence::ClaimOutbox
- Movie::Persistence::ClaimOutbox
- Struct
- Value
- Object
Included Modules
Defined in:
movie/persistence/protocol.crConstructors
- .for(owner : String, limit : Int32 = 100, lease : Time::Span = 30.seconds, now : Time = Time.utc) : self
- .new(owner : String, limit : Int32, now_epoch_ms : Int64, lease_until_epoch_ms : Int64)
Instance Method Summary
- #execute(connection : BackendConnection) : Array(StoredOutboxEntry)
- #lease_until_epoch_ms : Int64
- #limit : Int32
- #now_epoch_ms : Int64
- #owner : String
Instance methods inherited from module Movie::Persistence::RetryableConnectionRequest(Array(Movie::Persistence::StoredOutboxEntry))
retryable_after_connection_loss? : Bool
retryable_after_connection_loss?
Instance methods inherited from module Movie::Persistence::TypedConnectionRequest(Array(Movie::Persistence::StoredOutboxEntry))
dispatch(worker : ConnectionWorker, sender : Movie::ActorRefBase | Nil) : Nil
dispatch,
execute(connection : BackendConnection) : T(Movie::Persistence::StoredOutboxEntry)
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.for(owner : String, limit : Int32 = 100, lease : Time::Span = 30.seconds, now : Time = Time.utc) : self
#
def self.new(owner : String, limit : Int32, now_epoch_ms : Int64, lease_until_epoch_ms : Int64)
#