Documentation
¶
Index ¶
Constants ¶
View Source
const ( MaxInFlightNodes = 15 WaitingInFlightNodesPeriod = 20 * time.Second )
Variables ¶
This section is empty.
Functions ¶
func NewUnscheduledPodHandler ¶
func NewUnscheduledPodHandler(ctx context.Context, scheduler *scheduler.Scheduler, allocator *gpuallocator.GpuAllocator, recorder record.EventRecorder) (*UnscheduledPodHandler, *NodeExpander)
Types ¶
type NodeExpander ¶
type NodeExpander struct {
// contains filtered or unexported fields
}
func NewNodeExpander ¶
func NewNodeExpander( ctx context.Context, allocator *gpuallocator.GpuAllocator, scheduler *scheduler.Scheduler, recorder record.EventRecorder, ) *NodeExpander
func (*NodeExpander) ProcessExpansion ¶
func (*NodeExpander) RemoveInFlightNode ¶
func (e *NodeExpander) RemoveInFlightNode(nodeName string)
func (*NodeExpander) RemovePreSchedulePod ¶
func (e *NodeExpander) RemovePreSchedulePod(podName string, stopTimer bool)
type UnscheduledPodHandler ¶
type UnscheduledPodHandler struct {
// contains filtered or unexported fields
}
func (*UnscheduledPodHandler) HandleRejectedPod ¶
func (h *UnscheduledPodHandler) HandleRejectedPod(ctx context.Context, podInfo *framework.QueuedPodInfo, status *fwk.Status)
Source Files
Click to show internal directories.
Click to hide internal directories.