- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for add_func (0.29 sec)
-
plugin/pkg/auth/authorizer/node/graph_populator.go
AddFunc: g.addPod, UpdateFunc: g.updatePod, DeleteFunc: g.deletePod, }) pvsHandler, _ := pvs.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPV, UpdateFunc: g.updatePV, DeleteFunc: g.deletePV, }) attachHandler, _ := attachments.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addVolumeAttachment,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kube/controllers/common.go
type EventHandler[T Object] struct { AddFunc func(obj T) AddExtendedFunc func(obj T, initialSync bool) UpdateFunc func(oldObj, newObj T) DeleteFunc func(obj T) } func (e EventHandler[T]) OnAdd(obj interface{}, initialSync bool) { if e.AddExtendedFunc != nil { e.AddExtendedFunc(Extract[T](obj), initialSync) } else if e.AddFunc != nil { e.AddFunc(Extract[T](obj)) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
src/net/file_unix.go
default: poll.CloseFunc(s) return nil, syscall.EPROTONOSUPPORT } fd, err := newFD(s, family, sotype, "") if err != nil { poll.CloseFunc(s) return nil, err } laddr := fd.addrFunc()(lsa) raddr := fd.addrFunc()(rsa) fd.net = laddr.Network() if err := fd.init(); err != nil { fd.Close() return nil, err } fd.setAddr(laddr, raddr) return fd, nil } func fileConn(f *os.File) (Conn, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.5K 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) -
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) -
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/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) -
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) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
// lifecycle to the Service so that when the Service is deleted, // k8s automatically deletes the ServiceExport. c.services.AddEventHandler(controllers.EventHandler[controllers.Object]{AddFunc: c.queue.AddObject}) return c } func (c *autoServiceExportController) Run(stopCh <-chan struct{}) { kube.WaitForCacheSync("auto service export", stopCh, c.services.HasSynced) c.queue.Run(stopCh)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0)