predicates

Documentation

Index

• Variables
• type Predictor
  • func NewPredictor(args *factory.PluginFactoryArgs, testMode bool) *Predictor
  • func (p *Predictor) Enabled() bool
  • func (p *Predictor) GetPredicateMeta(pod *v1.Pod, nodeNameToInfo map[string]*deschedulernode.NodeInfo) predicates.PredicateMetadata
  • func (p *Predictor) Predicates(pod *v1.Pod, meta predicates.PredicateMetadata, node *deschedulernode.NodeInfo) error
  • func (p *Predictor) RegisterFitPredicate(name string, predicate predicates.FitPredicate) string
  • func (p *Predictor) RegisterFitPredicateFactory(name string, predicateFactory factory.FitPredicateFactory) string
  • func (p *Predictor) RegisterMandatoryFitPredicate(name string, predicate predicates.FitPredicate) string
  • func (p *Predictor) RegisterPredicateMetadataProducerFactory(factory factory.PredicateMetadataProducerFactory)

Variables

var DefaultSchedulerPolicy = schedulerapi.Policy{
	Predicates: []schedulerapi.PredicatePolicy{
		{Name: predicates.MatchNodeSelectorPred},
		{Name: predicates.PodFitsResourcesPred},
		{Name: "PodFitsPorts"},
		{Name: predicates.NoDiskConflictPred},
		{Name: predicates.MatchInterPodAffinityPred},

		{Name: predicates.CheckVolumeBindingPred},
	},
}

this policy defines a configurable set of supported predicates. this should be configurable, and can be dumped as part of the scheduler configuration, which can be used to explicitly advertise what are supported.

Types

type Predictor

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

func NewPredictor

func NewPredictor(args *factory.PluginFactoryArgs, testMode bool) *Predictor

func (*Predictor) Enabled

func (p *Predictor) Enabled() bool

func (*Predictor) GetPredicateMeta

func (p *Predictor) GetPredicateMeta(pod *v1.Pod,
	nodeNameToInfo map[string]*deschedulernode.NodeInfo) predicates.PredicateMetadata

func (*Predictor) Predicates

func (p *Predictor) Predicates(pod *v1.Pod, meta predicates.PredicateMetadata, node *deschedulernode.NodeInfo) error

func (*Predictor) RegisterFitPredicate

func (p *Predictor) RegisterFitPredicate(name string, predicate predicates.FitPredicate) string

From: k8s.io/kubernetes/pkg/scheduler/factory/plugins.go RegisterFitPredicate registers a fit predicate with the algorithm registry. Returns the name with which the predicate was registered.

func (*Predictor) RegisterFitPredicateFactory

func (p *Predictor) RegisterFitPredicateFactory(name string, predicateFactory factory.FitPredicateFactory) string

From: k8s.io/kubernetes/pkg/scheduler/factory/plugins.go RegisterFitPredicateFactory registers a fit predicate factory with the algorithm registry. Returns the name with which the predicate was registered.

func (*Predictor) RegisterMandatoryFitPredicate

func (p *Predictor) RegisterMandatoryFitPredicate(name string, predicate predicates.FitPredicate) string

From: k8s.io/kubernetes/pkg/scheduler/factory/plugins.go RegisterMandatoryFitPredicate registers a fit predicate with the algorithm registry, the predicate is used by kubelet, DaemonSet; it is always included in configuration. Returns the name with which the predicate was registered.

func (*Predictor) RegisterPredicateMetadataProducerFactory

func (p *Predictor) RegisterPredicateMetadataProducerFactory(factory factory.PredicateMetadataProducerFactory)

RegisterPredicateMetadataProducerFactory registers a PredicateMetadataProducerFactory.