descheduler

Documentation

Index

• type Descheduler
  • func New(client clientset.Interface, informerFactory informers.SharedInformerFactory, ...) (*Descheduler, error)
  • func (d *Descheduler) Start(ctx context.Context) error
• type FrameworkCapturer
• type Option
  • func WithBuildFrameworkCapturer(fc FrameworkCapturer) Option
  • func WithComponentConfigVersion(apiVersion string) Option
  • func WithDeschedulingInterval(interval time.Duration) Option
  • func WithDryRun(dryRun bool) Option
  • func WithFrameworkOutOfTreeRegistry(registry frameworkruntime.Registry) Option
  • func WithKubeConfig(cfg *restclient.Config) Option
  • func WithNodeSelector(nodeSelector *metav1.LabelSelector) Option
  • func WithPodAssignedToNodeFn(fn PodAssignedToNodeFn) Option
  • func WithProfiles(p ...deschedulerconfig.DeschedulerProfile) Option
• type PodAssignedToNodeFn

Types

type Descheduler

type Descheduler struct {
	// Profiles are the descheduling profiles.
	Profiles profile.Map

	// Close this to shut down the scheduler.
	StopEverything <-chan struct{}
	// contains filtered or unexported fields
}

func New

func New(client clientset.Interface,
	informerFactory informers.SharedInformerFactory,
	dynInformerFactory dynamicinformer.DynamicSharedInformerFactory,
	recorderFactory profile.RecorderFactory,
	stopCh <-chan struct{},
	opts ...Option,
) (*Descheduler, error)

func (*Descheduler) Start

func (d *Descheduler) Start(ctx context.Context) error

type FrameworkCapturer

type FrameworkCapturer func(deschedulerconfig.DeschedulerProfile)

FrameworkCapturer is used for registering a notify function in building framework.

type Option

type Option func(*deschedulerOptions)

Option configures a Scheduler

func WithBuildFrameworkCapturer

func WithBuildFrameworkCapturer(fc FrameworkCapturer) Option

WithBuildFrameworkCapturer sets a notify function for getting buildFramework details.

func WithComponentConfigVersion

func WithComponentConfigVersion(apiVersion string) Option

WithComponentConfigVersion sets the component config version to the DeschedulerConfiguration version used. The string should be the full scheme group/version of the external type we converted from (for example "descheduler/v1alpha2")

func WithDeschedulingInterval

func WithDeschedulingInterval(interval time.Duration) Option

func WithDryRun

func WithDryRun(dryRun bool) Option

func WithFrameworkOutOfTreeRegistry

func WithFrameworkOutOfTreeRegistry(registry frameworkruntime.Registry) Option

WithFrameworkOutOfTreeRegistry sets the registry for out-of-tree plugins. Those plugins will be appended to the default registry.

func WithKubeConfig

func WithKubeConfig(cfg *restclient.Config) Option

func WithNodeSelector

func WithNodeSelector(nodeSelector *metav1.LabelSelector) Option

func WithPodAssignedToNodeFn

func WithPodAssignedToNodeFn(fn PodAssignedToNodeFn) Option

func WithProfiles

func WithProfiles(p ...deschedulerconfig.DeschedulerProfile) Option

type PodAssignedToNodeFn

type PodAssignedToNodeFn func(nodeName string) ([]*corev1.Pod, error)