- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for DeleteFunc (0.17 sec)
-
plugin/pkg/auth/authorizer/node/graph_populator.go
podHandler, _ := pods.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ 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{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
src/maps/maps.go
// with the key in src. func Copy[M1 ~map[K]V, M2 ~map[K]V, K comparable, V any](dst M1, src M2) { for k, v := range src { dst[k] = v } } // DeleteFunc deletes any key/value pairs from m for which del returns true. func DeleteFunc[M ~map[K]V, K comparable, V any](m M, del func(K, V) bool) { for k, v := range m { if del(k, v) { delete(m, k) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 28 20:35:05 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/kube/controllers/common.go
if e.UpdateFunc != nil { e.UpdateFunc(Extract[T](oldObj), Extract[T](newObj)) } } func (e EventHandler[T]) OnDelete(obj interface{}) { if e.DeleteFunc != nil { e.DeleteFunc(Extract[T](obj)) } } var _ cache.ResourceEventHandler = EventHandler[Object]{} type Shutdowner interface { ShutdownHandlers() }
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/encoding/csv/fuzz_test.go
// Note that the reader parses the quoted record "" as an empty string, // and the writer turns that into an empty line, which the reader skips over. // Filter those out to avoid false positives. records = slices.DeleteFunc(records, func(record []string) bool { return len(record) == 1 && record[0] == "" }) // The reader uses nil when returning no records at all. if len(records) == 0 { records = nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 01:26:13 UTC 2024 - 2.5K bytes - Viewed (0) -
src/crypto/tls/defaults.go
ECDSAWithSHA1, } var tlsrsakex = godebug.New("tlsrsakex") var tls3des = godebug.New("tls3des") func defaultCipherSuites() []uint16 { suites := slices.Clone(cipherSuitesPreferenceOrder) return slices.DeleteFunc(suites, func(c uint16) bool { return disabledCipherSuites[c] || tlsrsakex.Value() != "1" && rsaKexCiphers[c] || tls3des.Value() != "1" && tdesCiphers[c] }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 3.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/unusedresult/unusedresult.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 19:00:13 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/test_helpers.go
AddFunc: func(obj controllers.Object) { tracker.Record("add/" + obj.GetName()) }, UpdateFunc: func(oldObj, newObj controllers.Object) { tracker.Record("update/" + newObj.GetName()) }, DeleteFunc: func(obj controllers.Object) { tracker.Record("delete/" + obj.GetName()) }, } } func Names[T controllers.Object](list []T) sets.String {
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/controlplane/controller/legacytokentracking/controller.go
} 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 } func (c *Controller) enqueue() { c.queue.Add(queueKey) } // Run starts the controller sync loop.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
UpdateFunc: func(old, new interface{}) { oldCSR := old.(*certificates.CertificateSigningRequest) logger.V(4).Info("Updating certificate request", "old", oldCSR.Name) cc.enqueueCertificateRequest(new) }, DeleteFunc: func(obj interface{}) { csr, ok := obj.(*certificates.CertificateSigningRequest) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
workqueue.TypedRateLimitingQueueConfig[string]{ Name: "root_ca_cert_publisher", }, ), } cmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ DeleteFunc: e.configMapDeleted, UpdateFunc: e.configMapUpdated, }) e.cmLister = cmInformer.Lister() e.cmListerSynced = cmInformer.Informer().HasSynced nsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0)