framework

Apr 17, 2024

Changes in this version

+ func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo

+ func NewEqualPrioritizerPlugin() frameworkruntime.PluginFactory

type FakeExtender

+ Binder func() error

+ func (f *FakeExtender) IsFilter() bool

+ func (f *FakeExtender) IsPrioritizer() bool

Dec 13, 2023

Changes in this version

+ const ErrReasonFake

+ func ErrorPredicateExtender(pod *v1.Pod, node *v1.Node) *framework.Status

+ func ErrorPrioritizerExtender(pod *v1.Pod, nodes []*v1.Node) (*framework.NodeScoreList, error)

+ func FalsePredicateExtender(pod *v1.Pod, node *v1.Node) *framework.Status

+ func NewFakeFilterPlugin(failedNodeReturnCodeMap map[string]framework.Code) frameworkruntime.PluginFactory

+ func NewFakePermitPlugin(status *framework.Status, timeout time.Duration) frameworkruntime.PluginFactory

+ func NewFakePreBindPlugin(status *framework.Status) frameworkruntime.PluginFactory

+ func NewFakePreFilterPlugin(name string, result *framework.PreFilterResult, status *framework.Status) frameworkruntime.PluginFactory

+ func NewFakePreScoreAndScorePlugin(name string, score int64, preScoreStatus, scoreStatus *framework.Status) frameworkruntime.PluginFactory

+ func NewFakeReservePlugin(status *framework.Status) frameworkruntime.PluginFactory

+ func NewFalseFilterPlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error)

+ func NewFramework(ctx context.Context, fns []RegisterPluginFunc, profileName string, ...) (framework.Framework, error)

+ func NewMatchFilterPlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error)

+ func NewNode2PrioritizerPlugin() frameworkruntime.PluginFactory

+ func NewTrueFilterPlugin(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error)

+ func Node1PredicateExtender(pod *v1.Pod, node *v1.Node) *framework.Status

+ func Node1PrioritizerExtender(pod *v1.Pod, nodes []*v1.Node) (*framework.NodeScoreList, error)

+ func Node2PredicateExtender(pod *v1.Pod, node *v1.Node) *framework.Status

+ func Node2PrioritizerExtender(pod *v1.Pod, nodes []*v1.Node) (*framework.NodeScoreList, error)

+ func TruePredicateExtender(pod *v1.Pod, node *v1.Node) *framework.Status

+ type CSINodeLister []storagev1.CSINode

+ func (n CSINodeLister) Get(name string) (*storagev1.CSINode, error)

+ func (n CSINodeLister) List(selector labels.Selector) (ret []*storagev1.CSINode, err error)

+ type ControllerLister []*v1.ReplicationController

+ func (f ControllerLister) GetPodControllers(pod *v1.Pod) (controllers []*v1.ReplicationController, err error)

+ func (f ControllerLister) List(labels.Selector) ([]*v1.ReplicationController, error)

+ func (f ControllerLister) ReplicationControllers(namespace string) corelisters.ReplicationControllerNamespaceLister

+ type FakeExtender struct

+ CachedNodeNameToInfo map[string]*framework.NodeInfo

+ ExtenderName string

+ FilteredNodes []*v1.Node

+ Ignorable bool

+ NodeCacheCapable bool

+ Predicates []FitPredicate

+ Prioritizers []PriorityConfig

+ UnInterested bool

+ Weight int64

+ func (f *FakeExtender) Bind(binding *v1.Binding) error

+ func (f *FakeExtender) Filter(pod *v1.Pod, nodes []*v1.Node) ([]*v1.Node, extenderv1.FailedNodesMap, extenderv1.FailedNodesMap, error)

+ func (f *FakeExtender) IsBinder() bool

+ func (f *FakeExtender) IsIgnorable() bool

+ func (f *FakeExtender) IsInterested(pod *v1.Pod) bool

+ func (f *FakeExtender) Name() string

+ func (f *FakeExtender) Prioritize(pod *v1.Pod, nodes []*v1.Node) (*extenderv1.HostPriorityList, int64, error)

+ func (f *FakeExtender) ProcessPreemption(pod *v1.Pod, nodeNameToVictims map[string]*extenderv1.Victims, ...) (map[string]*extenderv1.Victims, error)

+ func (f *FakeExtender) SupportsPreemption() bool

+ type FakeFilterPlugin struct

+ FailedNodeReturnCodeMap map[string]framework.Code

+ NumFilterCalled int32

+ func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *FakeFilterPlugin) Name() string

+ type FakePermitPlugin struct

+ Status *framework.Status

+ Timeout time.Duration

+ func (pl *FakePermitPlugin) Name() string

+ func (pl *FakePermitPlugin) Permit(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) (*framework.Status, time.Duration)

+ type FakePreBindPlugin struct

+ Status *framework.Status

+ func (pl *FakePreBindPlugin) Name() string

+ func (pl *FakePreBindPlugin) PreBind(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status

+ type FakePreFilterAndFilterPlugin struct

+ func (pl FakePreFilterAndFilterPlugin) Name() string

+ type FakePreFilterPlugin struct

+ Result *framework.PreFilterResult

+ Status *framework.Status

+ func (pl *FakePreFilterPlugin) Name() string

+ func (pl *FakePreFilterPlugin) PreFilter(_ context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)

+ func (pl *FakePreFilterPlugin) PreFilterExtensions() framework.PreFilterExtensions

+ type FakePreScoreAndScorePlugin struct

+ func (pl *FakePreScoreAndScorePlugin) Name() string

+ func (pl *FakePreScoreAndScorePlugin) PreScore(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *FakePreScoreAndScorePlugin) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)

+ func (pl *FakePreScoreAndScorePlugin) ScoreExtensions() framework.ScoreExtensions

+ type FakeReservePlugin struct

+ Status *framework.Status

+ func (pl *FakeReservePlugin) Name() string

+ func (pl *FakeReservePlugin) Reserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status

+ func (pl *FakeReservePlugin) Unreserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string)

+ type FalseFilterPlugin struct

+ func (pl *FalseFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *FalseFilterPlugin) Name() string

+ type FitPredicate func(pod *v1.Pod, node *v1.Node) *framework.Status

+ type MatchFilterPlugin struct

+ func (pl *MatchFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *MatchFilterPlugin) Name() string

+ type NodeInfoLister []*framework.NodeInfo

+ func (nodes NodeInfoLister) Get(nodeName string) (*framework.NodeInfo, error)

+ func (nodes NodeInfoLister) HavePodsWithAffinityList() ([]*framework.NodeInfo, error)

+ func (nodes NodeInfoLister) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error)

+ func (nodes NodeInfoLister) List() ([]*framework.NodeInfo, error)

+ type PersistentVolumeClaimLister []v1.PersistentVolumeClaim

+ func (pvcs PersistentVolumeClaimLister) List(selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error)

+ func (pvcs PersistentVolumeClaimLister) PersistentVolumeClaims(namespace string) corelisters.PersistentVolumeClaimNamespaceLister

+ type PersistentVolumeLister []v1.PersistentVolume

+ func (pvs PersistentVolumeLister) Get(pvID string) (*v1.PersistentVolume, error)

+ func (pvs PersistentVolumeLister) List(selector labels.Selector) ([]*v1.PersistentVolume, error)

+ type PriorityConfig struct

+ Function PriorityFunc

+ Weight int64

+ type PriorityFunc func(pod *v1.Pod, nodes []*v1.Node) (*framework.NodeScoreList, error)

+ type RegisterPluginFunc func(reg *runtime.Registry, profile *schedulerapi.KubeSchedulerProfile)

+ func RegisterBindPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterFilterPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterPermitPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterPluginAsExtensions(pluginName string, pluginNewFunc runtime.PluginFactory, extensions ...string) RegisterPluginFunc

+ func RegisterPluginAsExtensionsWithWeight(pluginName string, weight int32, pluginNewFunc runtime.PluginFactory, ...) RegisterPluginFunc

+ func RegisterPreBindPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterPreFilterPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterPreScorePlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterQueueSortPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterReservePlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc

+ func RegisterScorePlugin(pluginName string, pluginNewFunc runtime.PluginFactory, weight int32) RegisterPluginFunc

+ type ReplicaSetLister []*appsv1.ReplicaSet

+ func (f ReplicaSetLister) GetPodReplicaSets(pod *v1.Pod) (rss []*appsv1.ReplicaSet, err error)

+ func (f ReplicaSetLister) List(labels.Selector) ([]*appsv1.ReplicaSet, error)

+ func (f ReplicaSetLister) ReplicaSets(namespace string) appslisters.ReplicaSetNamespaceLister

+ type ServiceLister []*v1.Service

+ func (f ServiceLister) List(labels.Selector) ([]*v1.Service, error)

+ func (f ServiceLister) Services(namespace string) corelisters.ServiceNamespaceLister

+ type StatefulSetLister []*appsv1.StatefulSet

+ func (f StatefulSetLister) GetPodStatefulSets(pod *v1.Pod) (sss []*appsv1.StatefulSet, err error)

+ func (f StatefulSetLister) List(labels.Selector) ([]*appsv1.StatefulSet, error)

+ func (f StatefulSetLister) StatefulSets(namespace string) appslisters.StatefulSetNamespaceLister

+ type StorageClassLister []storagev1.StorageClass

+ func (classes StorageClassLister) Get(name string) (*storagev1.StorageClass, error)

+ func (classes StorageClassLister) List(selector labels.Selector) ([]*storagev1.StorageClass, error)

+ type TrueFilterPlugin struct

+ func (pl *TrueFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *TrueFilterPlugin) Name() string