scheduler

Documentation

Index

• Constants
• 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 WithRateLimiterOptions(rateLimiterOptions ratelimiterflag.Options) Option
  • func WithSchedulerEstimatorConnection(port int, certFile, keyFile, trustedCAFile string, insecureSkipVerify bool) Option
  • func WithSchedulerEstimatorServicePrefix(schedulerEstimatorServicePrefix string) Option
  • func WithSchedulerEstimatorTimeout(schedulerEstimatorTimeout metav1.Duration) Option
  • func WithSchedulerName(schedulerName string) Option
• type ScheduleType
• type Scheduler
  • func NewScheduler(dynamicClient dynamic.Interface, karmadaClient karmadaclientset.Interface, ...) (*Scheduler, error)
  • func (s *Scheduler) Run(ctx context.Context)

Constants

const (
	// DefaultScheduler defines the name of default scheduler.
	DefaultScheduler = "default-scheduler"
)

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 WithRateLimiterOptions

func WithRateLimiterOptions(rateLimiterOptions ratelimiterflag.Options) Option

WithRateLimiterOptions sets the rateLimiterOptions for scheduler

func WithSchedulerEstimatorConnection

func WithSchedulerEstimatorConnection(port int, certFile, keyFile, trustedCAFile string, insecureSkipVerify bool) Option

WithSchedulerEstimatorConnection sets the grpc config 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

func WithSchedulerName

func WithSchedulerName(schedulerName string) Option

WithSchedulerName sets the schedulerName 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