frameworkext

Documentation

Index

• func AddFlags(fs *pflag.FlagSet)
• func DebugFiltersSetter(val string) (string, error)
• func DebugScoresSetter(val string) (string, error)
• func PluginFactoryProxy(extendHandle ExtendedHandle, factoryFn frameworkruntime.PluginFactory) frameworkruntime.PluginFactory
• type Controller
• type ControllerProvider
• type ControllersMap
  • func NewControllersMap() *ControllersMap
  • func (cm *ControllersMap) RegisterControllers(plugin framework.Plugin)
  • func (cm *ControllersMap) Start()
• type ExtendedHandle
  • func NewExtendedHandle(options ...Option) ExtendedHandle
• type FilterPhaseHook
• type FrameworkExtender
• type FrameworkExtenderFactory
  • func NewFrameworkExtenderFactory(handle ExtendedHandle, hooks ...SchedulingPhaseHook) FrameworkExtenderFactory
• type Option
  • func WithKoordinatorClientSet(koordinatorClientSet koordinatorclientset.Interface) Option
  • func WithKoordinatorSharedInformerFactory(informerFactory koordinatorinformers.SharedInformerFactory) Option
  • func WithServicesEngine(engine *services.Engine) Option
  • func WithSharedListerFactory(adapter SharedListerAdapter) Option
• type PreFilterPhaseHook
• type SchedulingPhaseHook
• type ScorePhaseHook
• type SharedListerAdapter

Functions

func AddFlags

func AddFlags(fs *pflag.FlagSet)

func DebugFiltersSetter

func DebugFiltersSetter(val string) (string, error)

DebugFiltersSetter updates debugFilterFailure to specified value

func DebugScoresSetter

func DebugScoresSetter(val string) (string, error)

DebugScoresSetter updates debugTopNScores to specified value

func PluginFactoryProxy

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

PluginFactoryProxy is used to proxy the call to the PluginFactory function and pass in the ExtendedHandle for the custom plugin

Types

type Controller

type Controller interface {
	Start()
	Name() string
}

type ControllerProvider

type ControllerProvider interface {
	NewControllers() ([]Controller, error)
}

type ControllersMap

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

func NewControllersMap

func NewControllersMap() *ControllersMap

func (*ControllersMap) RegisterControllers

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

func (*ControllersMap) Start

func (cm *ControllersMap) Start()

type ExtendedHandle

type ExtendedHandle interface {
	framework.Handle
	KoordinatorClientSet() koordinatorclientset.Interface
	KoordinatorSharedInformerFactory() koordinatorinformers.SharedInformerFactory
	SnapshotSharedLister() framework.SharedLister
	Run()
}

ExtendedHandle extends the k8s scheduling framework Handle interface to facilitate plugins to access Koordinator's resources and states.

func NewExtendedHandle

func NewExtendedHandle(options ...Option) ExtendedHandle

type FilterPhaseHook

type FilterPhaseHook interface {
	SchedulingPhaseHook
	FilterHook(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, nodeInfo *framework.NodeInfo) (*corev1.Pod, *framework.NodeInfo, bool)
}

type FrameworkExtender

type FrameworkExtender interface {
	framework.Framework
}

type FrameworkExtenderFactory

type FrameworkExtenderFactory interface {
	New(f framework.Framework) FrameworkExtender
}

func NewFrameworkExtenderFactory

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

type Option

type Option func(*extendedHandleOptions)

func WithKoordinatorClientSet

func WithKoordinatorClientSet(koordinatorClientSet koordinatorclientset.Interface) Option

func WithKoordinatorSharedInformerFactory

func WithKoordinatorSharedInformerFactory(informerFactory koordinatorinformers.SharedInformerFactory) Option

func WithServicesEngine

func WithServicesEngine(engine *services.Engine) Option

func WithSharedListerFactory

func WithSharedListerFactory(adapter SharedListerAdapter) Option

type PreFilterPhaseHook

type PreFilterPhaseHook interface {
	SchedulingPhaseHook
	PreFilterHook(handle ExtendedHandle, state *framework.CycleState, pod *corev1.Pod) (*corev1.Pod, bool)
}

type SchedulingPhaseHook

type SchedulingPhaseHook interface {
	Name() string
}

type ScorePhaseHook

type ScorePhaseHook interface {
	SchedulingPhaseHook
	ScoreHook(handle ExtendedHandle, cycleState *framework.CycleState, pod *corev1.Pod, nodes []*corev1.Node) (*corev1.Pod, []*corev1.Node, bool)
}

type SharedListerAdapter

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