- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for NewSelector (0.18 sec)
-
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) -
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) -
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) -
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)