Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 47 for add_func (0.14 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. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go

    		serializer:            serializer,
    	}
    	svi := informerFactory.Internal().V1alpha1().StorageVersions()
    	h.storageversionInformer = svi.Informer()
    
    	svi.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			h.addSV(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			h.updateSV(oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			h.deleteSV(obj)
    		}})
    	return h
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 2K bytes
    - Viewed (0)
  3. src/net/fd_windows.go

    	syscall.GetAcceptExSockaddrs((*byte)(unsafe.Pointer(&rawsa[0])),
    		0, rsan, rsan, &lrsa, &llen, &rrsa, &rlen)
    	lsa, _ := lrsa.Sockaddr()
    	rsa, _ := rrsa.Sockaddr()
    
    	netfd.setAddr(netfd.addrFunc()(lsa), netfd.addrFunc()(rsa))
    	return netfd, nil
    }
    
    // Unimplemented functions.
    
    func (fd *netFD) dup() (*os.File, error) {
    	// TODO: Implement this, perhaps using internal/poll.DupCloseOnExec.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 16:46:10 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. 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 (0)
  5. staging/src/k8s.io/apimachinery/third_party/forked/golang/reflect/deep_equal_test.go

    )
    
    func TestEqualities(t *testing.T) {
    	e := Equalities{}
    	type Bar struct {
    		X int
    	}
    	type Baz struct {
    		Y Bar
    	}
    	type Zap struct {
    		A []int
    		B map[string][]int
    	}
    	err := e.AddFuncs(
    		func(a, b int) bool {
    			return a+1 == b
    		},
    		func(a, b Bar) bool {
    			return a.X*10 == b.X
    		},
    	)
    	if err != nil {
    		t.Fatalf("Unexpected: %v", err)
    	}
    
    	type Foo struct {
    		X int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 14 18:55:26 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/apimachinery/pkg/conversion/deep_equal.go

    type Equalities struct {
    	reflect.Equalities
    }
    
    // For convenience, panics on errors
    func EqualitiesOrDie(funcs ...interface{}) Equalities {
    	e := Equalities{reflect.Equalities{}}
    	if err := e.AddFuncs(funcs...); err != nil {
    		panic(err)
    	}
    	return e
    }
    
    // Performs a shallow copy of the equalities map
    func (e Equalities) Copy() Equalities {
    	result := Equalities{reflect.Equalities{}}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 14 18:55:26 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top