Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewRepairController (0.12 sec)

  1. cni/pkg/repair/repair.go

    	}
    	repairLog.Info("starting CNI sidecar repair controller")
    
    	client, err := clientSetup()
    	if err != nil {
    		repairLog.Fatalf("CNI repair could not construct clientSet: %s", err)
    	}
    
    	rc, err := NewRepairController(client, cfg)
    	if err != nil {
    		repairLog.Fatalf("Fatal error constructing repair controller: %+v", err)
    	}
    	go rc.Run(ctx.Done())
    	client.RunAndWait(ctx.Done())
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. cni/pkg/repair/repaircontroller.go

    	pods         kclient.Client[*corev1.Pod]
    	queue        controllers.Queue
    	cfg          config.RepairConfig
    	events       kclient.EventRecorder
    	repairedPods map[types.NamespacedName]types.UID
    }
    
    func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) {
    	c := &Controller{
    		cfg:          cfg,
    		client:       client,
    		events:       kclient.NewEventRecorder(client, "cni-repair"),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top