Bonny.Server.Scheduler

[coryodaniel]

Kubernetes scheduler server.

All nodes and pods are automatically selected from Bonny.Config.cluster_name/0. pods/0 and nodes/0 are overridable callbacks of Bonny.Server.Scheduler

defmodule MyScheduler do
  use Bonny.Server.Scheduler, name: "foo"

  @impl Bonny.Server.Scheduler
  def select_node_for_pod(_pod, nodes) do
    nodes
    |> Stream.filter(fn(node) ->
      name = K8s.Resource.name(node)
      String.contains?(name, "preempt")
    end)
    |> Enum.take(1)
    |> List.first
  end
end

MyScheduler.start_link()