Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,641 for AsSelector (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go

    	foo4Meta.SetLabels(testLabels)
    
    	objs := ([]runtime.Object{foo3, foo4})
    
    	assignFn(objs)
    	filtered := []runtime.Object{objs[1]}
    
    	selector := labels.SelectorFromSet(labels.Set(testLabels))
    	options := &metainternalversion.ListOptions{LabelSelector: selector}
    	listObj, err := t.storage.(rest.Lister).List(ctx, options)
    	if err != nil {
    		t.Errorf("unexpected error: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 55.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/labels/selector.go

    type Requirements []Requirement
    
    // Selector represents a label selector.
    type Selector interface {
    	// Matches returns true if this selector matches the given set of labels.
    	Matches(Labels) bool
    
    	// Empty returns true if this selector does not restrict the selection space.
    	Empty() bool
    
    	// String returns a human readable string that represents this selector.
    	String() string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 31.8K bytes
    - Viewed (0)
  8. pkg/config/analysis/analyzers/telemetry/selector.go

    	// Using an index for selectoes is problematic because selector != label
    	// We can match a label to a selector, but we can't generate a selector from a label.
    	c.ForEach(gvk.Telemetry, func(rs *resource.Instance) bool {
    		s := rs.Message.(*v1alpha1.Telemetry)
    
    		// For this analysis, ignore Telemetries with no selectors specified at all.
    		if s.Selector == nil || len(s.GetSelector().MatchLabels) == 0 {
    			return true
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. pkg/config/analysis/analyzers/sidecar/selector.go

    	"istio.io/istio/pkg/config/analysis/msg"
    	"istio.io/istio/pkg/config/resource"
    	"istio.io/istio/pkg/config/schema/gvk"
    )
    
    // SelectorAnalyzer validates, per namespace, that:
    // * sidecar resources that define a workload selector match at least one pod
    // * there aren't multiple sidecar resources that select overlapping pods
    type SelectorAnalyzer struct{}
    
    var _ analysis.Analyzer = &SelectorAnalyzer{}
    
    // Metadata implements Analyzer
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/util/workloadinstances/selector.go

    )
    
    // ByServiceSelector returns a predicate that matches workload instances
    // of a given service.
    func ByServiceSelector(namespace string, selector labels.Instance) func(*model.WorkloadInstance) bool {
    	return func(wi *model.WorkloadInstance) bool {
    		return wi.Namespace == namespace && selector.Match(wi.Endpoint.Labels)
    	}
    }
    
    // FindAllInIndex returns a list of workload instances in the index
    // that match given predicate.
    //
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 07 04:26:56 UTC 2023
    - 1.4K bytes
    - Viewed (0)
Back to top