Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultSchedulingTimeoutDuration = 5 * time.Minute
DefaultSchedulingTimeoutDuration defines how long the gang pods should wait at the Permit stage for a quorum before being rejected. Variable is exported only for testing purposes.
Functions ¶
Types ¶
type WorkloadManager ¶
type WorkloadManager interface {
fwk.WorkloadManager
// AddPod is called by the scheduler when a Pod/Add event is observed.
AddPod(pod *v1.Pod)
// UpdatePod is called by the scheduler when a Pod/Update event is observed.
UpdatePod(oldPod, newPod *v1.Pod)
// DeletePod is called by the scheduler when a Pod/Delete event is observed.
DeletePod(pod *v1.Pod)
}
WorkloadManager is the central source of truth for the state of pods belonging to Workload objects. It is designed to be driven explicitly by the scheduler's event handlers to ensure thread safety and avoid race conditions with the main scheduling queue. Note: The current implementation assumes that pod.Spec.Workload is immutable. Allowing mutability would require changes to the manager, e.g., by properly handling pod updates.
Click to show internal directories.
Click to hide internal directories.