- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for HasSynced (0.16 sec)
-
cni/pkg/repair/repair_test.go
- t.Cleanup(func() {
- assert.NoError(t, c.queue.WaitForClose(time.Second))
- })
- stop := test.NewStop(t)
- tt.client.RunAndWait(stop)
- go c.Run(stop)
- kube.WaitForCacheSync("test", stop, c.queue.HasSynced)
- assert.EventuallyEqual(t, func() map[string]string {
- havePods := c.pods.List(metav1.NamespaceAll, klabels.Everything())
- slices.SortBy(havePods, func(a *corev1.Pod) string {
- return a.Name
- })
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
- }
- if util.PodRedirectionEnabled(ns, pod) {
- return pod, nil
- }
- return nil, nil
- }
- func (s *InformerHandlers) Start() {
- kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced)
- go s.queue.Run(s.ctx.Done())
- }
- // Gets a point-in-time snapshot of all pods that are CURRENTLY ambient enabled
- // (as per control plane annotation)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 11.7K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
- c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
- return c, nil
- }
- func (c *Controller) Run(stop <-chan struct{}) {
- kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced)
- c.queue.Run(stop)
- c.pods.ShutdownHandlers()
- }
- func (c *Controller) Reconcile(key types.NamespacedName) error {
- pod := c.pods.Get(key.Name, key.Namespace)
- if pod == nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
- - Shared informers now correctly propagate whether they are synced or not. Individual informer handlers may now check if they are synced or not (new `HasSynced` method). Library support is added to assist controllers in tracking whether their own work is completed for items in the initial list (`AsyncTracker`). ([#113985](https://github.com/kubernetes/kubernetes/pull/113985), [@lavalamp](https://github.com/lavalamp))...
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Jul 17 07:48:22 UTC 2024 - 466.3K bytes - Viewed (1)