Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewQueue (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top