func getPodsStatusByLabel()

in action/k8s/status.go [40:74]
23 lines of code
5 McCabe index (conditional complexity)

func getPodsStatusByLabel(namespace, labelSelector string) ([]string, error) {
	client, err := utils.GetClient()
	if err != nil {
		return nil, fmt.Errorf("failed to create client: %v", err)
	}

	// Retrieve all Pods with the specified label
	// Use LabelSelector to filter Pods with the specified cr_name label
	labelSelector = Label + "=" + labelSelector
	pods, err := client.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{
		LabelSelector: labelSelector,
	})

	if err != nil {
		return nil, fmt.Errorf("failed to list pods: %v", err)
	}

	// Check if any pods were found
	if len(pods.Items) == 0 {
		return nil, fmt.Errorf("no matching pods found") // Alternatively, return a specific error message as needed
	}

	// Iterate over all Pods and get their status
	var statuses []string

	// Build formatted status string for output
	statuses = append(statuses, fmt.Sprintf("%-25s %-10s", "POD NAME", "STATUS")) // Header
	statuses = append(statuses, fmt.Sprintf("%s", "-------------------------------------------"))

	for _, pod := range pods.Items {
		statuses = append(statuses, fmt.Sprintf("%-25s %-10s", pod.Name, pod.Status.Phase))
	}

	return statuses, nil
}