ObanPowertools.Cron (oban_powertools v0.5.0)

Copy Markdown View Source

Durable cron entry sync, slot claim, and operator actions.

Summary

Functions

claim_slot(repo, entry, slot_at, opts \\ [])
due_slots(repo, entry, now, opts \\ [])
latest_audit(repo, entry_name)
list_entries(repo)
list_slots(repo, entry_id)
pause_cron_entry(repo, preview_token, actor_id, opts \\ [])
pause_entry(repo, entry, actor_id, opts \\ [])
preview_entry_action(repo, action, entry, opts \\ [])
record_coverage(repo, entry, slot_at, opts \\ [])
resume_cron_entry(repo, preview_token, actor_id, opts \\ [])
resume_entry(repo, entry, actor_id, opts \\ [])
run_cron_entry(repo, preview_token, actor_id, opts \\ [])
run_now(repo, entry, actor_id, opts \\ [])
sync_entry(repo, attrs)

Functions

claim_slot(repo, entry, slot_at, opts \\ [])

due_slots(repo, entry, now, opts \\ [])

latest_audit(repo, entry_name)

list_entries(repo)

list_slots(repo, entry_id)

pause_cron_entry(repo, preview_token, actor_id, opts \\ [])

pause_entry(repo, entry, actor_id, opts \\ [])

preview_entry_action(repo, action, entry, opts \\ [])

record_coverage(repo, entry, slot_at, opts \\ [])

resume_cron_entry(repo, preview_token, actor_id, opts \\ [])

resume_entry(repo, entry, actor_id, opts \\ [])

run_cron_entry(repo, preview_token, actor_id, opts \\ [])

run_now(repo, entry, actor_id, opts \\ [])

sync_entry(repo, attrs)