Packages

gust

0.1.26
0.1.37 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 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.2 0.1.1 0.1.0

A DAG-Based Workflow Orchestration Engine for Elixir

HexDocs

Current section

Files

Jump to
Readme
37 Versions
9 Dependencies
Dependants
Files
Activity
gust lib gust run claim.ex
Raw

lib/gust/run/claim.ex 

defmodule Gust.Run.Claim do

  @moduledoc """

  Behavior + facade for claiming/renewing run leases.



  Configure the implementation with:



      config :gust, Gust.Run.Claim, Gust.Run.Claim.Repo

  """



  @type run_id :: term()

  @type token :: Ecto.UUID.t()

  @type run :: Gust.Flows.Run.t()



  @type next_run_result ::

          nil

          | %{run: run(), token: token(), claimed_by: String.t(), claim_expires_at: DateTime.t()}



  @callback renew_run(run_id(), token()) :: run() | nil

  @callback next_run() :: next_run_result()



  def renew_run(run_id, token), do: impl().renew_run(run_id, token)

  def next_run, do: impl().next_run()



  defp impl do

    Application.get_env(:gust, :run_claim, Gust.Run.Claim.Repo)

  end

end