Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Gated (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top