GenDurable.Reaper (gen_durable v0.2.0)

Copy Markdown View Source

Periodically returns executing rows with an expired lease to runnable, bumping attempt. This is the at-least-once safety floor for worker crashes; handle/2 is intentionally not involved.

The same tick also fires await timeouts: parked rows whose await_deadline passed go back to runnable (a wake, not a failure — attempt untouched), so timeout resolution is bounded by :reap_interval.

Summary

Functions

Returns a specification to start this module under a supervisor.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)