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!()
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!()
scale_queue(opts)
start_queue(opts)
stop_queue(opts)
update_job(job_or_id, changes_or_fun)

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)