From 7c69cc60b3ce674463629961e63d8878e4f56938 Mon Sep 17 00:00:00 2001 From: Parker Selbert Date: Tue, 23 Apr 2024 08:48:08 +0100 Subject: [PATCH] Make functions from calling use Oban overridable Now the functions generated by `use Oban` are all marked with `defoverridable` for extensibility. --- lib/oban.ex | 24 ++++++++++++++++++++++-- 1 file changed, 22 insertions(+), 2 deletions(-) diff --git a/lib/oban.ex b/lib/oban.ex index 6b0a4c31..aa7450b8 100644 --- a/lib/oban.ex +++ b/lib/oban.ex @@ -208,7 +208,7 @@ 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 @@ -216,7 +216,7 @@ defmodule Oban 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 @@ -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