Packages

rafted_value

0.1.9
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 pid_set.ex
Raw

lib/rafted_value/pid_set.ex 

use Croma



defmodule RaftedValue.PidSet do

  @moduledoc false



  @type t :: %{pid => true}

  defun validate(v :: any) :: Croma.Result.t(t) do

    m when is_map(m) -> {:ok, m}

    _                -> {:error, {:invalid_value, [__MODULE__]}}

  end



  defun new                           :: t              , do: %{}

  defun size(set :: t)                :: non_neg_integer, do: map_size(set)

  defun put(set :: t, pid :: pid)     :: t              , do: Map.put(set, pid, true)

  defun delete(set :: t, pid :: pid)  :: t              , do: Map.delete(set, pid)

  defun to_list(set :: t)             :: [pid]          , do: Map.keys(set)

  defun member?(set :: t, pid :: pid) :: boolean        , do: Map.has_key?(set, pid)

end