Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for parsedSelector (0.16 sec)

  1. pkg/controller/podautoscaler/horizontal.go

    	if a.hpaSelectors.SelectorExists(hpaKey) {
    		// Update HPA selector only if the HPA was registered in enqueueHPA.
    		a.hpaSelectors.PutSelector(hpaKey, parsedSelector)
    	}
    	a.hpaSelectorsMux.Unlock()
    
    	pods, err := a.podLister.Pods(hpa.Namespace).List(parsedSelector)
    	if err != nil {
    		return nil, err
    	}
    
    	selectingHpas := a.hpasControllingPodsUnderSelector(pods)
    	if len(selectingHpas) > 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  2. pkg/controller/podautoscaler/horizontal_test.go

    		selector := action.(core.ListAction).GetListRestrictions().Labels
    		parsedSelector := strings.Split(selector.String(), "=")
    		if len(parsedSelector) > 1 {
    			labelSet[parsedSelector[0]] = parsedSelector[1]
    			podNamePrefix = parsedSelector[1]
    		}
    
    		podMetric := metricsapi.PodMetrics{
    			ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 199.3K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/DefaultVersionedComponentChooserTest.groovy

            def selectedComponentResult = Mock(ComponentSelectionContext)
    
            when:
            chooser.selectNewestMatchingComponent([c, d, a, b], selectedComponentResult, versionSelectorScheme.parseSelector("1.+"), versionSelectorScheme.parseSelector("1.3"), consumerAttributes)
    
            then:
            _ * componentSelectionRules.rules >> []
            1 * selectedComponentResult.getContentFilter() >> null
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 17:38:42 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  4. pkg/test/framework/suite_test.go

    	defer cleanupRT()
    	g := NewWithT(t)
    
    	var runSkipped bool
    	runFn := func(ctx *suiteContext) int {
    		runSkipped = ctx.skipped
    		return 0
    	}
    
    	sel, err := label.ParseSelector("-customsetup")
    	g.Expect(err).To(BeNil())
    	settings := resource.DefaultSettings()
    	settings.Selector = sel
    
    	s := newTestSuite("tid", runFn, defaultExitFn, settingsFn(settings))
    	s.Label(label.CustomSetup)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. pkg/test/framework/resource/flags.go

    	if !config.Parsed() {
    		panic("config.Parse must be called before this function")
    	}
    
    	s := settingsFromCommandLine.Clone()
    	s.TestID = testID
    
    	f, err := label.ParseSelector(s.SelectorString)
    	if err != nil {
    		return nil, err
    	}
    	s.Selector = f
    
    	s.SkipMatcher, err = NewMatcher(s.SkipString)
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    				if err != nil {
    					b.Fatalf("new cacher: %v", err)
    				}
    				defer cacher.Stop()
    
    				// prepare result and pred
    				parsedField, err := fields.ParseSelector("spec.nodeName=node-0")
    				if err != nil {
    					b.Fatalf("parse selector: %v", err)
    				}
    				pred := storage.SelectionPredicate{
    					Label: labels.Everything(),
    					Field: parsedField,
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
Back to top