Skip to content

Commit

Permalink
Make functions from calling use Oban overridable
Browse files Browse the repository at this point in the history
Now the functions generated by `use Oban` are all marked with
`defoverridable` for extensibility.
  • Loading branch information
sorentwo committed Apr 23, 2024
1 parent 0abfe77 commit 7c69cc6
Showing 1 changed file with 22 additions and 2 deletions.
24 changes: 22 additions & 2 deletions lib/oban.ex
Original file line number Diff line number Diff line change
Expand Up @@ -208,15 +208,15 @@ defmodule Oban do
Oban.pause_queue(__MODULE__, opts)
end

def pause_all_queues(opts) do
def pause_all_queues(opts \\ []) do
Oban.pause_all_queues(__MODULE__, opts)
end

def resume_queue(opts) do
Oban.resume_queue(__MODULE__, opts)
end

def resume_all_queues(opts) do
def resume_all_queues(opts \\ []) do
Oban.resume_all_queues(__MODULE__, opts)
end

Expand All @@ -235,6 +235,26 @@ defmodule Oban do
def retry_all_jobs(queryable) do
Oban.retry_all_jobs(__MODULE__, queryable)
end

defoverridable cancel_all_jobs: 1,
cancel_job: 1,
check_queue: 1,
config: 0,
drain_queue: 1,
insert: 2,
insert: 4,
insert!: 2,
insert_all: 2,
insert_all: 4,
start_queue: 1,
pause_queue: 1,
pause_all_queues: 1,
resume_queue: 1,
resume_all_queues: 1,
scale_queue: 1,
stop_queue: 1,
retry_job: 1,
retry_all_jobs: 1
end
end

Expand Down

0 comments on commit 7c69cc6

Please sign in to comment.