Packages

raft_fleet

0.8.3
0.11.0 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.1 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 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.3 0.1.2 0.1.1 0.1.0

A fleet of Raft consensus groups

HexDocs

Current section

Files

Jump to
Readme
48 Versions
2 Dependencies
Dependants
Files
Activity
raft_fleet lib raft_fleet leader_pid_cache.ex
Raw

lib/raft_fleet/leader_pid_cache.ex 

use Croma



defmodule RaftFleet.LeaderPidCache do

  @table_name :raft_fleet_leader_pid_cache



  defun init() :: :ok do

    _table_id = :ets.new(@table_name, [:public, :named_table, {:read_concurrency, true}])

    :ok

  end



  defun get(name :: atom) :: nil | pid do

    case :ets.lookup(@table_name, name) do

      []         -> nil

      [{_, pid}] -> pid

    end

  end



  defun set(name :: atom, leader :: nil | pid) :: :ok do

    :ets.insert(@table_name, {name, leader})

    :ok

  end



  defun unset(name :: atom) :: :ok do

    :ets.delete(@table_name, name)

    :ok

  end



  defun keys() :: [atom] do

    case :ets.first(@table_name) do

      :"$end_of_table" -> []

      k                -> keys_impl(k, [k])

    end

  end



  defp keys_impl(k, acc) do

    case :ets.next(@table_name, k) do

      :"$end_of_table" -> acc

      k                -> keys_impl(k, [k | acc])

    end

  end

end