View Source Oban.Repo (Oban v2.14.0)
Wrappers around Ecto.Repo and Ecto.Adapters.SQL callbacks.
Each function resolves the correct repo instance and sets options such as prefix and log
according to Oban.Config.
Meant for Extending Oban
These functions should only be used when working with a repo inside engines, plugins, or other extensions for Oban. Favor using your application's repo directly when querying
Oban.Jobfrom your workers.
examples
Examples
The first argument for every function must be an Oban.Config struct. Many functions pass
configuration around as a conf key, and it can always be fetched with Oban.config/1. This
demonstrates fetching the default instance config and querying all jobs:
Oban
|> Oban.config()
|> Oban.Repo.all(Oban.Job)Link to this section Summary
Functions
Wraps Ecto.Repo.aggregate/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.all/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.checkout/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.config/0 with an additional Oban.Config argument.
The default values extracted from Oban.Config for use in all queries with options.
Wraps Ecto.Repo.default_options/1 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete_all/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.exists?/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.get/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get!/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_by/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_by!/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_dynamic_repo/0 with an additional Oban.Config argument.
Wraps Ecto.Repo.in_transaction?/0 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_all/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_or_update/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_or_update!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.load/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.one/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.one!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.preload/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.put_dynamic_repo/1 with an additional Oban.Config argument.
Wraps Ecto.Adapters.SQL.Repo.query/4 with an added Oban.Config argument.
Wraps Ecto.Repo.reload/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.reload!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.rollback/1 with an additional Oban.Config argument.
Wraps Ecto.Repo.stream/2 with an additional Oban.Config argument.
Wraps Ecto.Adapters.SQL.Repo.to_sql/2 with an added Oban.Config argument.
Wraps Ecto.Repo.transaction/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update_all/3 with an additional Oban.Config argument.
Link to this section Functions
Wraps Ecto.Repo.aggregate/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.all/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.checkout/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.config/0 with an additional Oban.Config argument.
The default values extracted from Oban.Config for use in all queries with options.
Wraps Ecto.Repo.default_options/1 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.delete_all/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.exists?/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.get/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get!/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_by/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_by!/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.get_dynamic_repo/0 with an additional Oban.Config argument.
Wraps Ecto.Repo.in_transaction?/0 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_all/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_or_update/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.insert_or_update!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.load/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.one/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.one!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.preload/3 with an additional Oban.Config argument.
Wraps Ecto.Repo.put_dynamic_repo/1 with an additional Oban.Config argument.
Wraps Ecto.Adapters.SQL.Repo.query/4 with an added Oban.Config argument.
Wraps Ecto.Repo.reload/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.reload!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.rollback/1 with an additional Oban.Config argument.
Wraps Ecto.Repo.stream/2 with an additional Oban.Config argument.
Wraps Ecto.Adapters.SQL.Repo.to_sql/2 with an added Oban.Config argument.
Wraps Ecto.Repo.transaction/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update!/2 with an additional Oban.Config argument.
Wraps Ecto.Repo.update_all/3 with an additional Oban.Config argument.