Packages

queuetopia

2.7.2
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
2 Dependencies
Dependants
Files
Activity
queuetopia lib queuetopia queue job_queryable.ex
Raw

lib/queuetopia/queue/job_queryable.ex 

defmodule Queuetopia.Queue.JobQueryable do

  use AntlUtilsEcto.Queryable,

    base_schema: Queuetopia.Queue.Job,

    searchable_fields: [:scope, :queue, :action, :params]



  import Ecto.Query



  @filterable_fields ~w(id scope queue action available?)a



  defp filter_by_field(queryable, {:available?, true}) do

    queryable

    |> where([job], is_nil(job.done_at))

    |> where([job], job.attempts < job.max_attempts)

  end



  defp filter_by_field(_queryable, {key, _value}) when key not in @filterable_fields do

    raise ArgumentError, "Filter not implemented"

  end

end