Lockspire.Oban (lockspire v1.0.0)

Copy Markdown

Named Oban instance owned by Lockspire for durable protocol work.

Summary

Functions

cancel_all_jobs(queryable)

cancel_job(job_or_id)

check_all_queues()

check_queue(opts)

child_spec(opts)

config()

config!()

@spec config!() :: Oban.Config.t()

delete_all_jobs(queryable)

delete_job(job_or_id)

drain_queue(opts)

insert(changeset, opts \\ [])

insert(multi, multi_name, changeset, opts \\ [])

insert!(changeset, opts \\ [])

insert_all(changesets, opts \\ [])

insert_all(multi, multi_name, changesets, opts \\ [])

pause_all_queues(opts \\ [])

pause_queue(opts)

resume_all_queues(opts \\ [])

resume_queue(opts)

retry_all_jobs(queryable)

retry_job(job_or_id)

runtime_config!()

@spec runtime_config!() :: keyword()

scale_queue(opts)

start_queue(opts)

stop_queue(opts)

update_job(job_or_id, changes_or_fun)