sneako

defmodule KinesisWriter do
  use Application

  def start(_type, _args) do
    children = [
      :poolboy.child_spec(
        :kinesis_writer_pool,
        [
          name: {:local, :kinesis_writer_pool},
          worker_module: KinesisWriter.Worker,

sneako

defmodule KinesisServer.Worker do
  use GenServer
  alias KinesisServer.Writer

  def start_link(opts \\ []) do
    GenServer.start_link(__MODULE__, Writer.new(opts))
  end

  @impl true
  def init(init_arg) do

sneako

defmodule KinesisWriter.Writer do
  @type t :: %__MODULE__{
          aggregator: ExKpl.t(),
          client: module(),
          client_opts: Keyword.t()
        }

  defstruct aggregator: ExKpl.new(),
            client: KinesisWriter.Client,
            client_opts: []

sneako

#!/usr/bin/env bash
# set -x

mkdir output

KUBECONFIG=/Users/nico/real-kubeconfig

SKIP_RESOURCES=(
  apiservices
  bindings