kubernetes: k8s.io/kubernetes/pkg/scheduler/framework/runtime Index | Files

package runtime

import "k8s.io/kubernetes/pkg/scheduler/framework/runtime"


Package Files

framework.go metrics_recorder.go registry.go waiting_pods_map.go


const (
    // Filter is the name of the filter extension point.
    Filter = "Filter"

func DecodeInto Uses

func DecodeInto(obj runtime.Object, into interface{}) error

DecodeInto decodes configuration whose type is *runtime.Unknown to the interface into.

func NewFramework Uses

func NewFramework(r Registry, plugins *config.Plugins, args []config.PluginConfig, opts ...Option) (framework.Framework, error)

NewFramework initializes plugins given the configuration and the registry.

type Option Uses

type Option func(*frameworkOptions)

Option for the frameworkImpl.

func WithClientSet Uses

func WithClientSet(clientSet clientset.Interface) Option

WithClientSet sets clientSet for the scheduling frameworkImpl.

func WithEventRecorder Uses

func WithEventRecorder(recorder events.EventRecorder) Option

WithEventRecorder sets clientSet for the scheduling frameworkImpl.

func WithExtenders Uses

func WithExtenders(extenders []framework.Extender) Option

WithExtenders sets extenders for the scheduling frameworkImpl.

func WithInformerFactory Uses

func WithInformerFactory(informerFactory informers.SharedInformerFactory) Option

WithInformerFactory sets informer factory for the scheduling frameworkImpl.

func WithPodNominator Uses

func WithPodNominator(nominator framework.PodNominator) Option

WithPodNominator sets podNominator for the scheduling frameworkImpl.

func WithProfileName Uses

func WithProfileName(name string) Option

WithProfileName sets the profile name.

func WithRunAllFilters Uses

func WithRunAllFilters(runAllFilters bool) Option

WithRunAllFilters sets the runAllFilters flag, which means RunFilterPlugins accumulates all failure Statuses.

func WithSnapshotSharedLister Uses

func WithSnapshotSharedLister(snapshotSharedLister framework.SharedLister) Option

WithSnapshotSharedLister sets the SharedLister of the snapshot.

type PluginFactory Uses

type PluginFactory = func(configuration runtime.Object, f v1alpha1.FrameworkHandle) (v1alpha1.Plugin, error)

PluginFactory is a function that builds a plugin.

type Registry Uses

type Registry map[string]PluginFactory

Registry is a collection of all available plugins. The framework uses a registry to enable and initialize configured plugins. All plugins must be in the registry before initializing the framework.

func (Registry) Merge Uses

func (r Registry) Merge(in Registry) error

Merge merges the provided registry to the current one.

func (Registry) Register Uses

func (r Registry) Register(name string, factory PluginFactory) error

Register adds a new plugin to the registry. If a plugin with the same name exists, it returns an error.

func (Registry) Unregister Uses

func (r Registry) Unregister(name string) error

Unregister removes an existing plugin from the registry. If no plugin with the provided name exists, it returns an error.

Package runtime imports 22 packages (graph) and is imported by 36 packages. Updated 2020-09-25. Refresh now. Tools for package owners.