k8s

Documentation

Index

• func NewFrameworkHandle(nodeMap map[string]*framework.NodeInfo, client kubernetes.Interface, ...) framework.Handle
• type Framework
  • func (f *Framework) AddNominatedPod(logger klog.Logger, pod *framework.PodInfo, ...)
  • func (f *Framework) ClientSet() kubernetes.Interface
  • func (f *Framework) DeleteNominatedPodIfExists(pod *v1.Pod)
  • func (f *Framework) EventRecorder() events.EventRecorder
  • func (f *Framework) Extenders() []framework.Extender
  • func (f *Framework) GetWaitingPod(uid types.UID) framework.WaitingPod
  • func (f *Framework) HasFilterPlugins() bool
  • func (f *Framework) HasScorePlugins() bool
  • func (f *Framework) IterateOverWaitingPods(callback func(framework.WaitingPod))
  • func (f *Framework) KubeConfig() *rest.Config
  • func (f *Framework) ListPlugins() map[string][]config.Plugin
  • func (f *Framework) NominatedPodsForNode(nodeName string) []*framework.PodInfo
  • func (f *Framework) Parallelizer() parallelize.Parallelizer
  • func (f *Framework) RejectWaitingPod(uid types.UID) bool
  • func (f *Framework) RunFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (f *Framework) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (f *Framework) RunPreFilterExtensionAddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (f *Framework) RunPreFilterExtensionRemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (f *Framework) RunPreScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (f *Framework) RunScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) ([]framework.NodePluginScores, *framework.Status)
  • func (f *Framework) SharedInformerFactory() informers.SharedInformerFactory
  • func (f *Framework) SnapshotSharedLister() framework.SharedLister
  • func (f *Framework) UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo)
  • func (f *Framework) VolumeBinder() scheduling.SchedulerVolumeBinder
• type Snapshot
  • func NewEmptySnapshot() *Snapshot
  • func NewSnapshot(nodeInfoMap map[string]*framework.NodeInfo) *Snapshot
  • func (s *Snapshot) Get(nodeName string) (*framework.NodeInfo, error)
  • func (s *Snapshot) HavePodsWithAffinityList() ([]*framework.NodeInfo, error)
  • func (s *Snapshot) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error)
  • func (s *Snapshot) IsPVCUsedByPods(key string) bool
  • func (s *Snapshot) List() ([]*framework.NodeInfo, error)
  • func (s *Snapshot) NodeInfos() framework.NodeInfoLister
  • func (s *Snapshot) Pods() scheduler.PodsLister
  • func (s *Snapshot) StorageInfos() framework.StorageInfoLister

Functions

func NewFrameworkHandle

func NewFrameworkHandle(nodeMap map[string]*framework.NodeInfo, client kubernetes.Interface, informerFactory informers.SharedInformerFactory) framework.Handle

NewFrameworkHandle creates a FrameworkHandle interface, which is used by k8s plugins.

Types

type Framework

type Framework struct {
	// contains filtered or unexported fields
}

Framework is a K8S framework who mainly provides some methods about snapshot and plugins such as predicates

func (*Framework) AddNominatedPod

func (f *Framework) AddNominatedPod(logger klog.Logger, pod *framework.PodInfo, nominatingInfo *framework.NominatingInfo)

func (*Framework) ClientSet

func (f *Framework) ClientSet() kubernetes.Interface

ClientSet returns a kubernetes clientset.

func (*Framework) DeleteNominatedPodIfExists

func (f *Framework) DeleteNominatedPodIfExists(pod *v1.Pod)

func (*Framework) EventRecorder

func (f *Framework) EventRecorder() events.EventRecorder

EventRecorder was introduced in k8s v1.19.6 and to be implemented

func (*Framework) Extenders

func (f *Framework) Extenders() []framework.Extender

func (*Framework) GetWaitingPod

func (f *Framework) GetWaitingPod(uid types.UID) framework.WaitingPod

GetWaitingPod returns a reference to a WaitingPod given its UID.

func (*Framework) HasFilterPlugins

func (f *Framework) HasFilterPlugins() bool

HasFilterPlugins returns true if at least one filter plugin is defined.

func (*Framework) HasScorePlugins

func (f *Framework) HasScorePlugins() bool

HasScorePlugins returns true if at least one score plugin is defined.

func (*Framework) IterateOverWaitingPods

func (f *Framework) IterateOverWaitingPods(callback func(framework.WaitingPod))

IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map.

func (*Framework) KubeConfig

func (f *Framework) KubeConfig() *rest.Config

func (*Framework) ListPlugins

func (f *Framework) ListPlugins() map[string][]config.Plugin

ListPlugins returns a map of extension point name to plugin names configured at each extension point. Returns nil if no plugins where configred.

func (*Framework) NominatedPodsForNode

func (f *Framework) NominatedPodsForNode(nodeName string) []*framework.PodInfo

func (*Framework) Parallelizer

func (f *Framework) Parallelizer() parallelize.Parallelizer

func (*Framework) RejectWaitingPod

func (f *Framework) RejectWaitingPod(uid types.UID) bool

func (*Framework) RunFilterPlugins

func (f *Framework) RunFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, info *framework.NodeInfo) *framework.Status

func (*Framework) RunFilterPluginsWithNominatedPods

func (f *Framework) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, info *framework.NodeInfo) *framework.Status

func (*Framework) RunPreFilterExtensionAddPod

func (f *Framework) RunPreFilterExtensionAddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status

func (*Framework) RunPreFilterExtensionRemovePod

func (f *Framework) RunPreFilterExtensionRemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status

func (*Framework) RunPreScorePlugins

func (f *Framework) RunPreScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node) *framework.Status

func (*Framework) RunScorePlugins

func (f *Framework) RunScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*v1.Node) ([]framework.NodePluginScores, *framework.Status)

func (*Framework) SharedInformerFactory

func (f *Framework) SharedInformerFactory() informers.SharedInformerFactory

SharedInformerFactory returns a shared informer factory.

func (*Framework) SnapshotSharedLister

func (f *Framework) SnapshotSharedLister() framework.SharedLister

SnapshotSharedLister returns the scheduler's SharedLister of the latest NodeInfo snapshot. The snapshot is taken at the beginning of a scheduling cycle and remains unchanged until a pod finishes "Reserve". There is no guarantee that the information remains unchanged after "Reserve".

func (*Framework) UpdateNominatedPod

func (f *Framework) UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo)

func (*Framework) VolumeBinder

func (f *Framework) VolumeBinder() scheduling.SchedulerVolumeBinder

VolumeBinder returns the volume binder used by scheduler.

type Snapshot

type Snapshot struct {
	// contains filtered or unexported fields
}

Snapshot is a snapshot of cache NodeInfo and NodeTree order. The scheduler takes a snapshot at the beginning of each scheduling cycle and uses it for its operations in that cycle.

func NewEmptySnapshot

func NewEmptySnapshot() *Snapshot

NewEmptySnapshot initializes a Snapshot struct and returns it.

func NewSnapshot

func NewSnapshot(nodeInfoMap map[string]*framework.NodeInfo) *Snapshot

NewSnapshot initializes a Snapshot struct and returns it.

func (*Snapshot) Get

func (s *Snapshot) Get(nodeName string) (*framework.NodeInfo, error)

Get returns the NodeInfo of the given node name.

func (*Snapshot) HavePodsWithAffinityList

func (s *Snapshot) HavePodsWithAffinityList() ([]*framework.NodeInfo, error)

HavePodsWithAffinityList returns the list of nodes with at least one pods with inter-pod affinity

func (*Snapshot) HavePodsWithRequiredAntiAffinityList

func (s *Snapshot) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error)

HavePodsWithRequiredAntiAffinityList returns the list of NodeInfos of nodes with pods with required anti-affinity terms.

func (*Snapshot) IsPVCUsedByPods

func (s *Snapshot) IsPVCUsedByPods(key string) bool

func (*Snapshot) List

func (s *Snapshot) List() ([]*framework.NodeInfo, error)

List returns the list of nodes in the snapshot.

func (*Snapshot) NodeInfos

func (s *Snapshot) NodeInfos() framework.NodeInfoLister

NodeInfos returns a NodeInfoLister.

func (*Snapshot) Pods

func (s *Snapshot) Pods() scheduler.PodsLister

Pods returns a PodLister

func (*Snapshot) StorageInfos

func (s *Snapshot) StorageInfos() framework.StorageInfoLister

StorageInfos returns a StorageInfoLister.