Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NodeShouldRunDaemonPod (0.34 sec)

  1. pkg/controller/daemon/daemon_controller.go

    	for _, ds := range dsList {
    		// If NodeShouldRunDaemonPod needs to uses other than Labels and Taints (mutable) properties of node, it needs to update shouldIgnoreNodeUpdate.
    		oldShouldRun, oldShouldContinueRunning := NodeShouldRunDaemonPod(oldNode, ds)
    		currentShouldRun, currentShouldContinueRunning := NodeShouldRunDaemonPod(curNode, 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/update.go

    				node, err := dsc.nodeLister.Get(nodeName)
    				if err != nil {
    					return fmt.Errorf("couldn't get node for nodeName %q: %v", nodeName, err)
    				}
    				if shouldRun, _ := NodeShouldRunDaemonPod(node, ds); !shouldRun {
    					logger.V(5).Info("DaemonSet pod on node is not available and does not match scheduling constraints, remove old pod", "daemonset", klog.KObj(ds), "node", nodeName, "oldPod", klog.KObj(oldPod))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  3. pkg/controller/daemon/daemon_controller_test.go

    			for _, p := range c.podsOnNode {
    				p.Spec.NodeName = "test-node"
    				manager.podStore.Add(p)
    			}
    			c.ds.Spec.UpdateStrategy = *strategy
    			shouldRun, shouldContinueRunning := NodeShouldRunDaemonPod(node, c.ds)
    
    			if shouldRun != c.shouldRun {
    				t.Errorf("[%v] strategy: %v, predicateName: %v expected shouldRun: %v, got: %v", i, c.ds.Spec.UpdateStrategy.Type, c.predicateName, c.shouldRun, shouldRun)
    			}
    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