Function GetPod

tests/utils/operator/operator.go:140–157

GetPod returns the operator pod if there is a single one running, error otherwise

(ctx context.Context, crudClient client.Client)

// GetPod returns the operator pod if there is a single one running, error otherwise
func GetPod(ctx context.Context, crudClient client.Client) (corev1.Pod, error) {
	podList := &corev1.PodList{}

	// This will work for newer versions of the operator, which are using
	// our custom label
	if err := objects.List(
		ctx, crudClient,
		podList, client.MatchingLabels{"app.kubernetes.io/name": "cloudnative-pg"}); err != nil {
		return corev1.Pod{}, err
	}
	activePods := utils.FilterActivePods(podList.Items)
	if len(activePods) != 1 {
		err := fmt.Errorf("number of running operator different than 1: %v pods running", len(activePods))
		return corev1.Pod{}, err
	}

	return activePods[0], nil
}

// NamespaceName returns the namespace the operator Deployment is running in
func NamespaceName(ctx context.Context, crudClient client.Client) (string, error) {