Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewIntegerResourceVersionMutationCache (0.48 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_naming_condition_controller"},
    		),
    	}
    
    	informerIndexer := crdInformer.Informer().GetIndexer()
    	c.crdMutationCache = cache.NewIntegerResourceVersionMutationCache(informerIndexer, informerIndexer, 60*time.Second, false)
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addCustomResourceDefinition,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller_test.go

    		for _, obj := range tc.existing {
    			crdIndexer.Add(obj)
    		}
    
    		c := NamingConditionController{
    			crdLister:        listers.NewCustomResourceDefinitionLister(crdIndexer),
    			crdMutationCache: cache.NewIntegerResourceVersionMutationCache(crdIndexer, crdIndexer, 60*time.Second, false),
    		}
    		actualNames, actualNameConflictCondition, establishedCondition := c.calculateNamesAndConditions(tc.in)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 03 16:49:27 UTC 2019
    - 15.7K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/tokens_controller.go

    			DeleteFunc: e.queueServiceAccountSync,
    		},
    		options.ServiceAccountResync,
    	)
    
    	secretCache := secrets.Informer().GetIndexer()
    	e.updatedSecrets = cache.NewIntegerResourceVersionMutationCache(secretCache, secretCache, 60*time.Second, true)
    	e.secretSynced = secrets.Informer().HasSynced
    	secrets.Informer().AddEventHandlerWithResyncPeriod(
    		cache.FilteringResourceEventHandler{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  4. pkg/controller/resourceclaim/controller.go

    		return nil, fmt.Errorf("could not initialize ResourceClaim controller: %w", err)
    	}
    	ec.claimCache = cache.NewIntegerResourceVersionMutationCache(claimInformerCache, claimInformerCache,
    		// Very long time to live, unlikely to be needed because
    		// the informer cache should get updated soon.
    		time.Hour,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top