- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 48 for labelSelector (0.25 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/validator.go
} // validate labelSelector if scale.LabelSelectorPath != nil { labelSelectorPath := strings.TrimPrefix(*scale.LabelSelectorPath, ".") // ignore leading period labelSelector, _, err := unstructured.NestedString(obj.UnstructuredContent(), strings.Split(labelSelectorPath, ".")...) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 14:00:05 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/kube/kubetypes/types.go
"k8s.io/apimachinery/pkg/watch" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/util/sets" ) type InformerOptions struct { // A selector to restrict the list of returned objects by their labels. LabelSelector string // A selector to restrict the list of returned objects by their fields. FieldSelector string // Namespace to watch. Namespace string // Cluster name for watch error handlers Cluster cluster.ID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0) -
releasenotes/notes/merge-svc.yaml
kind: feature area: traffic-management # releaseNotes is a markdown listing of any user facing changes. This will appear in the # release notes. releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 07:49:37 UTC 2024 - 912 bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
watcher := keycertbundle.NewWatcher() caBundle := []byte("caBundle") watcher.SetAndNotify(nil, nil, caBundle) meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{ DiscoverySelectors: []*meshconfig.LabelSelector{ { MatchLabels: map[string]string{ "discovery-selectors": "enabled", }, }, }, }) stop := test.NewStop(t) discoveryNamespacesFilter := filter.NewDiscoveryNamespacesFilter(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/persistent_volume_claims_test.go
Spec: spec, } } func TestPersistentVolumeClaimEvaluatorUsage(t *testing.T) { classGold := "gold" validClaim := testVolumeClaim("foo", "ns", core.PersistentVolumeClaimSpec{ Selector: &metav1.LabelSelector{ MatchExpressions: []metav1.LabelSelectorRequirement{ { Key: "key2", Operator: "Exists", }, }, }, AccessModes: []core.PersistentVolumeAccessMode{ core.ReadWriteOnce,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/config/analysis/analyzers/webhook/webhook.go
if !ok && wh.GetLabels()[label.IoIstioRev.Name] == "default" { return true } return false } func selectorMatches(selector *metav1.LabelSelector, labels klabels.Set) bool { // From webhook spec: "Default to the empty LabelSelector, which matches everything." if selector == nil { return true } s, err := metav1.LabelSelectorAsSelector(selector) if err != nil { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
} a.networkUpdateTrigger.MarkDependant(ctx) // Mark we depend on out of band a.Network return &model.ServiceInfo{ Service: a.constructService(s, waypoint), PortNames: portNames, LabelSelector: model.NewSelector(s.Spec.Selector), Source: kind.Service, Waypoint: waypointKey, } }, krt.WithName("ServicesInfo"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
func (d *discoveryNamespacesFilter) selectorsChanged( discoverySelectors []*meshapi.LabelSelector, notify bool, ) { d.lock.Lock() defer d.lock.Unlock() var selectors []labels.Selector newDiscoveryNamespaces := sets.New[string]() namespaceList := d.namespaces.List("", labels.Everything()) // convert LabelSelectors to Selectors for _, selector := range discoverySelectors {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
tests/integration/pilot/vm_test.go
retry.UntilSuccessOrFail(t, func() error { pilotRes, err := t.Clusters().Default().Kube().CoreV1().Pods(i.Settings().SystemNamespace). List(context.TODO(), metav1.ListOptions{LabelSelector: "istio=pilot"}) if err != nil { return err } if len(pilotRes.Items) != 2 { return errors.New("expected 2 pilots") } return nil }, retry.Timeout(10*time.Second))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.4K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
} } } noMatchingReason := func(whs []admitv1.MutatingWebhook) string { nsMatchedLabels := make([]string, 0) podMatchedLabels := make([]string, 0) extractMatchLabels := func(selector *metav1.LabelSelector) []string { if selector == nil { return nil } labels := make([]string, 0) for _, me := range selector.MatchExpressions { if me.Operator != metav1.LabelSelectorOpIn { continue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 9.3K bytes - Viewed (0)