scheduling

Documentation

Index

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

Types

type Scheduling

type Scheduling interface {
	// ScheduleCandidateParentsForNormalPeer schedules candidate parents to the normal peer.
	// Used only in v2 version of the grpc.
	ScheduleCandidateParentsForNormalPeer(context.Context, *resource.Peer, set.SafeSet[string])

	// ScheduleParentAndCandiateParentsForNormalPeer schedules a parent and candidate parents to the normal peer.
	// Used only in v1 version of the grpc.
	ScheduleParentsForNormalPeer(context.Context, *resource.Peer, set.SafeSet[string])

	// FindCandidateParents finds candidate parents for the peer.
	FindCandidateParents(context.Context, *resource.Peer, set.SafeSet[string]) ([]*resource.Peer, bool)
}

func New

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