Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueDaemonSet (0.98 sec)

  1. pkg/controller/daemon/daemon_controller.go

    	dsc.syncHandler = dsc.syncDaemonSet
    	dsc.enqueueDaemonSet = dsc.enqueue
    
    	dsc.failedPodsBackoff = failedPodsBackoff
    
    	return dsc, nil
    }
    
    func (dsc *DaemonSetsController) addDaemonset(logger klog.Logger, obj interface{}) {
    	ds := obj.(*apps.DaemonSet)
    	logger.V(4).Info("Adding daemon set", "daemonset", klog.KObj(ds))
    	dsc.enqueueDaemonSet(ds)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    			expectedCreates := 0
    			if c.expectedCreates != nil {
    				expectedCreates = c.expectedCreates()
    			}
    			expectSyncDaemonSets(t, manager, c.ds, podControl, expectedCreates, 0, expectedEvents)
    
    			manager.enqueueDaemonSet = func(ds *apps.DaemonSet) {
    				if ds.Name == "ds" {
    					enqueued = true
    				}
    			}
    
    			enqueued = false
    			manager.updateNode(logger, c.oldNode, c.newNode)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
Back to top