Packages

queuetopia

2.3.3
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 queue lock.ex
Raw

lib/queuetopia/queue/lock.ex 

defmodule Queuetopia.Queue.Lock do

  @moduledoc false



  use Ecto.Schema

  import Ecto.Changeset, only: [cast: 3, unique_constraint: 3, validate_required: 2]



  @type t :: %__MODULE__{}



  @primary_key {:id, :binary_id, autogenerate: true}

  schema "queuetopia_locks" do

    field(:scope, :string)

    field(:queue, :string)

    field(:locked_at, :utc_datetime)

    field(:locked_by_node, :string)

    field(:locked_until, :utc_datetime)



    timestamps()

  end



  @spec changeset(Lock.t(), map) :: Ecto.Changeset.t()

  def changeset(%__MODULE__{} = lock, attrs) when is_map(attrs) do

    lock

    |> cast(attrs, [:scope, :queue, :locked_at, :locked_by_node, :locked_until])

    |> validate_required([:scope, :queue, :locked_at, :locked_by_node, :locked_until])

    |> unique_constraint(:queue, name: :queuetopia_locks_scope_queue_index)

  end

end