algorithm

type ControllerLister ¶ added in v1.1.0

type ControllerLister interface {
	// Lists all the replication controllers
	List() ([]api.ReplicationController, error)
	// Gets the services for the given pod
	GetPodControllers(*api.Pod) ([]api.ReplicationController, error)
}

ControllerLister interface represents anything that can produce a list of ReplicationController; the list is consumed by a scheduler.

type EmptyControllerLister ¶ added in v1.1.0

type EmptyControllerLister struct{}

EmptyControllerLister implements ControllerLister on []api.ReplicationController returning empty data

func (f EmptyControllerLister) GetPodControllers(pod *api.Pod) (controllers []api.ReplicationController, err error)

func (f EmptyControllerLister) List() ([]api.ReplicationController, error)

type FakeControllerLister ¶ added in v1.1.0

type FakeControllerLister []api.ReplicationController

FakeControllerLister implements ControllerLister on []api.ReplicationController for test purposes.

func (f FakeControllerLister) GetPodControllers(pod *api.Pod) (controllers []api.ReplicationController, err error)

func (f FakeControllerLister) List() ([]api.ReplicationController, error)

type FakeNodeLister ¶ added in v1.1.0

type FakeNodeLister api.NodeList

FakeNodeLister implements NodeLister on a []string for test purposes.

func (f FakeNodeLister) List() (api.NodeList, error)

type FakePodLister ¶

type FakePodLister []*api.Pod

FakePodLister implements PodLister on an []api.Pods for test purposes.

func (f FakePodLister) List(s labels.Selector) (selected []*api.Pod, err error)

type FakeServiceLister ¶

type FakeServiceLister []api.Service

FakeServiceLister implements ServiceLister on []api.Service for test purposes.

func (f FakeServiceLister) GetPodServices(pod *api.Pod) (services []api.Service, err error)

func (f FakeServiceLister) List() (api.ServiceList, error)

type FitPredicate ¶

type FitPredicate func(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

FitPredicate is a function that indicates if a pod fits into an existing node.

type HostPriority ¶

type HostPriority struct {
	Host  string
	Score int
}

HostPriority represents the priority of scheduling to a particular host, lower priority is better.

type HostPriorityList ¶

type HostPriorityList []HostPriority

func (h HostPriorityList) Len() int

func (h HostPriorityList) Less(i, j int) bool

func (h HostPriorityList) Swap(i, j int)

type NodeLister ¶ added in v1.1.0

type NodeLister interface {
	List() (list api.NodeList, err error)
}

NodeLister interface represents anything that can list nodes for a scheduler.

type PodLister ¶

type PodLister interface {
	// TODO: make this exactly the same as client's Pods(ns).List() method, by returning a api.PodList
	List(labels.Selector) ([]*api.Pod, error)
}

PodLister interface represents anything that can list pods for a scheduler.

type PriorityConfig ¶

type PriorityConfig struct {
	Function PriorityFunction
	Weight   int
}

type PriorityFunction ¶

type PriorityFunction func(pod *api.Pod, podLister PodLister, nodeLister NodeLister) (HostPriorityList, error)

type ScheduleAlgorithm ¶

type ScheduleAlgorithm interface {
	Schedule(*api.Pod, NodeLister) (selectedMachine string, err error)
}

Scheduler is an interface implemented by things that know how to schedule pods onto machines.

type ServiceLister ¶

type ServiceLister interface {
	// Lists all the services
	List() (api.ServiceList, error)
	// Gets the services for the given pod
	GetPodServices(*api.Pod) ([]api.Service, error)
}

ServiceLister interface represents anything that can produce a list of services; the list is consumed by a scheduler.