Queuetopia.Performer behaviour (queuetopia v2.7.1)

View Source

The behaviour for a Queuetopia performer.

Summary

Callbacks

backoff(job)
handle_failed_job!(t)
perform(t)

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.

Callbacks

backoff(job)

@callback backoff(job :: Queuetopia.Queue.Job.t()) :: pos_integer()

handle_failed_job!(t)

@callback handle_failed_job!(Queuetopia.Queue.Job.t()) :: :ok

perform(t)

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

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.