Packages

raft_fleet

0.6.0
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 util.ex
Raw

lib/raft_fleet/util.ex 

use Croma



defmodule RaftFleet.Util do

  alias RaftFleet.LeaderPidCache



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

    case find_leader(name) do

      nil -> nil

      pid ->

        LeaderPidCache.set(name, pid)

        pid

    end

  end



  defunp find_leader(name :: atom) :: nil | pid do

    [Node.self() | Node.list()]

    |> Enum.map(fn node -> try_status({name, node}) end)

    |> Enum.filter(&match?(%{leader: p} when is_pid(p), &1))

    |> case do

      [] -> nil

      ss -> Enum.max_by(ss, &(&1.current_term)).leader

    end

  end



  def try_status(server) do

    try do

      RaftedValue.status(server)

      |> Map.delete(:config) # `:config` is not important and thus removed here

    catch

      :exit, _ -> nil

    end

  end



  def retrieve_member_statuses(group) do

    [Node.self() | Node.list()]

    |> Enum.map(fn n -> {n, try_status({group, n})} end)

    |> Enum.reject(&match?({_, nil}, &1))

  end

end