- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 91 for add_func (0.14 sec)
-
pkg/scheduler/eventhandlers.go
return false default: utilruntime.HandleError(fmt.Errorf("unable to handle object in %T: %T", sched, obj)) return false } }, Handler: cache.ResourceEventHandlerFuncs{ AddFunc: sched.addPodToCache, UpdateFunc: sched.updatePodInCache, DeleteFunc: sched.deletePodFromCache, }, }, ); err != nil { return err } handlers = append(handlers, handlerRegistration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
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) -
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) -
pkg/proxy/config/config.go
listerSynced: endpointSliceInformer.Informer().HasSynced, logger: klog.FromContext(ctx), } _, _ = endpointSliceInformer.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: result.handleAddEndpointSlice, UpdateFunc: result.handleUpdateEndpointSlice, DeleteFunc: result.handleDeleteEndpointSlice, }, resyncPeriod, ) return result }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
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) -
tensorflow/compiler/aot/tests/tfcompile_test.cc
FunctionComp add_fn; EXPECT_EQ(add_fn.arg0_data(), add_fn.arg_data(0)); EXPECT_EQ(add_fn.arg1_data(), add_fn.arg_data(1)); add_fn.arg0() = 1; add_fn.arg1() = 2; EXPECT_TRUE(add_fn.Run()); EXPECT_EQ(add_fn.error_msg(), ""); EXPECT_EQ(add_fn.result0(), 3); EXPECT_EQ(add_fn.result0_data()[0], 3); EXPECT_EQ(add_fn.result0_data(), add_fn.results()[0]); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 26.4K bytes - Viewed (0) -
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) -
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) -
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) -
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)