Packages

cyclium

0.3.2
0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.2 0.2.1 0.2.0 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Cyclium is a framework for building and orchestrating long-running, stateful processes ("actors") in Elixir.

HexDocs

Current section

Files

Jump to
Readme
24 Versions
5 Dependencies
Dependants
Files
Activity
cyclium lib cyclium migrations v5.ex
Raw

lib/cyclium/migrations/v5.ex 

defmodule Cyclium.Migrations.V5 do

  @moduledoc """

  V5: Unique index on episodes dedupe_key for multi-node coordination.



  Replaces the non-unique index from V1 with a filtered unique index.

  NULL dedupe_keys and archived episodes are excluded — archived episodes

  can reuse dedupe_keys so re-triggered work isn't blocked.

  """



  use Ecto.Migration



  def up do

    drop(index(:cyclium_episodes, [:dedupe_key]))



    create(

      unique_index(:cyclium_episodes, [:dedupe_key],

        where: "dedupe_key IS NOT NULL AND archived_at IS NULL"

      )

    )

  end



  def down do

    drop(index(:cyclium_episodes, [:dedupe_key]))

    create(index(:cyclium_episodes, [:dedupe_key]))

  end

end