- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for NewSelector (0.35 sec)
-
pkg/kube/namespace/filter.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 } // SelectorsChanged initializes the discovery filter state with the discovery selectors and selected namespaces
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/ErrorHandlingModuleComponentRepositoryTest.groovy
given: def dependency = Mock(ModuleDependencyMetadata) def result = Mock(BuildableModuleVersionListingResolveResult) dependency.getSelector() >> DefaultModuleComponentSelector.newSelector(DefaultModuleIdentifier.newId('a', 'b'), DefaultImmutableVersionConstraint.of('1.0')) when: 'repo is not disabled' repositoryBlacklister.isDisabled(REPOSITORY_ID) >> false
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 13.5K 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) -
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) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfiguration.java
: DefaultMutableVersionConstraint.withVersion(lockedVersion); ModuleComponentSelector selector = DefaultModuleComponentSelector.newSelector(DefaultModuleIdentifier.newId(lockedDependency.getGroup(), lockedDependency.getModule()), versionConstraint); return new LocalComponentDependencyMetadata(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:36:01 UTC 2024 - 85.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
ModuleComponentIdentifier platformId = (ModuleComponentIdentifier) owner; final ModuleComponentSelector cs = DefaultModuleComponentSelector.newSelector(platformId.getModuleIdentifier(), platformId.getVersion()); // There are 2 possibilities here:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
pilot/pkg/model/service.go
func (i WorkloadAuthorization) ResourceName() string { return i.Authorization.GetNamespace() + "/" + i.Authorization.GetName() } type LabelSelector struct { Labels map[string]string } func NewSelector(l map[string]string) LabelSelector { return LabelSelector{l} } func (l LabelSelector) GetLabelSelector() map[string]string { return l.Labels }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
if err != nil { return err } noHeadlessEndpoints, err := labels.NewRequirement(v1.IsHeadlessService, selection.DoesNotExist, nil) if err != nil { return err } labelSelector := labels.NewSelector() labelSelector = labelSelector.Add(*noProxyName, *noHeadlessEndpoints) // Make informers that filter out objects that want a non-default service proxy.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)