Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 28 of 28 for NewSelector (0.35 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top