Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for WithReconciler (0.2 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
    }
    
    func (c *Controller) Run(stop <-chan struct{}) {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
Back to top