feat(kubernetes): check if DaemonSet is ready

Signed-off-by: Chin-Ya Huang <[email protected]>
longhorn · May 2, 2024 · 5a4d394 · 5a4d394
1 parent 1fa9c14
commit 5a4d394
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/kubernetes/daemonset.go b/kubernetes/daemonset.go
@@ -65,3 +65,8 @@ func GetDaemonSet(kubeClient kubeclient.Interface, namespace, name string) (*app
 
 	return kubeClient.AppsV1().DaemonSets(namespace).Get(context.Background(), name, metav1.GetOptions{})
 }
+
+// IsDaemonSetReady checks if the DaemonSet is ready by comparing the number of ready pods with the desired number of pods.
+func IsDaemonSetReady(daemonSet *appsv1.DaemonSet) bool {
+	return daemonSet.Status.NumberReady == daemonSet.Status.DesiredNumberScheduled
+}