- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for HasSynced (0.27 sec)
-
pkg/revisions/tag_watcher.go
return } // Notify handlers of initial state p.notifyHandlers() p.queue.Run(stopCh) } // AddHandler registers a new handler for updates to tag changes. func (p *tagWatcher) AddHandler(handler TagHandler) { p.handlers = append(p.handlers, handler) } func (p *tagWatcher) HasSynced() bool { return p.queue.HasSynced() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kube/krt/informer.go
i.inf.AddEventHandler(informerEventHandler[I](func(o Event[I], initialSync bool) { f([]Event[I]{o}, initialSync) })) } return pollSyncer{ name: fmt.Sprintf("%v handler", i.name()), f: i.inf.HasSynced, } } func informerEventHandler[I controllers.ComparableObject](handler func(o Event[I], initialSync bool)) cache.ResourceEventHandler { return controllers.EventHandler[I]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
if err != nil { return nil, err } } ic.nodeLister = nodeInformer.Lister() ic.nodeInformerSynced = nodeInformer.Informer().HasSynced return ic, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes. func (nc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
}, }) // Start namespaces and wait for it to be ready now. This is required for subsequent users, so we want to block namespaces.Start(stop) kube.WaitForCacheSync("discovery filter", stop, namespaces.HasSynced) f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), false) return f } func (d *discoveryNamespacesFilter) notifyHandlersLocked(added sets.Set[string], removed sets.String) { for _, h := range d.handlers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0)