- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewQueue (0.15 sec)
-
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) -
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) -
architecture/networking/controllers.md
With a few exceptions, Istio controllers typically are split in two phases: construction and running. Construction should create informers (via `kclient.New`), setup a queue (via `controllers.NewQueue`), and register event handlers on the informers. Often, these handlers are adding something to the queue like `client.AddEventHandler(controllers.ObjectHandler(queue.AddObject))`.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Feb 09 17:41:25 GMT 2024 - 4.9K bytes - Viewed (0)