- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for Gated (0.07 sec)
-
pkg/scheduler/internal/queue/scheduling_queue.go
p.lock.Lock() defer p.lock.Unlock() pInfo := p.newQueuedPodInfo(pod) gated := pInfo.Gated if added, err := p.addToActiveQ(logger, pInfo); !added { return err } if p.unschedulablePods.get(pod) != nil { logger.Error(nil, "Error: pod is already in the unschedulable queue", "pod", klog.KObj(pod)) p.unschedulablePods.delete(pod, gated) } // Delete pod from backoffQ if it is backing off
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
pInfos := makeQueuedPodInfos(queueableNum, "x", queueable, timestamp) // The last 10 Pods are not queueable. gated := makeQueuedPodInfos(total-queueableNum, "y", failme, timestamp) // Manually mark them as gated=true. for _, pInfo := range gated { setQueuedPodInfoGated(pInfo) } pInfos = append(pInfos, gated...) totalWithDelay := 20
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
cmd/kubeadm/app/features/features.go
WaitForAllControlPlaneComponents: {FeatureSpec: featuregate.FeatureSpec{Default: false, PreRelease: featuregate.Alpha}}, } // Feature represents a feature being gated type Feature struct { featuregate.FeatureSpec MinimumVersion *version.Version HiddenInHelpText bool DeprecationMessage string } // FeatureList represents a list of feature gates
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 13:55:11 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
UnschedulablePlugins sets.Set[string] // PendingPlugins records the plugin names that the Pod failed with Pending status. PendingPlugins sets.Set[string] // Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not. Gated bool } // DeepCopy returns a deep copy of the QueuedPodInfo object. func (pqi *QueuedPodInfo) DeepCopy() *QueuedPodInfo { return &QueuedPodInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
src/io/pipe_test.go
if n, err := r.Read(buf[i : i+readSize]); n != readSize || err != nil { t.Errorf("Read() = (%d, %v); want (%d, nil)", n, err, readSize) } } // Since each Write is fully gated, if multiple Read calls were needed, // the contents of Write should still appear together in the output. got := string(buf) want := strings.Repeat(input, count) if got != want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager.go
LowThresholdPercent int // Minimum age at which an image can be garbage collected. MinAge time.Duration // Maximum age after which an image can be garbage collected, regardless of disk usage. // Currently gated by MaximumImageGCAge feature gate and Kubelet configuration. // If 0, the feature is disabled. MaxAge time.Duration } type realImageGCManager struct { // Container runtime runtime container.Runtime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/apis/core/validation/validation_test.go
test: "removing node selector is not allowed for gated pods", }, { old: core.Pod{ Spec: core.PodSpec{ NodeSelector: map[string]string{ "foo": "bar", }, }, }, new: core.Pod{}, err: "Forbidden: pod updates may not change fields other than `spec.containers[*].image", test: "removing node selector is not allowed for non-gated pods", }, { old: core.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
// If someone writes a function that uses >65K values, // they get incomplete debug info on 32-bit platforms. return } if start == end { if state.loggingLevel > 1 { // Printf not logf so not gated by GOSSAFUNC; this should fire very rarely. // TODO this fires a lot, need to figure out why. state.logf("Skipping empty location list for %v in %s\n", state.vars[varID], state.f.Name) } return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
- Improved scheduling latency when many gated pods ([#124618](https://github.com/kubernetes/kubernetes/pull/124618), [@gabesaba](https://github.com/gabesaba)) [SIG Scheduling and Testing]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:34:14 UTC 2024 - 60.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
### Bug or Regression - Improved scheduling latency when many gated pods ([#124866](https://github.com/kubernetes/kubernetes/pull/124866), [@gabesaba](https://github.com/gabesaba)) [SIG Scheduling and Testing]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 23:01:06 UTC 2024 - 455.3K bytes - Viewed (0)