scheduler

May 25, 2022

Changes in this version

+ const UnknownZone

Jan 25, 2022

Changes in this version

+ type SchedulerFunc func(vpod VPod) ([]duckv1alpha1.Placement, error)

+ func (f SchedulerFunc) Schedule(vpod VPod) ([]duckv1alpha1.Placement, error)

Nov 1, 2021

Changes in this version

+ const MaxWeight

+ const MinWeight

+ const ZoneLabel

+ var ErrNotEnoughReplicas = errors.New("scheduling failed (not enough pod replicas)")

+ func GetPlacementForPod(placements []duckv1alpha1.Placement, podName string) *duckv1alpha1.Placement

+ func GetPodCount(placements []duckv1alpha1.Placement) int

+ func GetTotalVReplicas(placements []duckv1alpha1.Placement) int32

+ type Evictor func(pod *corev1.Pod, vpod VPod, from *duckv1alpha1.Placement) error

+ type PredicatePolicy struct

+ Args interface{}

+ Name string

+ type PriorityPolicy struct

+ Args interface{}

+ Name string

+ Weight uint64

+ type Scheduler interface

+ Schedule func(vpod VPod) ([]duckv1alpha1.Placement, error)

+ type SchedulerPolicy struct

+ Predicates []PredicatePolicy

+ Priorities []PriorityPolicy

+ type SchedulerPolicyType string

+ const MAXFILLUP

+ const PodAnnotationKey

+ type VPod interface

+ GetKey func() types.NamespacedName

+ GetPlacements func() []duckv1alpha1.Placement

+ GetResourceVersion func() string

+ GetVReplicas func() int32

+ type VPodLister func() ([]VPod, error)