Packages

queuetopia

2.5.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
3 Dependencies
Dependants
Files
Activity
queuetopia lib queuetopia migrations.ex
Raw

lib/queuetopia/migrations.ex 

defmodule Queuetopia.Migrations do

  use Ecto.Migration



  @initial_version 0

  @current_version 4

  def up(opts \\ []) when is_list(opts) do

    from_version = Keyword.get(opts, :from_version, @initial_version) |> Kernel.+(1)

    to_version = Keyword.get(opts, :to_version, @current_version)



    if from_version <= to_version do

      change(from_version..to_version, :up)

    end

  end



  def down(opts \\ []) when is_list(opts) do

    from_version = Keyword.get(opts, :from_version, @current_version)

    to_version = Keyword.get(opts, :to_version, @initial_version) |> Kernel.+(1)



    if from_version >= to_version do

      change(from_version..to_version, :down)

    end

  end



  @doc false

  def initial_version, do: @initial_version



  @doc false

  def current_version, do: @current_version



  defp change(range, direction) do

    for index <- range do

      [__MODULE__, "V#{index}"]

      |> Module.concat()

      |> apply(direction, [])

    end

  end

end