controller

Documentation

Index

• func Start()
• type PreemptibleController
  • func NewPreemptibleController() *PreemptibleController
  • func (pc *PreemptibleController) CheckIfPodIsDeleted(p v1.Pod) error
  • func (pc *PreemptibleController) ListKubeSystemPods(nodeName string) (*v1.PodList, error)
  • func (pc *PreemptibleController) ListNodes() (*v1.NodeList, error)
  • func (pc *PreemptibleController) ListPods(nodeName string) (*v1.PodList, error)
  • func (pc *PreemptibleController) Process()
  • func (pc *PreemptibleController) ProcessPods(pods []v1.Pod)
  • func (pc *PreemptibleController) Run(stopCh <-chan struct{})

Functions

func Start

func Start()

Types

type PreemptibleController

type PreemptibleController struct {
	Client kubernetes.Interface
	Config config.Config
}

func NewPreemptibleController

func NewPreemptibleController() *PreemptibleController

func (*PreemptibleController) CheckIfPodIsDeleted

func (pc *PreemptibleController) CheckIfPodIsDeleted(p v1.Pod) error

func (*PreemptibleController) ListKubeSystemPods

func (pc *PreemptibleController) ListKubeSystemPods(nodeName string) (*v1.PodList, error)

func (*PreemptibleController) ListNodes

func (pc *PreemptibleController) ListNodes() (*v1.NodeList, error)

func (*PreemptibleController) ListPods

func (pc *PreemptibleController) ListPods(nodeName string) (*v1.PodList, error)

func (*PreemptibleController) Process

func (pc *PreemptibleController) Process()

func (*PreemptibleController) ProcessPods

func (pc *PreemptibleController) ProcessPods(pods []v1.Pod)

func (*PreemptibleController) Run

func (pc *PreemptibleController) Run(stopCh <-chan struct{})