kazan (k8s elixir lib) code

try_kazan.ex

defmodule Replicator do
  @moduledoc """
  Documentation for Replicator.
  """

  def try_kazan do
    server = Kazan.Server.from_kubeconfig("/home/rdesousa/.kube/config")

    {:ok, res} =
      Kazan.Apis.Core.V1.list_namespaced_pod!("test")
      |> Kazan.run(server: server)

    version = List.last(res.items).metadata.resource_version

    Kazan.Apis.Core.V1.watch_namespaced_pod_list!("test")
    |> Kazan.Watcher.start_link(server: server, send_to: self(), resource_version: version)
  end

  def handle_info(object, state) do
    {:noreply, state}
  end
end