Packages

queuetopia

1.3.0
2.7.2 2.7.1 2.7.0 2.6.1 2.6.0 2.5.3 2.5.2 2.5.1 2.5.0 2.4.4 2.4.3 2.4.2 2.4.1 2.4.0 2.3.5 2.3.3 2.3.2 2.3.1 2.3.0 2.2.0 2.1.3 2.1.2 2.1.1 2.1.0 2.0.1 2.0.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.1 1.3.0 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.0 0.6.3 0.6.2 0.6.1 0.6.0 0.5.1 0.5.0 0.3.0 0.2.0 0.1.2

Persistent blocking job queue

HexDocs

Current section

Files

Jump to
Readme
48 Versions
5 Dependencies
Dependants
Files
Activity
queuetopia lib queuetopia performer.ex
Raw

lib/queuetopia/performer.ex 

defmodule Queuetopia.Performer do

  @moduledoc """

  The behaviour for a Queuetopia performer.

  """

  alias Queuetopia.Queue.Job



  @doc """

  Callback invoked by the Queuetopia to perfom a job.

  It may return :ok, an :ok tuple or a tuple error, with a string as error.

  Note that any failure in the processing will cause the job to be retried.

  """

  @callback perform(Job.t()) :: :ok | {:ok, any()} | {:error, binary}

end