Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for AddEventHandlerWithResyncPeriod (0.48 sec)

  1. pkg/controller/bootstrap/bootstrapsigner.go

    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "bootstrap_signer_queue",
    			},
    		),
    	}
    
    	configMaps.Informer().AddEventHandlerWithResyncPeriod(
    		cache.FilteringResourceEventHandler{
    			FilterFunc: func(obj interface{}) bool {
    				switch t := obj.(type) {
    				case *v1.ConfigMap:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. pkg/proxy/config/config.go

    	result := &EndpointSliceConfig{
    		listerSynced: endpointSliceInformer.Informer().HasSynced,
    		logger:       klog.FromContext(ctx),
    	}
    
    	_, _ = endpointSliceInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    result.handleAddEndpointSlice,
    			UpdateFunc: result.handleUpdateEndpointSlice,
    			DeleteFunc: result.handleDeleteEndpointSlice,
    		},
    		resyncPeriod,
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/serviceaccounts_controller.go

    		),
    	}
    
    	saHandler, _ := saInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{
    		DeleteFunc: e.serviceAccountDeleted,
    	}, options.ServiceAccountResync)
    	e.saLister = saInformer.Lister()
    	e.saListerSynced = saHandler.HasSynced
    
    	nsHandler, _ := nsInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{
    		AddFunc:    e.namespaceAdded,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. pkg/controller/replication/conversion.go

    	return i.SharedIndexInformer.AddEventHandler(conversionEventHandler{handler})
    }
    
    func (i conversionInformer) AddEventHandlerWithResyncPeriod(handler cache.ResourceEventHandler, resyncPeriod time.Duration) (cache.ResourceEventHandlerRegistration, error) {
    	return i.SharedIndexInformer.AddEventHandlerWithResyncPeriod(conversionEventHandler{handler}, resyncPeriod)
    }
    
    type conversionLister struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 14 18:43:33 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  5. pkg/controller/bootstrap/tokencleaner.go

    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "token_cleaner",
    			},
    		),
    	}
    
    	secrets.Informer().AddEventHandlerWithResyncPeriod(
    		cache.FilteringResourceEventHandler{
    			FilterFunc: func(obj interface{}) bool {
    				switch t := obj.(type) {
    				case *v1.Secret:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. pkg/controller/namespace/namespace_controller.go

    	}
    
    	// configure the namespace informer event handlers
    	namespaceInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc: func(obj interface{}) {
    				namespace := obj.(*v1.Namespace)
    				namespaceController.enqueueNamespace(namespace)
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. pkg/controller/serviceaccount/tokens_controller.go

    		),
    
    		maxRetries: maxRetries,
    	}
    
    	e.serviceAccounts = serviceAccounts.Lister()
    	e.serviceAccountSynced = serviceAccounts.Informer().HasSynced
    	serviceAccounts.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    e.queueServiceAccountSync,
    			UpdateFunc: e.queueServiceAccountUpdateSync,
    			DeleteFunc: e.queueServiceAccountSync,
    		},
    		options.ServiceAccountResync,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  8. pkg/registry/core/service/ipallocator/controller/repairip.go

    		workerLoopPeriod: time.Second,
    		broadcaster:      eventBroadcaster,
    		recorder:         recorder,
    		clock:            clock.RealClock{},
    	}
    
    	_, _ = serviceInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			key, err := cache.MetaNamespaceKeyFunc(obj)
    			if err == nil {
    				r.svcQueue.Add(key)
    			}
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  9. pkg/controller/resourcequota/resource_quota_monitor.go

    		},
    	}
    	shared, err := qm.informerFactory.ForResource(resource)
    	if err == nil {
    		logger.V(4).Info("QuotaMonitor using a shared informer", "resource", resource.String())
    		shared.Informer().AddEventHandlerWithResyncPeriod(handlers, qm.resyncPeriod())
    		return shared.Informer().GetController(), nil
    	}
    	logger.V(4).Error(err, "QuotaMonitor unable to use a shared informer", "resource", resource.String())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller.go

    		registry:     options.Registry,
    	}
    	// set the synchronization handler
    	rq.syncHandler = rq.syncResourceQuotaFromKey
    
    	logger := klog.FromContext(ctx)
    
    	options.ResourceQuotaInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc: func(obj interface{}) {
    				rq.addQuota(logger, obj)
    			},
    			UpdateFunc: func(old, cur interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top