Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewRepairController (0.19 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/repair_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			mt := monitortest.New(t)
    			tt.config.LabelPods = true
    			c, err := NewRepairController(tt.client, tt.config)
    			assert.NoError(t, err)
    			t.Cleanup(func() {
    				assert.NoError(t, c.queue.WaitForClose(time.Second))
    			})
    			stop := test.NewStop(t)
    			tt.client.RunAndWait(stop)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  3. 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