Bonny.Server.Watcher behaviour (bonny v0.4.3) View Source

Continuously watch a list Operation for add, modify, and delete events.

Link to this section Summary

Functions

dispatch(map, controller)

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

process_line(line, current_rv, module)

process_lines(lines, rv, module)

watch(module, rv, pid)

Callbacks

add(map)

delete(map)

modify(map)

watch_operation()

K8s.Operation to watch.

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()

Link to this section Callbacks

add(map)

Specs

add(map()) :: :ok | :error

delete(map)

Specs

delete(map()) :: :ok | :error

modify(map)

Specs

modify(map()) :: :ok | :error

watch_operation()

Specs

watch_operation() :: K8s.Operation.t()

K8s.Operation to watch.

Examples

Log all pod lifecycle events

    defmodule PodLifecycleLogger do
      use Bonny.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