scheduler

Documentation

Index

• Constants
• type Scheduler
  • func NewScheduler(schedulerOptions *options.SchedulerOptions) (*Scheduler, error)
  • func (sched *Scheduler) Run(ctx context.Context) error

Constants

const (
	// ReasonUnschedulable reason in SubscriptionScheduled SubscriptionCondition means that the scheduler
	// can't schedule the subscription right now, for example due to insufficient resources in the clusters.
	ReasonUnschedulable = "Unschedulable"

	// SchedulerError is the reason recorded for events when an error occurs during scheduling a subscription.
	SchedulerError = "SchedulerError"
)

These are reasons for a subscription's transition to a condition.

Types

type Scheduler

type Scheduler struct {
	SecureServing *apiserver.SecureServingInfo

	ClusternetInformerFactory informers.SharedInformerFactory

	// SchedulingQueue holds subscriptions to be scheduled
	SchedulingQueue workqueue.RateLimitingInterface

	// Profiles are the scheduling profiles.
	Profiles profile.Map
	// contains filtered or unexported fields
}

Scheduler defines configuration for clusternet scheduler

func NewScheduler

func NewScheduler(schedulerOptions *options.SchedulerOptions) (*Scheduler, error)

NewScheduler returns a new Scheduler.

func (*Scheduler) Run

func (sched *Scheduler) Run(ctx context.Context) error

Run begins watching and scheduling. It starts scheduling and blocked until the context is done.