init

Author: Phineas

.elixir_ls/build/test/lib/ex_hash_ring/.mix/compile.elixir

@@ -0,0 +1 @@
+�ha
j

.elixir_ls/build/test/lib/ex_hash_ring/.mix/compile.elixir_scm

@@ -0,0 +1,10 @@
+{application,ex_hash_ring,
+             [{applications,[kernel,stdlib,elixir]},
+              {description,"ex_hash_ring"},
+              {modules,['Elixir.ExHashRing','Elixir.ExHashRing.HashRing',
+                        'Elixir.ExHashRing.HashRing.ETS',
+                        'Elixir.ExHashRing.HashRing.ETS.Config',
+                        'Elixir.ExHashRing.HashRing.Utils']},
+              {registered,[]},
+              {vsn,"3.0.0"},
+              {mod,{'Elixir.ExHashRing',[]}}]}.

.elixir_ls/build/test/lib/ex_hash_ring/.mix/compile.fetch

@@ -0,0 +1 @@
+�ha
j

.elixir_ls/build/test/lib/ex_hash_ring/.mix/compile.xref

@@ -0,0 +1,6 @@
+{application,node_compass,
+             [{applications,[kernel,stdlib,elixir,logger,ex_hash_ring]},
+              {description,"node_compass"},
+              {modules,['Elixir.NodeCompass']},
+              {registered,[]},
+              {vsn,"0.1.0"}]}.

.elixir_ls/build/test/lib/ex_hash_ring/ebin/Elixir.ExHashRing.HashRing.ETS.Config.beam

@@ -0,0 +1,4 @@
+# Used by "mix format"
+[
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+]

.elixir_ls/build/test/lib/ex_hash_ring/ebin/Elixir.ExHashRing.HashRing.ETS.beam

@@ -0,0 +1,24 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where third-party dependencies like ExDoc output generated docs.
+/doc/
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Ignore package tarball (built via "mix hex.build").
+node_compass-*.tar
+

.elixir_ls/build/test/lib/ex_hash_ring/ebin/Elixir.ExHashRing.HashRing.Utils.beam

@@ -0,0 +1,74 @@
+defmodule NodeCompass do
+  use GenServer
+
+  require Logger
+  alias ExHashRing.HashRing
+
+  defstruct [
+    :ring_pid,
+    :verify_node_tag
+  ]
+
+  @spec find_node(binary | integer) :: {:ok, binary} | {:error, atom}
+  def find_node(key) do
+    HashRing.ETS.find_node(:compass_ring, key)
+  end
+
+
+  def verify_node(ext_pid, remote_tag) do
+    tag = GenServer.call(:node_compass, {:get_verify_tag})
+
+    with tag <- remote_tag do
+      GenServer.cast(ext_pid, {:add_node, node()})
+    end
+  end
+
+  @doc """
+  Start the node_compass controller.
+  NodeCompass should be run under a supervision tree, it is not recommended to call this directly.
+  """
+  def start_link(verify_node_tag \\ nil) do
+    GenServer.start_link(__MODULE__, %__MODULE__{verify_node_tag: verify_node_tag}, name: :node_compass)
+  end
+
+  def init(state) do
+    {:ok, pid} = HashRing.ETS.start_link(:compass_ring)
+
+    pid
+    |> HashRing.ETS.add_node(node())
+
+    :net_kernel.monitor_nodes(true)
+
+    {:ok, %__MODULE__{state | ring_pid: pid}}
+  end
+
+  def handle_call({:get_verify_tag}, _from, state) do
+    {:reply, state.verify_node_tag, state}
+  end
+
+  def handle_cast({:add_node, remote_node}, state) do
+    state.ring_pid
+    |> HashRing.ETS.add_node(remote_node)
+
+    Logger.info("Node added to hash ring: #{remote_node}")
+    {:noreply, state}
+  end
+
+  def handle_info({:nodeup, remote_node}, state) do
+    case state.verify_node_tag do
+      nil ->
+        GenServer.cast(self(), {:add_node, node})
+      _ ->
+        Node.spawn(remote_node, NodeCompass, :verify_node, [self(), state.verify_node_tag])
+    end
+
+    {:noreply, state}
+  end
+
+  def handle_info({:nodedown, node}, state) do
+    state.ring_pid
+    |> HashRing.ETS.remove_node(node)
+
+    {:noreply, state}
+  end
+end

.elixir_ls/build/test/lib/ex_hash_ring/ebin/Elixir.ExHashRing.HashRing.beam

@@ -0,0 +1,42 @@
+defmodule NodeCompass.MixProject do
+  use Mix.Project
+
+  def project do
+    [
+      app: :node_compass,
+      version: "0.1.0",
+      elixir: "~> 1.9",
+      start_permanent: Mix.env() == :prod,
+      deps: deps(),
+      package: package()
+    ]
+  end
+
+  # Run "mix help compile.app" to learn about applications.
+  def application do
+    [
+      extra_applications: [:logger]
+    ]
+  end
+
+  # Run "mix help deps" to learn about dependencies.
+  defp deps do
+    [
+      {:ex_hash_ring, "~> 3.0"}
+      # {:dep_from_hexpm, "~> 0.3.0"},
+      # {:dep_from_git, git: "https://github.com/elixir-lang/my_dep.git", tag: "0.1.0"}
+    ]
+  end
+
+  defp package do
+    [
+      name: :node_compass,
+      description: "NodeCompass is an automated hash-ring management system for Elixir clusters",
+      maintainers: ["Hiven", "phineas"],
+      licenses: ["MIT"],
+      links: %{
+        "GitHub" => "https://github.com/hivenapp/node_compass"
+      }
+    ]
+  end
+end

.elixir_ls/build/test/lib/ex_hash_ring/ebin/Elixir.ExHashRing.beam

@@ -0,0 +1,3 @@
+%{
+  "ex_hash_ring": {:hex, :ex_hash_ring, "3.0.0", "da32c83d7c6d964b9537eb52f27bad0a3a6f7012efdc2749e11a5f268b120b6b", [:mix], [], "hexpm"},
+}

.elixir_ls/build/test/lib/ex_hash_ring/ebin/ex_hash_ring.app

@@ -0,0 +1,8 @@
+defmodule NodeCompassTest do
+  use ExUnit.Case
+  doctest NodeCompass
+
+  test "greets the world" do
+    assert NodeCompass.hello() == :world
+  end
+end

.elixir_ls/build/test/lib/node_compass/.mix/compile.elixir

@@ -0,0 +1 @@
+ExUnit.start()