scheduling

Documentation

Index

• func ConstructSuccessNormalTaskResponse(candidateParents []*resource.Peer) *schedulerv2.AnnouncePeerResponse_NormalTaskResponse
• func ConstructSuccessPeerPacket(peer *resource.Peer, parent *resource.Peer, candidateParents []*resource.Peer) *schedulerv1.PeerPacket
• type Scheduling
  • func New(cfg *config.SchedulerConfig, dynconfig config.DynconfigInterface, ...) Scheduling

Functions

func ConstructSuccessNormalTaskResponse

func ConstructSuccessNormalTaskResponse(candidateParents []*resource.Peer) *schedulerv2.AnnouncePeerResponse_NormalTaskResponse

ConstructSuccessNormalTaskResponse constructs scheduling successful response of the normal task. Used only in v2 version of the grpc.

func ConstructSuccessPeerPacket

func ConstructSuccessPeerPacket(peer *resource.Peer, parent *resource.Peer, candidateParents []*resource.Peer) *schedulerv1.PeerPacket

ConstructSuccessPeerPacket constructs peer successful packet. Used only in v1 version of the grpc.

Types

type Scheduling

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

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

	// FindCandidateParents finds candidate parents for the peer.
	// Used only in v2 version of the grpc.
	FindCandidateParents(context.Context, *resource.Peer, set.SafeSet[string]) ([]*resource.Peer, bool)

	// FindParentAndCandidateParents finds a parent and candidate parents for the peer.
	// Used only in v1 version of the grpc.
	FindParentAndCandidateParents(context.Context, *resource.Peer, set.SafeSet[string]) ([]*resource.Peer, bool)

	// FindSuccessParent finds success parent for the peer.
	FindSuccessParent(context.Context, *resource.Peer, set.SafeSet[string]) (*resource.Peer, bool)
}

func New

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