class

JoobQ::Delivery::Context

Inherits Reference < Object

Cooperative cancellation only: losing a lease never kills a Crystal fiber.

Constants

START = Time.instant

Constructors

new(claim : JoobQ::Delivery::Claim, acquired : Time::Instant = Time.instant, lease : Time::Span = 30.seconds, execution_timeout : Time::Span = 5.minutes)

Source

Instance methods

cancel

cancelled?

check!

claim

extend_lease(acquired : Time::Instant, lease : Time::Span) : Nil

Source

idempotency_key

Stable across redelivery; pass this to an external service's idempotency API.

Source