- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for IsWait (0.09 sec)
-
pkg/scheduler/framework/interface.go
} // IsSuccess returns true if and only if "Status" is nil or Code is "Success". func (s *Status) IsSuccess() bool { return s.Code() == Success } // IsWait returns true if and only if "Status" is non-nil and its Code is "Wait". func (s *Status) IsWait() bool { return s.Code() == Wait } // IsSkip returns true if and only if "Status" is non-nil and its Code is "Skip". func (s *Status) IsSkip() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
} // Run "permit" plugins. runPermitStatus := fwk.RunPermitPlugins(ctx, state, assumedPod, scheduleResult.SuggestedHost) if !runPermitStatus.IsWait() && !runPermitStatus.IsSuccess() { // trigger un-reserve to clean up state associated with the reserved Pod fwk.RunReservePluginsUnreserve(ctx, state, assumedPod, scheduleResult.SuggestedHost)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
if status.IsRejected() { logger.V(4).Info("Pod rejected by plugin", "pod", klog.KObj(pod), "plugin", pl.Name(), "status", status.Message()) return status.WithPlugin(pl.Name()) } if status.IsWait() { // Not allowed to be greater than maxTimeout. if timeout > maxTimeout { timeout = maxTimeout } pluginsWaitTime[pl.Name()] = timeout statusCode = framework.Wait } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0)