Added a simple GenServer for monitoring the API health endpoint

Author: Fletcher Haynes

lib/exkube.ex

@@ -23,7 +23,5 @@ defmodule Exkube.Base do
       _ ->
         {:error, %{status_code: status_code, body: body}}
     end
-
   end
-
 end

lib/health_supervisor.ex

@@ -0,0 +1,37 @@
+defmodule Exkube.HealthSupervisor do
+  @moduledoc """
+  Periodically pings the k8s API to check system health
+  """
+
+  use GenServer
+
+  def start_link(api_url, ok_callback, error_callback) do
+    GenServer.start_link(__MODULE__, [api_url: api_url, ok_callback: ok_callback, error_callback: error_callback], [])
+  end
+
+  def init([api_url, ok_callback, error_callback]) do
+    schedule_work()
+    {:ok, [api_url, ok_callback, error_callback]}
+  end
+
+  def handle_info(:work, state) do
+    state = do_work(state)
+    schedule_work()
+    {:noreply, state}
+  end
+
+  defp do_work(state) do
+    case Exkube.Base.status(state[:api_url]) do
+      {:ok, _} ->
+        state[:ok_callback].(state[:api_url])
+      {:error, _} ->
+        state[:error_callback].(state[:api_url])
+    end
+    state
+  end
+
+  defp schedule_work do
+    Process.send_after(self(), :work, 5_000)
+  end
+
+end

mix.exs

@@ -3,10 +3,9 @@ defmodule Exkube.Mixfile do
 
   def project do
     [app: :exkube,
-     version: "0.1.0",
+     version: "0.1.1",
      description: description(),
      package: package(),
-     links: links(),
      elixir: "~> 1.4",
      build_embedded: Mix.env == :prod,
      start_permanent: Mix.env == :prod,
@@ -36,7 +35,8 @@ defmodule Exkube.Mixfile do
   defp deps do
     [
       {:httpoison, "~> 0.11.2"},
-      {:poison, "~> 3.1.0"}
+      {:poison, "~> 3.1.0"},
+      {:ex_doc, ">= 0.0.0", only: :dev}
     ]
   end
 
@@ -51,12 +51,13 @@ defmodule Exkube.Mixfile do
     [
       name: :exkube,
       maintainers: ["Fletcher Haynes <[email protected]>"],
-      licenses: ["Apache 2.0"]
+      licenses: ["Apache 2.0"],
+      links: links()
     ]
   end
 
   defp links do
-    %{}
+    %{"GitHub" => "https://github.com/fhaynes/exkube"}
   end
-  
+
 end

mix.lock

@@ -1,4 +1,6 @@
 %{"certifi": {:hex, :certifi, "1.2.1", "c3904f192bd5284e5b13f20db3ceac9626e14eeacfbb492e19583cf0e37b22be", [:rebar3], [], "hexpm"},
+  "earmark": {:hex, :earmark, "1.2.2", "f718159d6b65068e8daeef709ccddae5f7fdc770707d82e7d126f584cd925b74", [:mix], [], "hexpm"},
+  "ex_doc": {:hex, :ex_doc, "0.16.1", "b4b8a23602b4ce0e9a5a960a81260d1f7b29635b9652c67e95b0c2f7ccee5e81", [:mix], [{:earmark, "~> 1.1", [hex: :earmark, repo: "hexpm", optional: false]}], "hexpm"},
   "hackney": {:hex, :hackney, "1.8.6", "21a725db3569b3fb11a6af17d5c5f654052ce9624219f1317e8639183de4a423", [:rebar3], [{:certifi, "1.2.1", [hex: :certifi, repo: "hexpm", optional: false]}, {:idna, "5.0.2", [hex: :idna, repo: "hexpm", optional: false]}, {:metrics, "1.0.1", [hex: :metrics, repo: "hexpm", optional: false]}, {:mimerl, "1.0.2", [hex: :mimerl, repo: "hexpm", optional: false]}, {:ssl_verify_fun, "1.1.1", [hex: :ssl_verify_fun, repo: "hexpm", optional: false]}], "hexpm"},
   "httpoison": {:hex, :httpoison, "0.11.2", "9e59f17a473ef6948f63c51db07320477bad8ba88cf1df60a3eee01150306665", [:mix], [{:hackney, "~> 1.8.0", [hex: :hackney, repo: "hexpm", optional: false]}], "hexpm"},
   "idna": {:hex, :idna, "5.0.2", "ac203208ada855d95dc591a764b6e87259cb0e2a364218f215ad662daa8cd6b4", [:rebar3], [{:unicode_util_compat, "0.2.0", [hex: :unicode_util_compat, repo: "hexpm", optional: false]}], "hexpm"},

test/exkube_test.exs

@@ -1,9 +1,4 @@
 defmodule ExkubeTest do
   use ExUnit.Case
 
-
-  test "get status" do
-    result = Exkube.Base.status("https://api.kubernetes.ausw1a.int.uops.internal.unity3d.com")
-    assert result == {:ok, "ok"}
-  end
 end