- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetTargetNodeName (0.19 sec)
-
pkg/controller/daemon/util/daemonset_util.go
}, } return affinity } // GetTargetNodeName get the target node name of DaemonSet pods. If `.spec.NodeName` is not empty (nil), // return `.spec.NodeName`; otherwise, retrieve node name of pending pods from NodeAffinity. Return error // if failed to retrieve node name from `.spec.NodeName` and NodeAffinity. func GetTargetNodeName(pod *v1.Pod) (string, error) { if len(pod.Spec.NodeName) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 18 11:54:59 UTC 2022 - 9.3K bytes - Viewed (0) -
pkg/controller/daemon/util/daemonset_util_test.go
Name: "pod4", Namespace: "default", }, Spec: v1.PodSpec{}, }, expectedErr: true, }, } for _, test := range tests { got, err := GetTargetNodeName(test.pod) if test.expectedErr != (err != nil) { t.Errorf("Unexpected error, expectedErr: %v, err: %v", test.expectedErr, err) } else if !test.expectedErr { if test.nodeName != got {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
}) // mark one of the old pods that is on a node without an updated pod as unready setPodReadiness(t, manager, false, 1, func(pod *v1.Pod) bool { nodeName, err := util.GetTargetNodeName(pod) if err != nil { t.Fatal(err) } return pod.Labels[apps.ControllerRevisionHashLabelKey] != hash && len(currentPods[nodeName]) == 0 })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// store by the kubelet or the Pod GC. The DS controller doesn't have // anything else to do with it. continue } nodeName, err := util.GetTargetNodeName(pod) if err != nil { logger.V(4).Info("Failed to get target node name of Pod in DaemonSet", "pod", klog.KObj(pod), "daemonset", klog.KObj(ds)) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
if ready { if c := podutil.GetPodReadyCondition(pod.Status); c != nil { readyLast = c.LastTransitionTime.Time.Add(time.Duration(ds.Spec.MinReadySeconds) * time.Second) } } nodeName, _ := util.GetTargetNodeName(pod) lines = append(lines, fmt.Sprintf("node=%s current=%-5t ready=%-5t age=%-4d pod=%s now=%d available=%d", nodeName, hash == pod.Labels[apps.ControllerRevisionHashLabelKey], ready, now.Unix(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0)