Packages

gust

0.1.32
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 dag adapter.ex
Raw

lib/gust/dag/adapter.ex 

defmodule Gust.DAG.Adapter do

  @moduledoc false



  @default_adapters [

    elixir: %{

      parser: Gust.DAG.Parser.Adapters.Elixir,

      runtime: Gust.DAG.Runtime.Adapters.Elixir,

      task_worker: Gust.DAG.TaskWorker.Adapters.Elixir

    }

  ]



  def impl!(adapter_name, key) do

    adapter_name

    |> adapter_config!()

    |> Map.fetch!(key)

  end



  def parser_module!(adapter_name) do

    impl!(adapter_name, :parser)

  end



  def parser_modules do

    adapters()

    |> Keyword.values()

    |> Enum.map(&Map.fetch!(&1, :parser))

  end



  def parser_for_extension(extension) do

    adapters()

    |> Keyword.values()

    |> Enum.find_value(fn %{parser: parser} ->

      if parser.extension() == extension, do: parser, else: nil

    end)

  end



  defp adapter_config!(adapter_name) do

    adapters()

    |> Keyword.fetch!(adapter_name)

  end



  defp adapters do

    configured = Application.get_env(:gust, :dag_adapter, [])



    Keyword.merge(@default_adapters, configured, fn _key, default_val, configured_val ->

      Map.merge(default_val, configured_val)

    end)

  end

end