frameworkext

package

Go to main page

Versions in this module

v1

v1.5.0

Jun 3, 2024

Changes in this version

type ReservationNominator

+ AddNominatedReservePod func(reservePod *corev1.Pod, nodeName string)

+ DeleteNominatedReservePod func(reservePod *corev1.Pod)

v1.4.1

Feb 26, 2024

v1.4.0

Jan 9, 2024

Changes in this version

+ func DefaultReservationNormalizeScore(maxPriority int64, reverse bool, scores ReservationScoreList) *framework.Status

type ExtendedHandle

+ GetReservationNominator func() ReservationNominator

+ RegisterErrorHandlerFilters func(preFilter PreErrorHandlerFilter, afterFilter PostErrorHandlerFilter)

type FakeScheduler

+ NodeInfos map[string]*framework.NodeInfo

type FrameworkExtender

+ RunNUMATopologyManagerAdmit func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ RunResizePod func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

type FrameworkExtenderFactory

+ func (d FrameworkExtenderFactory) RegisterErrorHandlerFilters(preFilter PreErrorHandlerFilter, postFilter PostErrorHandlerFilter)

type Option

+ func WithReservationNominator(nominator ReservationNominator) Option

+ type PostErrorHandlerFilter PreErrorHandlerFilter

+ type PreEnqueueCheck func(pod *corev1.Pod) bool

+ type PreErrorHandlerFilter func(*framework.QueuedPodInfo, error) bool

type ReservationInfo

+ OwnerMatchers []reservationutil.ReservationOwnerMatcher

+ ParseError error

+ func (ri *ReservationInfo) Match(pod *corev1.Pod) bool

type ReservationNominator

+ AddNominatedReservation func(pod *corev1.Pod, nodeName string, rInfo *ReservationInfo)

+ GetNominatedReservation func(pod *corev1.Pod, nodeName string) *ReservationInfo

+ RemoveNominatedReservations func(pod *corev1.Pod)

+ type ReservationScoreExtensions interface

+ NormalizeReservationScore func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

type ReservationScorePlugin

+ ReservationScoreExtensions func() ReservationScoreExtensions

+ type ResizePodPlugin interface

+ ResizePod func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ type SchedulerMonitor struct

+ func NewSchedulerMonitor(period time.Duration, timeout time.Duration) *SchedulerMonitor

+ func (m *SchedulerMonitor) Complete(pod *corev1.Pod)

+ func (m *SchedulerMonitor) StartMonitoring(pod *corev1.Pod)

v1.3.0

Aug 14, 2023

Changes in this version

+ var AssignedPodDelete = framework.ClusterEvent

+ func SetupCustomInformers(informerFactory informers.SharedInformerFactory)

+ type ErrorHandler func(*framework.QueuedPodInfo, error) bool

type ExtendedHandle

+ ForgetPod func(pod *corev1.Pod) error

+ RegisterErrorHandler func(handler ErrorHandler)

+ RegisterForgetPodHandler func(handler ForgetPodHandler)

+ Scheduler func() Scheduler

+ type FakeQueue struct

+ AssignedPods map[string]*corev1.Pod

+ AssignedUpdatedPods map[string]*corev1.Pod

+ Pods map[string]*corev1.Pod

+ UnschedulablePods map[string]*corev1.Pod

+ func (f *FakeQueue) Add(pod *corev1.Pod) error

+ func (f *FakeQueue) AddUnschedulableIfNotPresent(pod *framework.QueuedPodInfo, podSchedulingCycle int64) error

+ func (f *FakeQueue) AssignedPodAdded(pod *corev1.Pod)

+ func (f *FakeQueue) AssignedPodUpdated(pod *corev1.Pod)

+ func (f *FakeQueue) Delete(pod *corev1.Pod) error

+ func (f *FakeQueue) MoveAllToActiveOrBackoffQueue(event framework.ClusterEvent)

+ func (f *FakeQueue) SchedulingCycle() int64

+ func (f *FakeQueue) Update(oldPod, newPod *corev1.Pod) error

+ type FakeScheduler struct

+ AssumedPod map[string]*corev1.Pod

+ Pods map[string]*corev1.Pod

+ Queue *FakeQueue

+ func NewFakeScheduler() *FakeScheduler

+ func (f *FakeScheduler) AddPod(pod *corev1.Pod) error

+ func (f *FakeScheduler) AssumePod(pod *corev1.Pod) error

+ func (f *FakeScheduler) ForgetPod(pod *corev1.Pod) error

+ func (f *FakeScheduler) GetCache() SchedulerCache

+ func (f *FakeScheduler) GetPod(pod *corev1.Pod) (*corev1.Pod, error)

+ func (f *FakeScheduler) GetSchedulingQueue() SchedulingQueue

+ func (f *FakeScheduler) InvalidNodeInfo(nodeName string) error

+ func (f *FakeScheduler) IsAssumedPod(pod *corev1.Pod) (bool, error)

+ func (f *FakeScheduler) RemovePod(pod *corev1.Pod) error

+ func (f *FakeScheduler) UpdatePod(oldPod, newPod *corev1.Pod) error

+ type ForgetPodHandler func(pod *corev1.Pod)

type FrameworkExtender

+ RunReservationExtensionFinalRestoreReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ RunReservationExtensionPreRestoreReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod) *framework.Status

+ RunReservationExtensionRestoreReservation func(ctx context.Context, cycleState *framework.CycleState, ...) (PluginToReservationRestoreStates, *framework.Status)

+ SetConfiguredPlugins func(plugins *schedconfig.Plugins)

type FrameworkExtenderFactory

+ func (d FrameworkExtenderFactory) Error(podInfo *framework.QueuedPodInfo, err error)

+ func (d FrameworkExtenderFactory) RegisterErrorHandler(handler ErrorHandler)

+ func (f *FrameworkExtenderFactory) InitScheduler(sched Scheduler)

+ func (f *FrameworkExtenderFactory) InterceptSchedulerError(sched *scheduler.Scheduler)

+ func (f *FrameworkExtenderFactory) Scheduler() Scheduler

+ type NodeReservationRestoreStates map[string]interface

+ type PluginToNodeReservationRestoreStates map[string]NodeReservationRestoreStates

+ type PluginToReservationRestoreStates map[string]interface

+ type PodRequirement struct

+ Name string

+ Namespace string

+ Ports framework.HostPortInfo

+ Requests corev1.ResourceList

+ UID types.UID

+ func NewPodRequirement(pod *corev1.Pod) *PodRequirement

+ func (p *PodRequirement) Clone() *PodRequirement

+ type PreBindExtensions interface

+ ApplyPatch func(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ type ReservationInfo struct

+ Allocatable corev1.ResourceList

+ AllocatablePorts framework.HostPortInfo

+ Allocated corev1.ResourceList

+ AllocatedPorts framework.HostPortInfo

+ AssignedPods map[types.UID]*PodRequirement

+ Pod *corev1.Pod

+ Reservation *schedulingv1alpha1.Reservation

+ ResourceNames []corev1.ResourceName

+ func NewReservationInfo(r *schedulingv1alpha1.Reservation) *ReservationInfo

+ func NewReservationInfoFromPod(pod *corev1.Pod) *ReservationInfo

+ func (ri *ReservationInfo) AddAssignedPod(pod *corev1.Pod)

+ func (ri *ReservationInfo) Clone() *ReservationInfo

+ func (ri *ReservationInfo) GetAllocatePolicy() schedulingv1alpha1.ReservationAllocatePolicy

+ func (ri *ReservationInfo) GetName() string

+ func (ri *ReservationInfo) GetNamespace() string

+ func (ri *ReservationInfo) GetNodeName() string

+ func (ri *ReservationInfo) GetObject() metav1.Object

+ func (ri *ReservationInfo) GetPodOwners() []schedulingv1alpha1.ReservationOwner

+ func (ri *ReservationInfo) GetPriority() int32

+ func (ri *ReservationInfo) GetReservePod() *corev1.Pod

+ func (ri *ReservationInfo) IsAllocateOnce() bool

+ func (ri *ReservationInfo) IsAvailable() bool

+ func (ri *ReservationInfo) IsTerminating() bool

+ func (ri *ReservationInfo) IsUnschedulable() bool

+ func (ri *ReservationInfo) RemoveAssignedPod(pod *corev1.Pod)

+ func (ri *ReservationInfo) UID() types.UID

+ func (ri *ReservationInfo) UpdatePod(pod *corev1.Pod)

+ func (ri *ReservationInfo) UpdateReservation(r *schedulingv1alpha1.Reservation)

+ type ReservationRestorePlugin interface

+ FinalRestoreReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ PreRestoreReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod) *framework.Status

+ RestoreReservation func(ctx context.Context, cycleState *framework.CycleState, ...) (interface{}, *framework.Status)

type ReservationScore

+ Namespace string

+ UID types.UID

+ type Scheduler interface

+ GetCache func() SchedulerCache

+ GetSchedulingQueue func() SchedulingQueue

+ type SchedulerAdapter struct

+ Scheduler *scheduler.Scheduler

+ func (s *SchedulerAdapter) GetCache() SchedulerCache

+ func (s *SchedulerAdapter) GetSchedulingQueue() SchedulingQueue

+ func (s *SchedulerAdapter) MoveAllToActiveOrBackoffQueue(event framework.ClusterEvent)

+ type SchedulerCache interface

+ AddPod func(pod *corev1.Pod) error

+ AssumePod func(pod *corev1.Pod) error

+ ForgetPod func(pod *corev1.Pod) error

+ GetPod func(pod *corev1.Pod) (*corev1.Pod, error)

+ InvalidNodeInfo func(nodeName string) error

+ IsAssumedPod func(pod *corev1.Pod) (bool, error)

+ RemovePod func(pod *corev1.Pod) error

+ UpdatePod func(oldPod, newPod *corev1.Pod) error

+ type SchedulingQueue interface

+ Add func(pod *corev1.Pod) error

+ AddUnschedulableIfNotPresent func(pod *framework.QueuedPodInfo, podSchedulingCycle int64) error

+ AssignedPodAdded func(pod *corev1.Pod)

+ AssignedPodUpdated func(pod *corev1.Pod)

+ Delete func(pod *corev1.Pod) error

+ MoveAllToActiveOrBackoffQueue func(event framework.ClusterEvent)

+ SchedulingCycle func() int64

+ Update func(oldPod, newPod *corev1.Pod) error

v1.2.0

Apr 7, 2023

Changes in this version

+ const MaxReservationScore

+ const MinReservationScore

+ var DefaultTransformers []SchedulingTransformer

+ func GetNominatedReservation(cycleState *framework.CycleState) *schedulingv1alpha1.Reservation

+ func RegisterDefaultTransformers(transformers ...SchedulingTransformer)

+ func SetNominatedReservation(cycleState *framework.CycleState, reservation *schedulingv1alpha1.Reservation)

+ type FilterTransformer interface

+ BeforeFilter func(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*corev1.Pod, *framework.NodeInfo, bool)

type FrameworkExtender

+ func NewFrameworkExtender(f *FrameworkExtenderFactory, fw framework.Framework) FrameworkExtender

+ RunReservationFilterPlugins func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ RunReservationPreFilterExtensionAddPodInReservation func(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ RunReservationPreFilterExtensionRemoveReservation func(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ RunReservationScorePlugins func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (PluginToReservationScores, *framework.Status)

type FrameworkExtenderFactory

+ func (f *FrameworkExtenderFactory) GetExtender(profileName string) FrameworkExtender

+ func (f *FrameworkExtenderFactory) KoordinatorClientSet() koordinatorclientset.Interface

+ func (f *FrameworkExtenderFactory) KoordinatorSharedInformerFactory() koordinatorinformers.SharedInformerFactory

+ func (f *FrameworkExtenderFactory) NewFrameworkExtender(fw framework.Framework) FrameworkExtender

+ func (f *FrameworkExtenderFactory) Run()

+ func (f *FrameworkExtenderFactory) SharedListerAdapter() SharedListerAdapter

type Option

+ func WithDefaultTransformers(transformers ...SchedulingTransformer) Option

+ type PluginToReservationScores map[string]ReservationScoreList

+ type PreFilterTransformer interface

+ AfterPreFilter func(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod) error

+ BeforePreFilter func(handle ExtendedHandle, state *framework.CycleState, pod *corev1.Pod) (*corev1.Pod, bool)

+ type ReservationFilterPlugin interface

+ FilterReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ type ReservationNominator interface

+ NominateReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*schedulingv1alpha1.Reservation, *framework.Status)

+ type ReservationPreBindPlugin interface

+ PreBindReservation func(ctx context.Context, state *framework.CycleState, ...) *framework.Status

+ type ReservationPreFilterExtension interface

+ AddPodInReservation func(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ RemoveReservation func(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ type ReservationScore struct

+ Name string

+ Score int64

+ type ReservationScoreList []ReservationScore

+ type ReservationScorePlugin interface

+ ScoreReservation func(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)

+ type SchedulingTransformer interface

+ Name func() string

+ type ScoreTransformer interface

+ BeforeScore func(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*corev1.Pod, []*corev1.Node, bool)

+ type TemporarySnapshot struct

+ func NewTemporarySnapshot() *TemporarySnapshot

+ func (snapshot *TemporarySnapshot) Get(nodeName string) (*framework.NodeInfo, error)

+ func (snapshot *TemporarySnapshot) HavePodsWithAffinityList() ([]*framework.NodeInfo, error)

+ func (snapshot *TemporarySnapshot) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error)

+ func (snapshot *TemporarySnapshot) List() ([]*framework.NodeInfo, error)

+ func (snapshot *TemporarySnapshot) NodeInfos() framework.NodeInfoLister

+ func (snapshot *TemporarySnapshot) UpdateSnapshot(sharedLister framework.SharedLister) error

v1.1.1

Jan 16, 2023

v1.1.0

Dec 26, 2022

Changes in this version

+ func DebugFiltersSetter(val string) (string, error)

v1.0.0

Nov 2, 2022

Changes in this version

+ type Controller interface

+ Name func() string

+ Start func()

+ type ControllerProvider interface

+ NewControllers func() ([]Controller, error)

+ type ControllersMap struct

+ func NewControllersMap() *ControllersMap

+ func (cm *ControllersMap) RegisterControllers(plugin framework.Plugin)

+ func (cm *ControllersMap) Start()

type ExtendedHandle

+ Run func()

v0

v0.7.0

Sep 21, 2022

Changes in this version

+ func AddFlags(fs *pflag.FlagSet)

+ func DebugScoresSetter(val string) (string, error)

type ExtendedHandle

+ SnapshotSharedLister func() framework.SharedLister

type Option

+ func WithServicesEngine(engine *services.Engine) Option

+ func WithSharedListerFactory(adapter SharedListerAdapter) Option

+ type ScorePhaseHook interface

+ ScoreHook func(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*corev1.Pod, []*corev1.Node, bool)

+ type SharedListerAdapter func(lister framework.SharedLister) framework.SharedLister

v0.6.2

Aug 15, 2022

v0.6.1

Aug 5, 2022

v0.6.0

Aug 4, 2022

Changes in this version

+ type FilterPhaseHook interface

+ FilterHook func(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*corev1.Pod, *framework.NodeInfo, bool)

+ type FrameworkExtender interface

+ type FrameworkExtenderFactory interface

+ New func(f framework.Framework) FrameworkExtender

+ func NewFrameworkExtenderFactory(handle ExtendedHandle, hooks ...SchedulingPhaseHook) FrameworkExtenderFactory

+ type PreFilterPhaseHook interface

+ PreFilterHook func(handle ExtendedHandle, state *framework.CycleState, pod *corev1.Pod) (*corev1.Pod, bool)

+ type SchedulingPhaseHook interface

+ Name func() string

v0.5.0

Jun 30, 2022

Changes in this version

type ExtendedHandle

+ NodeResourceTopologySharedInformerFactory func() nrtinformers.SharedInformerFactory

+ type Option func(*extendedHandleOptions)

+ func WithKoordinatorClientSet(koordinatorClientSet koordinatorclientset.Interface) Option

+ func WithKoordinatorSharedInformerFactory(informerFactory koordinatorinformers.SharedInformerFactory) Option

+ func WithNodeResourceTopologySharedInformerFactory(informerFactory nrtinformers.SharedInformerFactory) Option

v0.4.1

Jun 8, 2022

v0.4.0

May 31, 2022

Changes in this version

+ func PluginFactoryProxy(extendHandle ExtendedHandle, factoryFn frameworkruntime.PluginFactory) frameworkruntime.PluginFactory

+ type ExtendedHandle interface

+ KoordinatorClientSet func() koordinatorclientset.Interface

+ KoordinatorSharedInformerFactory func() koordinatorinformers.SharedInformerFactory

+ func NewExtendedHandle(koordinatorClientSet koordinatorclientset.Interface, ...) ExtendedHandle

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL