Function GetDeployment

tests/utils/operator/operator.go:102–137

GetDeployment returns the operator Deployment if there is a single one running, error otherwise

(ctx context.Context, crudClient client.Client)

// GetDeployment returns the operator Deployment if there is a single one running, error otherwise
func GetDeployment(ctx context.Context, crudClient client.Client) (appsv1.Deployment, error) {
	deploymentList := &appsv1.DeploymentList{}
	if err := objects.List(ctx, crudClient, deploymentList,
		client.MatchingLabels{"app.kubernetes.io/name": "cloudnative-pg"},
	); err != nil {
		return appsv1.Deployment{}, err
	}
	// We check if we have one or more deployments
	switch {
	case len(deploymentList.Items) > 1:
		err := fmt.Errorf("number of operator deployments != 1")
		return appsv1.Deployment{}, err
	case len(deploymentList.Items) == 1:
		return deploymentList.Items[0], nil
	}

	if err := objects.List(
		ctx,
		crudClient,
		deploymentList,
		client.HasLabels{"operators.coreos.com/cloudnative-pg.openshift-operators"},
	); err != nil {
		return appsv1.Deployment{}, err
	}

	// We check if we have one or more deployments
	switch {
	case len(deploymentList.Items) > 1:
		err := fmt.Errorf("number of operator deployments != 1")
		return appsv1.Deployment{}, err
	case len(deploymentList.Items) == 1:
		return deploymentList.Items[0], nil
	}

	return deploymentList.Items[0], nil
}

// 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) {