Function GetPrimary

tests/utils/clusterutils/cluster.go:160–188

GetPrimary gets the primary pod of a cluster

(
	ctx context.Context,
	crudClient client.Client,
	namespace, clusterName string,
)

// GetPrimary gets the primary pod of a cluster
func GetPrimary(
	ctx context.Context,
	crudClient client.Client,
	namespace, clusterName string,
) (*corev1.Pod, error) {
	podList := &corev1.PodList{}

	err := objects.List(ctx, crudClient, podList, client.InNamespace(namespace),
		client.MatchingLabels{
			utils.ClusterLabelName:             clusterName,
			utils.ClusterInstanceRoleLabelName: specs.ClusterRoleLabelPrimary,
		},
	)
	if err != nil {
		return &corev1.Pod{}, err
	}
	if len(podList.Items) > 0 {
		// if there are multiple, get the one without deletion timestamp
		for _, pod := range podList.Items {
			if pod.DeletionTimestamp == nil {
				return &pod, nil
			}
		}
		err = fmt.Errorf("all pod with primary role has deletion timestamp")
		return &(podList.Items[0]), err
	}
	err = fmt.Errorf("no primary found")
	return &corev1.Pod{}, err
}

// GetReplicas gets a slice containing all the replica pods of a cluster
func GetReplicas(