Packages

raft_fleet

0.1.16
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



  def find_leader_and_cache(name) do

    case find_leader(name) do

      nil -> nil

      pid ->

        LeaderPidCache.set(name, pid)

        pid

    end

  end



  defp find_leader(name) do

    statuses =

      [Node.self | Node.list]

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

      |> Enum.reject(&is_nil/1)

    if Enum.empty?(statuses) do

      nil

    else

      max_term = Enum.map(statuses, &(&1[:current_term])) |> Enum.max

      Enum.filter(statuses, &(&1[:current_term] == max_term))

      |> Enum.map(&(&1[:leader]))

      |> Enum.reject(&is_nil/1)

      |> List.first

    end

  end



  def try_status(server) do

    try do

      RaftedValue.status(server)

    catch

      :exit, _ -> nil

    end

  end

end