Packages

ferricstore

0.7.1
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore flow terminal_query.ex
Raw

lib/ferricstore/flow/terminal_query.ex 

defmodule Ferricstore.Flow.TerminalQuery do

  @moduledoc false



  def state(opts, terminal_states) do

    case Keyword.get(opts, :state, "any") do

      "any" ->

        {:ok, "any"}



      state ->

        if state in terminal_states do

          {:ok, state}

        else

          {:error, "ERR flow terminal state must be failed, completed, cancelled, or any"}

        end

    end

  end



  def ids_from_chunks(chunks, count, terminal_states) do

    chunks

    |> Enum.flat_map(& &1)

    |> Enum.uniq()

    |> Enum.take(count * length(terminal_states))

  end



  def filter_any(records, terminal_states) do

    Enum.filter(records, &(Map.get(&1, :state) in terminal_states))

  end



  def filter_state(records, state) do

    Enum.filter(records, &(Map.get(&1, :state) == state))

  end

end