Quantum v2.4.0 Quantum.Job View Source

This Struct defines a Job.

Usage

The struct should never be defined by hand. Use Acme.Scheduler.new_job/0 to create a new job and use the setters mentioned below to mutate the job.

This is to ensure type safety.

Link to this section Summary

Types

name()

schedule()

state()

t()

task()

timezone()

Functions

new(config)

Takes some config from a scheduler and returns a new job

set_name(job, name)

Sets a job's name.

set_overlap(job, overlap?)

Sets a job's overlap.

set_run_strategy(job, run_strategy)

Sets a job's run strategy.

set_schedule(job, schedule)

Sets a job's schedule.

set_state(job, atom)

Sets a job's state.

set_task(job, task)

Sets a job's task.

set_timezone(job, timezone)

Sets a job's timezone.

Link to this section Types

name()

name() :: atom() | reference()

schedule()

schedule() :: Crontab.CronExpression.t()

state()

state() :: :active | :inactive

t()

t() :: %Quantum.Job{
  name: name(),
  overlap: boolean(),
  run_strategy: Quantum.RunStrategy.NodeList,
  schedule: schedule() | nil,
  state: state(),
  task: task() | nil,
  timezone: timezone()
}

task()

task() :: {atom(), atom(), [any()]} | (() -> any())

timezone()

timezone() :: :utc | String.t()

Link to this section Functions

new(config)

new(config :: Keyword.t()) :: t()

Takes some config from a scheduler and returns a new job

Examples

iex> Acme.Scheduler.config
...> |> Quantum.Job.new
%Quantum.Job{...}

set_name(job, name)

set_name(t(), atom()) :: t()

Sets a job's name.

Parameters

job - The job struct to modify
name - The name to set

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_name(:name)
...> |> Map.get(:name)
:name

set_overlap(job, overlap?)

set_overlap(t(), boolean()) :: t()

Sets a job's overlap.

Parameters

job - The job struct to modify
overlap - Enable / Disable Overlap

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_overlap(false)
...> |> Map.get(:overlap)
false

set_run_strategy(job, run_strategy)

set_run_strategy(t(), Quantum.RunStrategy.NodeList) :: t()

Sets a job's run strategy.

Parameters

job - The job struct to modify
run_strategy - The run strategy to set

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.run_strategy(%Quantum.RunStrategy.All{nodes: [:one, :two]})
...> |> Map.get(:run_strategy)
[:one, :two]

set_schedule(job, schedule)

set_schedule(t(), Crontab.CronExpression.t()) :: t()

Sets a job's schedule.

Parameters

job - The job struct to modify
schedule - The schedule to set. May only be of type %Crontab.CronExpression{}

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_schedule(Crontab.CronExpression.Parser.parse!("*/7"))
...> |> Map.get(:schedule)
Crontab.CronExpression.Parser.parse!("*/7")

set_state(job, atom)

set_state(t(), state()) :: t()

Sets a job's state.

Parameters

job - The job struct to modify
state - The state to set

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_state(:active)
...> |> Map.get(:state)
:active

set_task(job, task)

set_task(t(), task()) :: t()

Sets a job's task.

Parameters

job - The job struct to modify
task - The function to be performed, ex: {Heartbeat, :send, []} or fn -> :something end

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_task({Backup, :backup, []})
...> |> Map.get(:task)
{Backup, :backup, []}

set_timezone(job, timezone)

set_timezone(t(), String.t() | :utc) :: t()

Sets a job's timezone.

Parameters

job - The job struct to modify
timezone - The timezone to set.

Examples

iex> Acme.Scheduler.new_job()
...> |> Quantum.Job.set_timezone("Europe/Zurich")
...> |> Map.get(:timezone)
"Europe/Zurich"