Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 87 for AddFunc (0.98 sec)

  1. src/internal/coverage/encodemeta/encode.go

    	tmp = tmp[:0]
    	tmp = append(tmp, 0, 0, 0, 0)
    	binary.LittleEndian.PutUint32(tmp, x)
    	h.Write(tmp)
    }
    
    type funcDesc struct {
    	encoded []byte
    }
    
    // AddFunc registers a new function with the meta data builder.
    func (b *CoverageMetaDataBuilder) AddFunc(f coverage.FuncDesc) uint {
    	hashFuncDesc(b.h, &f, b.tmp)
    	fd := funcDesc{}
    	b.tmp = b.tmp[:0]
    	b.tmp = uleb128.AppendUleb128(b.tmp, uint(len(f.Units)))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Feb 29 17:16:10 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/kube/pod_controller.go

    			}
    			options.LabelSelector += s.String()
    		})
    	q := queue.NewQueue(1 * time.Second)
    	_, informer := cache.NewInformer(podListWatch, &corev1.Pod{}, 0, controllers.EventHandler[*corev1.Pod]{
    		AddFunc: func(pod *corev1.Pod) {
    			q.Push(func() error {
    				return handlers.added(pod)
    			})
    		},
    		UpdateFunc: func(old, cur *corev1.Pod) {
    			q.Push(func() error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 09 02:22:47 UTC 2023
    - 2.6K bytes
    - Viewed (1)
  3. pkg/controller/bootstrap/bootstrapsigner.go

    				default:
    					utilruntime.HandleError(fmt.Errorf("object passed to %T that is not expected: %T", e, obj))
    					return false
    				}
    			},
    			Handler: cache.ResourceEventHandlerFuncs{
    				AddFunc:    func(_ interface{}) { e.pokeConfigMapSync() },
    				UpdateFunc: func(_, _ interface{}) { e.pokeConfigMapSync() },
    			},
    		},
    		options.ConfigMapResync,
    	)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. pkg/controller/endpointslice/endpointslice_controller.go

    		AddFunc: c.onServiceUpdate,
    		UpdateFunc: func(old, cur interface{}) {
    			c.onServiceUpdate(cur)
    		},
    		DeleteFunc: c.onServiceDelete,
    	})
    	c.serviceLister = serviceInformer.Lister()
    	c.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addPod,
    		UpdateFunc: c.updatePod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  5. pkg/kube/kclient/index.go

    		o := ro.(O)
    		objectKey := config.NamespacedName(o)
    		for _, indexKey := range extract(o) {
    			sets.DeleteCleanupLast(idx.objects, indexKey, objectKey)
    		}
    	}
    	handler := cache.ResourceEventHandlerDetailedFuncs{
    		AddFunc: func(obj any, initialList bool) {
    			idx.mu.Lock()
    			addObj(obj)
    			idx.mu.Unlock()
    			if delegate != nil {
    				delegate.OnAdd(obj, initialList)
    			}
    		},
    		UpdateFunc: func(oldObj, newObj any) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 04 03:49:30 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  6. pkg/kube/kclient/clienttest/test_helpers.go

    // TrackerHandler returns an object handler that records each event
    func TrackerHandler(tracker *assert.Tracker[string]) controllers.EventHandler[controllers.Object] {
    	return controllers.EventHandler[controllers.Object]{
    		AddFunc: func(obj controllers.Object) {
    			tracker.Record("add/" + obj.GetName())
    		},
    		UpdateFunc: func(oldObj, newObj controllers.Object) {
    			tracker.Record("update/" + newObj.GetName())
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. pkg/controller/validatingadmissionpolicystatus/controller.go

    		),
    		policyClient: policyClient,
    		typeChecker:  typeChecker,
    	}
    	reg, err := policyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueuePolicy(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.enqueuePolicy(newObj)
    		},
    	})
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. 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)
  9. pkg/controlplane/controller/legacytokentracking/controller.go

    		configMapCache:      informer.GetIndexer(),
    		configMapSynced:     informer.HasSynced,
    		creationRatelimiter: limiter,
    		clock:               cl,
    	}
    
    	informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.enqueue()
    		},
    		DeleteFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    	})
    
    	return c
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager.go

    		createValidatingWebhookAccessor: webhook.NewValidatingWebhookAccessor,
    	}
    	manager.lazy.Evaluate = manager.getConfiguration
    
    	handle, _ := informer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(_ interface{}) { manager.lazy.Notify() },
    		UpdateFunc: func(old, new interface{}) {
    			obj := new.(*v1.ValidatingWebhookConfiguration)
    			manager.configurationsCache.Delete(obj.GetName())
    			manager.lazy.Notify()
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 22:43:12 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top