schedule

Documentation

Index

• func NewController(clusters []*cluster.Cluster, kClients map[string]kubernetes.Interface, ...) (*controller.Controller, error)
• type Scheduler
• type SchedulerShim

Functions

func NewController

func NewController(clusters []*cluster.Cluster, kClients map[string]kubernetes.Interface, impersonatingKClients map[string]map[string]kubernetes.Interface, s Scheduler) (*controller.Controller, error)

Types

type Scheduler

type Scheduler interface {
	Reset()
	SetPod(p *corev1.Pod)
	SetNode(n *corev1.Node)
	SetNodePool(np *v1alpha1.NodePool)
	Schedule(p *corev1.Pod) (string, error)
}

type SchedulerShim

type SchedulerShim interface {
	Schedule(pod *corev1.Pod, srcClusterName string) (targetClusterName string, err error)
}