class

JoobQ::Delivery::Runtime::ActiveLease

Inherits Reference < Object

Only jobs which reach their renewal time spawn a renewal operation. A shared scanner avoids two channels and a fiber allocation per short job.

Constructors

new(context : JoobQ::Delivery::Context, ledger : JoobQ::Delivery::Ledger, next_renewal : Time::Instant)

context

due?(now : Time::Instant) : Bool

finished

ledger

lock

renewing

reschedule(at : Time::Instant) : Nil