Bella.Server.Watcher behaviour (bella v0.0.1) View Source

    defmodule PodLifecycleLogger do
      use Bella.Server.Watcher

      @impl true
      def watch_operation() do
        K8s.Client.list("v1", :pods, namespace: :all)
      end

      @impl true
      def add(pod) do
        log_event(:add, pod)
      end

      @impl true
      def modify(pod) do
        log_event(:modify, pod)
      end

      @impl true
      def delete(pod) do
        log_event(:delete, pod)
      end

      @spec log_event(atom, map) :: :ok
      def log_event(type, pod) do
        name = get_in(pod, ["metadata", "name"])
        namespace = get_in(pod, ["metadata", "namepace"]) || "default"
        # log type,name,namespace here
      end
    end

Link to this section Functions

dispatch(map, controller)

Specs

dispatch(map(), atom()) :: no_return()

Dispatches an ADDED, MODIFIED, and DELETED events to an controller

process_line(line, current_rv, module)

Specs

process_line(binary(), binary(), module()) :: {:ok, binary()} | {:error, :gone}

process_lines(lines, rv, module)

Specs

process_lines([binary()], binary(), module()) ::
  {:ok, binary()} | {:error, :gone}

watch(module, rv, pid)

Specs

watch(module(), binary(), pid()) :: no_return()