Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for filterFuncs (0.27 sec)

  1. pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go

    		kubeSystemConfigMapInformer: kubeSystemConfigMapInformer,
    	}
    
    	kubeSystemConfigMapInformer.AddEventHandler(cache.FilteringResourceEventHandler{
    		FilterFunc: func(obj interface{}) bool {
    			if cast, ok := obj.(*corev1.ConfigMap); ok {
    				return cast.Namespace == configMapNamespace && cast.Name == configMapName
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. pkg/controller/serviceaccount/tokens_controller.go

    	e.secretSynced = secrets.Informer().HasSynced
    	secrets.Informer().AddEventHandlerWithResyncPeriod(
    		cache.FilteringResourceEventHandler{
    			FilterFunc: func(obj interface{}) bool {
    				switch t := obj.(type) {
    				case *v1.Secret:
    					return t.Type == v1.SecretTypeServiceAccountToken
    				default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	}
    }
    
    func filterWithAttrsFunction(key string, p storage.SelectionPredicate) filterWithAttrsFunc {
    	filterFunc := func(objKey string, label labels.Set, field fields.Set) bool {
    		if !hasPathPrefix(objKey, key) {
    			return false
    		}
    		return p.MatchesObjectAttributes(label, field)
    	}
    	return filterFunc
    }
    
    // LastSyncResourceVersion returns resource version to which the underlying cache is synced.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top