- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 50 for add_func (0.27 sec)
-
src/cmd/link/internal/loader/loader_test.go
if r1.Sym() != r2.Sym() || r1.Type() != r2.Type() || r1.Off() != r2.Off() || r1.Add() != r2.Add() || r1.Siz() != r2.Siz() { return false } } return true } type addFunc func(l *Loader, s Sym, s2 Sym) Sym func mkReloc(l *Loader, typ objabi.RelocType, off int32, siz uint8, add int64, sym Sym) Reloc { r := Reloc{&goobj.Reloc{}, l.extReader, l} r.SetType(typ) r.SetOff(off)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 19:08:09 UTC 2024 - 12K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
Name: "endpoint_slice_mirroring", }, ), workerLoopPeriod: time.Second, } endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onEndpointsAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.onEndpointsUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
), } e.pvcLister = pvcInformer.Lister() e.pvcListerSynced = pvcInformer.Informer().HasSynced pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { e.pvcAddedUpdated(logger, obj) }, UpdateFunc: func(old, new interface{}) { e.pvcAddedUpdated(logger, new) }, }) e.podLister = podInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
} tm.taintEvictionQueue = CreateWorkerQueue(deletePodHandler(c, tm.emitPodDeletionEvent, tm.name)) _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { pod := obj.(*v1.Pod) tm.PodUpdated(nil, pod) }, UpdateFunc: func(prev, obj interface{}) { prevPod := prev.(*v1.Pod) newPod := obj.(*v1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
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) } }, UpdateFunc: func(old interface{}, new interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced _, _ = ipAddressInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addIPAddress, DeleteFunc: c.deleteIPAddress, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
AddFunc: func(obj interface{}) { adc.nodeAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { adc.nodeUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { adc.nodeDelete(logger, obj) }, }) pvcInformer.Informer().AddEventHandler(kcache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { adc.enqueuePVC(obj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
} 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, ) secretCache := secrets.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
eventBroadcaster: eventBroadcaster, } podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ // lookup the statefulset and enqueue AddFunc: func(obj interface{}) { ssc.addPod(logger, obj) }, // lookup current and old statefulset if labels changed UpdateFunc: func(oldObj, newObj interface{}) { ssc.updatePod(logger, oldObj, newObj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
DeleteFunc: func(obj interface{}) { c.onDeleteLease(logger, obj) }, }) // use the default resync period from the informer storageVersionInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onAddStorageVersion(logger, obj) }, UpdateFunc: func(old, newObj interface{}) { c.onUpdateStorageVersion(logger, old, newObj) }, }) return c }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0)