Packages

queuetopia

2.6.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
2 Dependencies
Dependants
Files
Activity
queuetopia lib queuetopia in_memory_sequence.ex
Raw

lib/queuetopia/in_memory_sequence.ex 

defmodule Queuetopia.InMemorySequence do

  use Agent



  def start_link(opts) do

    Agent.start_link(fn -> next_sequence(opts[:repo]) end, name: opts[:name])

  end



  def next_value!(process) do

    Agent.get_and_update(process, &{&1, &1 + 1})

  end



  defp next_sequence(repo) do

    %{rows: [[max_seq]]} = repo.query!("SELECT max(sequence) FROM queuetopia_jobs")

    (max_seq || 0) + 1

  end

end