extender

Documentation

Overview

Package extender contains types and logic to respond to requests from a Kubernetes http scheduler extender.

Index

• func GetKubeClient(kubeConfig string) (kubernetes.Interface, *rest.Config, error)
• func GetKubeClientExt(kubeConfig string, burst int, qps float32) (kubernetes.Interface, *rest.Config, error)
• type Scheduler
• type Server
  • func (m Server) StartServer(port string, certFile string, keyFile string, caFile string, unsafe bool)

Functions

func GetKubeClient

func GetKubeClient(kubeConfig string) (kubernetes.Interface, *rest.Config, error)

GetKubeClient returns the kube client interface with its config.

func GetKubeClientExt

func GetKubeClientExt(kubeConfig string, burst int, qps float32) (kubernetes.Interface, *rest.Config, error)

GetKubeClientExt returns the kube client interface with its config. The given Burst and QPS are set into the config.

Types

type Scheduler

type Scheduler interface {
	Bind(w http.ResponseWriter, r *http.Request)
	Prioritize(w http.ResponseWriter, r *http.Request)
	Filter(w http.ResponseWriter, r *http.Request)
}

Scheduler has the capabilities needed to prioritize and filter nodes based on http requests.

type Server

type Server struct {
	Scheduler
}

Server type wraps the implementation of the extender.

func (Server) StartServer

func (m Server) StartServer(port string, certFile string, keyFile string, caFile string, unsafe bool)

StartServer starts the HTTP server needed for the scheduler extender. It registers the handlers and checks for existing telemetry policies.