Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.