- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 105 for add_func (0.24 sec)
-
pkg/controller/volume/persistentvolume/pv_controller_base.go
return nil, fmt.Errorf("could not initialize volume plugins for PersistentVolume Controller: %w", err) } p.VolumeInformer.Informer().AddEventHandler( cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, newObj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
// Unit tests don't use informers if informer != nil { // Cannot fail in practice?! No-one bothers checking the error. _, _ = informer.AddEventHandler( cache.ResourceEventHandlerFuncs{ AddFunc: c.add, UpdateFunc: c.update, DeleteFunc: c.delete, }, ) } return c } func (c *AssumeCache) add(obj interface{}) { if obj == nil { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
} } // Watch add/update events for APIServices apiServiceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ //nolint:errcheck // no way to return error AddFunc: func(obj interface{}) { handleAPIServiceChange(obj.(*v1.APIService)) }, UpdateFunc: func(old, new interface{}) { handleAPIServiceChange(new.(*v1.APIService)) }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
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) -
src/text/template/funcs.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 22:23:55 UTC 2024 - 20.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_finalizer"}, ), } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *CRDFinalizer) sync(key string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
c.crdMutationCache = cache.NewIntegerResourceVersionMutationCache(informerIndexer, informerIndexer, 60*time.Second, false) 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 - 13.2K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttl_jobs_to_delete"}, ), } logger := klog.FromContext(ctx) jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { tc.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { tc.updateJob(logger, oldObj, newObj) }, }) tc.jLister = jobInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
), internalStopCh: make(chan struct{}), tree: iptree.New[*Allocator](), ipFamily: family, } _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) go c.run() return c, nil } func (c *MetaAllocator) addServiceCIDR(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
src/cmd/covdata/metamerge.go
fnhash := encodemeta.HashFuncDesc(fd) gfidx, ok := mm.p.ftab[fnhash] if !ok { // We haven't seen this function before, need to add it to // the meta data. gfidx = uint32(mm.p.cmdb.AddFunc(*fd)) mm.p.ftab[fnhash] = gfidx if *verbflag >= 3 { fmt.Printf("new meta entry for fn %s fid=%d\n", fd.Funcname, gfidx) } } fnIdx = gfidx } if !haveCounters { return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 12 17:17:47 UTC 2024 - 12.1K bytes - Viewed (0)