Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 47 of 47 for add_func (0.45 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go

    			return
    		}
    		if isInInitialList {
    			c.hasProcessed.Start(key)
    		}
    
    		c.queue.Add(key)
    	}
    
    	registration, err := c.informer.AddEventHandler(cache.ResourceEventHandlerDetailedFuncs{
    		AddFunc: enqueue,
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			oldMeta, err1 := meta.Accessor(oldObj)
    			newMeta, err2 := meta.Accessor(newObj)
    
    			if err1 != nil || err2 != nil {
    				if err1 != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    		),
    	}
    	c.syncHandler = c.handleVersionUpdate
    
    	crdinformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			cast := obj.(*apiextensionsv1.CustomResourceDefinition)
    			c.enqueueCRD(cast)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    		},
    		Handler: cache.ResourceEventHandlerFuncs{
    			// we have a filter, so any time we're called, we may as well queue. We only ever check one configmap
    			// so we don't have to be choosy about our key.
    			AddFunc: func(obj interface{}) {
    				c.queue.Add(c.keyFn())
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				c.queue.Add(c.keyFn())
    			},
    			DeleteFunc: func(obj interface{}) {
    				c.queue.Add(c.keyFn())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. pkg/controller/ttl/ttl_controller.go

    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttlcontroller"},
    		),
    	}
    	logger := klog.FromContext(ctx)
    	nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			ttlc.addNode(logger, obj)
    		},
    		UpdateFunc: func(old, newObj interface{}) {
    			ttlc.updateNode(logger, old, newObj)
    		},
    		DeleteFunc: ttlc.deleteNode,
    	})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_openapi_controller"},
    		),
    		specsByName: map[string]*specCache{},
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addCustomResourceDefinition,
    		UpdateFunc: c.updateCustomResourceDefinition,
    		DeleteFunc: c.deleteCustomResourceDefinition,
    	})
    
    	c.syncFn = c.sync
    	return c
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. pkg/controller/volume/ephemeral/controller.go

    	ec.recorder = eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "ephemeral_volume"})
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: ec.enqueuePod,
    		// The pod spec is immutable. Therefore the controller can ignore pod updates
    		// because there cannot be any changes that have to be copied into the generated
    		// PVC.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. src/text/template/template.go

    // so calls can be chained.
    func (t *Template) Funcs(funcMap FuncMap) *Template {
    	t.init()
    	t.muFuncs.Lock()
    	defer t.muFuncs.Unlock()
    	addValueFuncs(t.execFuncs, funcMap)
    	addFuncs(t.parseFuncs, funcMap)
    	return t
    }
    
    // Lookup returns the template with the given name that is associated with t.
    // It returns nil if there is no such template or the template has no definition.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:57:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
Back to top