scheduler

package
v1.13.0-alpha.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 31, 2018 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// BindTimeoutSeconds defines the default bind timeout
	BindTimeoutSeconds = 100
)

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeConfigurator added in v1.10.0

type FakeConfigurator struct {
	Config *factory.Config
}

FakeConfigurator is an implementation for test.

func (*FakeConfigurator) Create added in v1.10.0

func (fc *FakeConfigurator) Create() (*factory.Config, error)

Create returns FakeConfigurator.Config

func (*FakeConfigurator) CreateFromConfig added in v1.10.0

func (fc *FakeConfigurator) CreateFromConfig(policy schedulerapi.Policy) (*factory.Config, error)

CreateFromConfig returns FakeConfigurator.Config

func (*FakeConfigurator) CreateFromKeys added in v1.10.0

func (fc *FakeConfigurator) CreateFromKeys(predicateKeys, priorityKeys sets.String, extenders []algorithm.SchedulerExtender) (*factory.Config, error)

CreateFromKeys returns FakeConfigurator.Config

func (*FakeConfigurator) CreateFromProvider added in v1.10.0

func (fc *FakeConfigurator) CreateFromProvider(providerName string) (*factory.Config, error)

CreateFromProvider returns FakeConfigurator.Config

func (*FakeConfigurator) GetClient added in v1.10.0

func (fc *FakeConfigurator) GetClient() clientset.Interface

GetClient is not implemented yet.

func (*FakeConfigurator) GetHardPodAffinitySymmetricWeight added in v1.10.0

func (fc *FakeConfigurator) GetHardPodAffinitySymmetricWeight() int32

GetHardPodAffinitySymmetricWeight is not implemented yet.

func (*FakeConfigurator) GetNodeLister added in v1.10.0

func (fc *FakeConfigurator) GetNodeLister() corelisters.NodeLister

GetNodeLister is not implemented yet.

func (*FakeConfigurator) GetPredicateMetadataProducer added in v1.10.0

func (fc *FakeConfigurator) GetPredicateMetadataProducer() (algorithm.PredicateMetadataProducer, error)

GetPredicateMetadataProducer is not implemented yet.

func (*FakeConfigurator) GetPredicates added in v1.10.0

func (fc *FakeConfigurator) GetPredicates(predicateKeys sets.String) (map[string]algorithm.FitPredicate, error)

GetPredicates is not implemented yet.

func (*FakeConfigurator) GetScheduledPodLister added in v1.10.0

func (fc *FakeConfigurator) GetScheduledPodLister() corelisters.PodLister

GetScheduledPodLister is not implemented yet.

func (*FakeConfigurator) MakeDefaultErrorFunc added in v1.10.0

func (fc *FakeConfigurator) MakeDefaultErrorFunc(backoff *util.PodBackoff, podQueue internalqueue.SchedulingQueue) func(pod *v1.Pod, err error)

MakeDefaultErrorFunc is not implemented yet.

type Option

type Option func(*schedulerOptions)

Option configures a Scheduler

func WithBindTimeoutSeconds

func WithBindTimeoutSeconds(bindTimeoutSeconds int64) Option

WithBindTimeoutSeconds sets bindTimeoutSeconds for Scheduler, the default value is 100

func WithEquivalenceClassCacheEnabled

func WithEquivalenceClassCacheEnabled(enableEquivalenceClassCache bool) Option

WithEquivalenceClassCacheEnabled sets enableEquivalenceClassCache for Scheduler, the default value is false

func WithHardPodAffinitySymmetricWeight

func WithHardPodAffinitySymmetricWeight(hardPodAffinitySymmetricWeight int32) Option

WithHardPodAffinitySymmetricWeight sets hardPodAffinitySymmetricWeight for Scheduler, the default value is 1

func WithName

func WithName(schedulerName string) Option

WithName sets schedulerName for Scheduler, the default schedulerName is default-scheduler

func WithPercentageOfNodesToScore

func WithPercentageOfNodesToScore(percentageOfNodesToScore int32) Option

WithPercentageOfNodesToScore sets percentageOfNodesToScore for Scheduler, the default value is 50

func WithPreemptionDisabled

func WithPreemptionDisabled(disablePreemption bool) Option

WithPreemptionDisabled sets disablePreemption for Scheduler, the default value is false

type Scheduler

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

Scheduler watches for new unscheduled pods. It attempts to find nodes that they fit on and writes bindings back to the api server.

func New

func New(client clientset.Interface,
	nodeInformer coreinformers.NodeInformer,
	podInformer coreinformers.PodInformer,
	pvInformer coreinformers.PersistentVolumeInformer,
	pvcInformer coreinformers.PersistentVolumeClaimInformer,
	replicationControllerInformer coreinformers.ReplicationControllerInformer,
	replicaSetInformer appsinformers.ReplicaSetInformer,
	statefulSetInformer appsinformers.StatefulSetInformer,
	serviceInformer coreinformers.ServiceInformer,
	pdbInformer policyinformers.PodDisruptionBudgetInformer,
	storageClassInformer storageinformers.StorageClassInformer,
	recorder record.EventRecorder,
	schedulerAlgorithmSource kubeschedulerconfig.SchedulerAlgorithmSource,
	opts ...func(o *schedulerOptions)) (*Scheduler, error)

New returns a Scheduler

func NewFromConfig added in v1.10.0

func NewFromConfig(config *factory.Config) *Scheduler

NewFromConfig returns a new scheduler using the provided Config.

func NewFromConfigurator added in v1.10.0

func NewFromConfigurator(c factory.Configurator, modifiers ...func(c *factory.Config)) (*Scheduler, error)

NewFromConfigurator returns a new scheduler that is created entirely by the Configurator. Assumes Create() is implemented. Supports intermediate Config mutation for now if you provide modifier functions which will run after Config is created.

func (*Scheduler) Cache added in v1.12.0

func (sched *Scheduler) Cache() schedulerinternalcache.Cache

Cache returns the cache in scheduler for test to check the data in scheduler.

func (*Scheduler) Config added in v1.10.0

func (sched *Scheduler) Config() *factory.Config

Config returns scheduler's config pointer. It is exposed for testing purposes.

func (*Scheduler) Run added in v1.10.0

func (sched *Scheduler) Run()

Run begins watching and scheduling. It waits for cache to be synced, then starts a goroutine and returns immediately.

func (*Scheduler) StopEverything added in v1.10.0

func (sched *Scheduler) StopEverything()

StopEverything closes the scheduler config's StopEverything channel, to shut down the Scheduler.

Directories

Path Synopsis
Package algorithm contains a generic Scheduler interface and several implementations.
Package algorithm contains a generic Scheduler interface and several implementations.
api
Package api contains scheduler API objects.
Package api contains scheduler API objects.
v1
Package v1 contains scheduler API objects.
Package v1 contains scheduler API objects.
apis
equivalence
Package equivalence defines Pod equivalence classes and the equivalence class cache.
Package equivalence defines Pod equivalence classes and the equivalence class cache.
Package factory can set up a scheduler.
Package factory can set up a scheduler.
internal

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL