- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 118 for NewSelector (0.16 sec)
-
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers.go
} r, err := labels.NewRequirement(expr.Key, op, append([]string(nil), expr.Values...)) if err != nil { return nil, err } requirements = append(requirements, *r) } selector := labels.NewSelector() selector = selector.Add(requirements...) return selector, nil } // LabelSelectorAsMap converts the LabelSelector api type into a map of strings, ie. the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 15 10:58:36 UTC 2022 - 9.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/ComponentSelectorSerializer.java
} else if (Implementation.MODULE.getId() == id) { return DefaultModuleComponentSelector.newSelector(DefaultModuleIdentifier.newId(decoder.readString(), decoder.readString()), readVersionConstraint(decoder), readAttributes(decoder), readCapabilities(decoder)); } else if (Implementation.LIBRARY.getId() == id) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 15.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/selectors/SelectorStateResolverTest.groovy
} private ModuleVersionNotFoundException missing(VersionSelector prefer) { def moduleComponentSelector = DefaultModuleComponentSelector.newSelector(DefaultModuleIdentifier.newId(moduleId.group, moduleId.name), prefer.selector) return new ModuleVersionNotFoundException(moduleComponentSelector, []) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 07 23:54:34 UTC 2024 - 16.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
logger.V(4).Info("Resyncing PV controller") pvcs, err := ctrl.claimLister.List(labels.NewSelector()) if err != nil { logger.Info("Cannot list claims", "err", err) return } for _, pvc := range pvcs { ctrl.enqueueWork(ctx, ctrl.claimQueue, pvc) } pvs, err := ctrl.volumeLister.List(labels.NewSelector()) if err != nil { logger.Info("Cannot list persistent volumes", "err", err) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/labels/selector_test.go
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") } if !(NewSelector()).Empty() { t.Errorf("Nil Selector should be empty") } } func TestLexer(t *testing.T) { testcases := []struct { s string t Token }{ {"", EndOfStringToken},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 14 16:39:04 UTC 2022 - 29.9K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
componentRequirement, err := klabels.NewRequirement(IstioComponentLabelStr, selection.Exists, nil) if err != nil { return usList, err } if includeClusterResources { s := klabels.NewSelector() err = h.client.List(context.TODO(), objects, client.MatchingLabelsSelector{Selector: s.Add(*componentRequirement)}) } else { // do not prune base components or unknown components includeCN := []string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/labels/selector.go
var sharedNothingSelector Selector = nothingSelector{} // Nothing returns a selector that matches no labels func Nothing() Selector { return sharedNothingSelector } // NewSelector returns a nil selector func NewSelector() Selector { return internalSelector(nil) } type internalSelector []Requirement func (s internalSelector) DeepCopy() internalSelector { if s == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 31.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
slices kclient.Client[*v1.EndpointSlice] c *Controller } var ( endpointSliceRequirement = labelRequirement(mcs.LabelServiceName, selection.DoesNotExist, nil) endpointSliceSelector = klabels.NewSelector().Add(*endpointSliceRequirement) ) func newEndpointSliceController(c *Controller) *endpointSliceController { slices := kclient.NewFiltered[*v1.EndpointSlice](c.client, kclient.Filter{ObjectFilter: c.client.ObjectFilter()})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/util/selectors/bimultimap_test.go
ss[ls[i]] = ls[i+1] } return ss } func selector(ss ...string) pkglabels.Selector { if len(ss)%2 != 0 { panic("selector requires pairs of strings.") } s := pkglabels.NewSelector() for i := 0; i < len(ss); i += 2 { r, err := pkglabels.NewRequirement(ss[i], selection.Equals, []string{ss[i+1]}) if err != nil { panic(err) } s = s.Add(*r) } return s }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 13 01:56:36 UTC 2022 - 16.9K bytes - Viewed (0) -
pkg/apis/batch/validation/validation_test.go
// on its own; therfore, the only way to test selector immutability is // when the new selector is changed but still matches the existing labels. newSelector := getValidGeneratedSelector() newSelector.MatchLabels["foo"] = "bar" validTolerations := []api.Toleration{{ Key: "foo", Operator: api.TolerationOpEqual, Value: "bar", Effect: api.TaintEffectPreferNoSchedule,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 124.3K bytes - Viewed (0)