scheduler

Documentation

Index

• type Scheduler
  • func New(cfg *config.SchedulerConfig, dynconfig config.DynconfigInterface, ...) Scheduler

Types

type Scheduler

type Scheduler interface {
	// ScheduleParent schedule a parent and candidates to a peer.
	ScheduleParent(context.Context, *resource.Peer, set.SafeSet[string])

	// Find the parent that best matches the evaluation and notify peer.
	NotifyAndFindParent(context.Context, *resource.Peer, set.SafeSet[string]) ([]*resource.Peer, bool)

	// Find the parent that best matches the evaluation.
	FindParent(context.Context, *resource.Peer, set.SafeSet[string]) (*resource.Peer, bool)
}

func New

func New(cfg *config.SchedulerConfig, dynconfig config.DynconfigInterface, pluginDir string) Scheduler