Packages

rafted_value

0.11.1
0.12.0 0.11.2 0.11.1 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.3 0.9.2 0.9.1 retired 0.9.0 0.8.0 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 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

Replicated and synchronized values wrapped by processes

HexDocs

Current section

Files

Jump to
Readme
37 Versions
1 Dependency
Dependants
Files
Activity
rafted_value lib rafted_value command_results.ex
Raw

lib/rafted_value/command_results.ex 

use Croma



defmodule RaftedValue.CommandResults do

  @type cmd_id :: RaftedValue.command_identifier

  @type t :: {:queue.queue(cmd_id), %{cmd_id => any}}

  defun valid?(v :: any) :: boolean do

    {{l1, l2}, m} when is_list(l1) and is_list(l2) and is_map(m) -> true

    _ -> false

  end



  defun new() :: t do

    {:queue.new(), %{}}

  end



  defun fetch({_q, m} :: t, cmd_id :: cmd_id) :: {:ok, any} | :error do

    Map.fetch(m, cmd_id)

  end



  defun put({q1, m1} :: t,

            cmd_id   :: cmd_id,

            result   :: any,

            max_size :: pos_integer) :: t do

    q2 = :queue.in(cmd_id, q1)

    m2 = Map.put(m1, cmd_id, result)

    if map_size(m2) <= max_size do

      {q2, m2}

    else

      {{:value, cmd_id_removed}, q3} = :queue.out(q2)

      m3 = Map.delete(m2, cmd_id_removed)

      {q3, m3}

    end

  end

end