Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,063 for AsSelector (0.28 sec)

  1. pkg/client/tests/listwatch_test.go

    	restclient "k8s.io/client-go/rest"
    	. "k8s.io/client-go/tools/cache"
    	utiltesting "k8s.io/client-go/util/testing"
    )
    
    func parseSelectorOrDie(s string) fields.Selector {
    	selector, err := fields.ParseSelector(s)
    	if err != nil {
    		panic(err)
    	}
    	return selector
    }
    
    // buildQueryValues is a convenience function for knowing if a namespace should be in a query param or not
    func buildQueryValues(query url.Values) url.Values {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 02 17:08:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/fields/fields.go

    // Conveniently, exactly the format that ParseSelector takes.
    func (ls Set) String() string {
    	selector := make([]string, 0, len(ls))
    	for key, value := range ls {
    		selector = append(selector, key+"="+value)
    	}
    	// Sort for determinism.
    	sort.StringSlice(selector).Sort()
    	return strings.Join(selector, ",")
    }
    
    // Has returns whether the provided field exists in the map.
    func (ls Set) Has(field string) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 19 14:50:16 UTC 2017
    - 1.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/helper/spread.go

    			labelSet = labels.Merge(labelSet, rc.Spec.Selector)
    			selector = labelSet.AsSelector()
    		}
    	case rsKind:
    		if rs, err := rsl.ReplicaSets(pod.Namespace).Get(owner.Name); err == nil {
    			if other, err := metav1.LabelSelectorAsSelector(rs.Spec.Selector); err == nil {
    				if r, ok := other.Requirements(); ok {
    					selector = selector.Add(r...)
    				}
    			}
    		}
    	case ssKind:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 25 20:04:48 UTC 2021
    - 3.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/labels/labels.go

    // Conveniently, exactly the format that ParseSelector takes.
    func (ls Set) String() string {
    	selector := make([]string, 0, len(ls))
    	for key, value := range ls {
    		selector = append(selector, key+"="+value)
    	}
    	// Sort for determinism.
    	sort.StringSlice(selector).Sort()
    	return strings.Join(selector, ",")
    }
    
    // Has returns whether the provided label exists in the map.
    func (ls Set) Has(label string) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 14 16:39:04 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/fields/selector_test.go

    }
    
    func TestNilMapIsValid(t *testing.T) {
    	selector := Set(nil).AsSelector()
    	if selector == nil {
    		t.Errorf("Selector for nil set should be Everything")
    	}
    	if !selector.Empty() {
    		t.Errorf("Selector for nil set should be Empty")
    	}
    }
    
    func TestSetIsEmpty(t *testing.T) {
    	if !(Set{}).AsSelector().Empty() {
    		t.Errorf("Empty set should be empty")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 27 08:00:38 UTC 2017
    - 11.2K bytes
    - Viewed (0)
  6. pilot/pkg/status/distribution/state.go

    		informers.WithNamespace(namespace),
    		informers.WithTweakListOptions(func(listOptions *metav1.ListOptions) {
    			listOptions.LabelSelector = labels.Set(map[string]string{labelKey: "true"}).AsSelector().String()
    		})).
    		Core().V1().ConfigMaps()
    	c.cmInformer = i.Informer()
    	c.cmHandle, _ = c.cmInformer.AddEventHandler(&DistroReportHandler{dc: c})
    
    	return c
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  7. pkg/controller/controller_ref_manager_test.go

    )
    
    var (
    	productionLabel         = map[string]string{"type": "production"}
    	testLabel               = map[string]string{"type": "testing"}
    	productionLabelSelector = labels.Set{"type": "production"}.AsSelector()
    	controllerUID           = "123"
    )
    
    func newPod(podName string, label map[string]string, owner metav1.Object) *v1.Pod {
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      podName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 10 17:19:26 UTC 2021
    - 10.6K bytes
    - Viewed (0)
  8. pkg/registry/core/node/strategy_test.go

    			{"metadata.name": "foo"},
    		},
    		false: {
    			{"foo": "bar"},
    		},
    	}
    
    	for expectedResult, fieldSet := range testFieldMap {
    		for _, field := range fieldSet {
    			m := MatchNode(labels.Everything(), field.AsSelector())
    			_, matchesSingle := m.MatchesSingle()
    			if e, a := expectedResult, matchesSingle; e != a {
    				t.Errorf("%+v: expected %v, got %v", fieldSet, e, a)
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  9. pkg/kubelet/util/manager/watch_based_manager.go

    	return &cacheStore{store, sync.Mutex{}, false}
    }
    
    func (c *objectCache) newReflectorLocked(namespace, name string) *objectCacheItem {
    	fieldSelector := fields.Set{"metadata.name": name}.AsSelector().String()
    	listFunc := func(options metav1.ListOptions) (runtime.Object, error) {
    		options.FieldSelector = fieldSelector
    		return c.listObject(namespace, options)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/labels/selector_test.go

    }
    
    func TestNilMapIsValid(t *testing.T) {
    	selector := Set(nil).AsSelector()
    	if selector == nil {
    		t.Errorf("Selector for nil set should be Everything")
    	}
    	if !selector.Empty() {
    		t.Errorf("Selector for nil set should be Empty")
    	}
    }
    
    func TestSetIsEmpty(t *testing.T) {
    	if !(Set{}).AsSelector().Empty() {
    		t.Errorf("Empty set should be empty")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 14 16:39:04 UTC 2022
    - 29.9K bytes
    - Viewed (0)
Back to top