- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewQueue (0.13 sec)
-
cni/pkg/nodeagent/informers.go
s := &InformerHandlers{ctx: ctx, dataplane: dataplane, systemNamespace: systemNamespace} s.queue = controllers.NewQueue("ambient", controllers.WithGenericReconciler(s.reconcile), controllers.WithMaxAttempts(5), ) // We only need to handle pods on our node
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{ LabelSelector: cfg.LabelSelectors, FieldSelector: strings.Join(fieldSelectors, ","), }) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)