scheduler

Documentation

Index

• type Option
  • func WithEnableSchedulerEstimator(enableSchedulerEstimator bool) Option
  • func WithSchedulerEstimatorPort(schedulerEstimatorPort int) 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 WithEnableSchedulerEstimator

func WithEnableSchedulerEstimator(enableSchedulerEstimator bool) Option

WithEnableSchedulerEstimator sets the enableSchedulerEstimator for scheduler

func WithSchedulerEstimatorPort

func WithSchedulerEstimatorPort(schedulerEstimatorPort int) Option

WithSchedulerEstimatorPort sets the schedulerEstimatorPort 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"

	// FailoverSchedule means one of the cluster a binding object associated with becomes failure.
	FailoverSchedule ScheduleType = "FailoverSchedule"
)

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