scheduler

Documentation

Index

• type Option
  • func WithDisableSchedulerEstimatorInPullMode(disableSchedulerEstimatorInPullMode bool) Option
  • func WithEnableEmptyWorkloadPropagation(enableEmptyWorkloadPropagation bool) Option
  • func WithEnableSchedulerEstimator(enableSchedulerEstimator bool) Option
  • func WithEnableSchedulerPlugin(plugins []string) Option
  • func WithOutOfTreeRegistry(registry runtime.Registry) Option
  • func WithSchedulerEstimatorPort(schedulerEstimatorPort int) Option
  • func WithSchedulerEstimatorServicePrefix(schedulerEstimatorServicePrefix string) Option
  • func WithSchedulerEstimatorTimeout(schedulerEstimatorTimeout metav1.Duration) Option
• type ScheduleType
• type Scheduler
  • func NewScheduler(dynamicClient dynamic.Interface, karmadaClient karmadaclientset.Interface, ...) (*Scheduler, error)
  • func (s *Scheduler) Run(ctx context.Context)

Types

type Option

type Option func(*schedulerOptions)

Option configures a Scheduler

func WithDisableSchedulerEstimatorInPullMode

func WithDisableSchedulerEstimatorInPullMode(disableSchedulerEstimatorInPullMode bool) Option

WithDisableSchedulerEstimatorInPullMode sets the disableSchedulerEstimatorInPullMode for scheduler

func WithEnableEmptyWorkloadPropagation

func WithEnableEmptyWorkloadPropagation(enableEmptyWorkloadPropagation bool) Option

WithEnableEmptyWorkloadPropagation sets the enablePropagateEmptyWorkLoad for scheduler

func WithEnableSchedulerEstimator

func WithEnableSchedulerEstimator(enableSchedulerEstimator bool) Option

WithEnableSchedulerEstimator sets the enableSchedulerEstimator for scheduler

func WithEnableSchedulerPlugin

func WithEnableSchedulerPlugin(plugins []string) Option

WithEnableSchedulerPlugin sets the scheduler-plugin for scheduler

func WithOutOfTreeRegistry

func WithOutOfTreeRegistry(registry runtime.Registry) Option

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

func WithSchedulerEstimatorPort

func WithSchedulerEstimatorPort(schedulerEstimatorPort int) Option

WithSchedulerEstimatorPort sets the schedulerEstimatorPort for scheduler

func WithSchedulerEstimatorServicePrefix

func WithSchedulerEstimatorServicePrefix(schedulerEstimatorServicePrefix string) Option

WithSchedulerEstimatorServicePrefix sets the schedulerEstimatorServicePrefix for scheduler

func WithSchedulerEstimatorTimeout

func WithSchedulerEstimatorTimeout(schedulerEstimatorTimeout metav1.Duration) Option

WithSchedulerEstimatorTimeout sets the schedulerEstimatorTimeout for scheduler

type ScheduleType

type ScheduleType string

ScheduleType defines the schedule type of a binding object should be performed.

const (
	// ReconcileSchedule means the binding object associated policy has been changed.
	ReconcileSchedule ScheduleType = "ReconcileSchedule"

	// ScaleSchedule means the replicas of binding object has been changed.
	ScaleSchedule ScheduleType = "ScaleSchedule"
)

type Scheduler

type Scheduler struct {
	DynamicClient dynamic.Interface
	KarmadaClient karmadaclientset.Interface
	KubeClient    kubernetes.Interface

	Algorithm core.ScheduleAlgorithm
	// contains filtered or unexported fields
}

Scheduler is the scheduler schema, which is used to schedule a specific resource to specific clusters

func NewScheduler

func NewScheduler(dynamicClient dynamic.Interface, karmadaClient karmadaclientset.Interface, kubeClient kubernetes.Interface, opts ...Option) (*Scheduler, error)

NewScheduler instantiates a scheduler

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context)

Run runs the scheduler