Packages

raft_fleet

0.8.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 activator.ex
Raw

lib/raft_fleet/activator.ex 

use Croma



defmodule RaftFleet.Activator do

  alias RaftFleet.Cluster



  @tries 5

  @sleep 1_000



  def activate(zone) do

    steps = [

      :start_cluster_consensus_member,

      {:add_node, zone},

      :notify_node_reconnector_in_this_node,

      :notify_node_reconnectors_in_other_nodes,

    ]

    run_steps(steps, @tries)

  end



  defp run_steps(_, 0), do: raise "Failed to complete all steps of node activation!"

  defp run_steps([], _), do: :ok

  defp run_steps([s | ss], tries_remaining) do

    case step(s) do

      :ok    -> run_steps(ss, tries_remaining)

      :error ->

        :timer.sleep(@sleep)

        run_steps([s | ss], tries_remaining - 1)

    end

  end



  defp step(:start_cluster_consensus_member) do

    case Supervisor.start_child(RaftFleet.Supervisor, Cluster.Server.child_spec()) do

      {:ok, _}    -> :ok

      {:error, _} -> :error

    end

  end

  defp step({:add_node, zone}) do

    case RaftFleet.command(Cluster, {:add_node, Node.self(), zone}) do

      {:ok, _}    -> :ok

      {:error, _} -> :error

    end

  end

  defp step(:notify_node_reconnector_in_this_node) do

    GenServer.cast(RaftFleet.NodeReconnector, :this_node_activated)

  end

  defp step(:notify_node_reconnectors_in_other_nodes) do

    GenServer.abcast(Node.list(), RaftFleet.NodeReconnector, {:other_node_activated, Node.self()})

    :ok

  end

end