Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 50 for add_func (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top