Added util functions

Added support to deploy a test deployment
Added a function to check if pod is failed to be scheduled.

Signed-off-by: rbaturov <rbaturov@redhat.com>

test/e2e/performanceprofile/functests/utils/deployments/deployments.go

@@ -0,0 +1,92 @@
+package deployments
+
+import (
+	"context"
+	"time"
+
+	appsv1 "k8s.io/api/apps/v1"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/images"
+	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/pods"
+)
+
+func Make(name, namespace string, opts ...func(dp *appsv1.Deployment)) *appsv1.Deployment {
+	dp := GetTestDeployment(name, namespace)
+	for _, opt := range opts {
+		opt(dp)
+	}
+	return dp
+}
+
+func GetTestDeployment(name, namespace string) *appsv1.Deployment {
+	replicas := int32(1)
+
+	return &appsv1.Deployment{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      name,
+			Namespace: namespace,
+		},
+		Spec: appsv1.DeploymentSpec{
+			Replicas: &replicas,
+			Selector: &metav1.LabelSelector{
+				MatchLabels: map[string]string{
+					"test": "",
+				},
+			},
+			Template: corev1.PodTemplateSpec{
+				ObjectMeta: metav1.ObjectMeta{
+					Labels: map[string]string{
+						"test": "",
+					},
+				},
+				Spec: corev1.PodSpec{
+					Containers: []corev1.Container{
+						{
+							Name:    "test",
+							Image:   images.Test(),
+							Command: []string{"sleep", "10h"},
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func WithNodeSelector(nodeSelector map[string]string) func(dp *appsv1.Deployment) {
+	return func(dp *appsv1.Deployment) {
+		dp.Spec.Template.Spec.NodeSelector = nodeSelector
+	}
+}
+
+func WithReplicas(replicas int32) func(dp *appsv1.Deployment) {
+	return func(dp *appsv1.Deployment) {
+		dp.Spec.Replicas = &replicas
+	}
+}
+
+func WithPodTemplate(podTemplate *corev1.Pod) func(dp *appsv1.Deployment) {
+	return func(dp *appsv1.Deployment) {
+		dp.Spec.Template.Spec = podTemplate.Spec
+		dp.Spec.Template.ObjectMeta.Labels = podTemplate.ObjectMeta.Labels
+		dp.Spec.Selector.MatchLabels = podTemplate.ObjectMeta.Labels
+	}
+}
+
+func IsReady(ctx context.Context, cli client.Client, listOptions *client.ListOptions, podList *corev1.PodList, dp *appsv1.Deployment) (bool, error) {
+	if err := cli.List(ctx, podList, listOptions); err != nil || len(podList.Items) == 0 {
+		return false, err
+	}
+
+	for _, pod := range podList.Items {
+		_, err := pods.WaitForCondition(context.TODO(), client.ObjectKeyFromObject(&pod), corev1.PodReady, corev1.ConditionTrue, 10*time.Minute)
+		if err != nil {
+			return false, err
+		}
+	}
+
+	return true, nil
+}

test/e2e/performanceprofile/functests/utils/pods/pods.go

@@ -24,6 +24,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	testclient "github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/client"
+	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/events"
 	"github.com/openshift/cluster-node-tuning-operator/test/e2e/performanceprofile/functests/utils/images"
 )
 
@@ -250,3 +251,20 @@ func resourceListToString(res corev1.ResourceList) string {
 	}
 	return strings.Join(items, ", ")
 }
+
+func CheckPODSchedulingFailed(c client.Client, pod *corev1.Pod) (bool, error) {
+	events, err := events.GetEventsForObject(c, pod.Namespace, pod.Name, string(pod.UID))
+	if err != nil {
+		return false, err
+	}
+	if len(events.Items) == 0 {
+		return false, fmt.Errorf("no event received for %s/%s", pod.Namespace, pod.Name)
+	}
+
+	for _, item := range events.Items {
+		if item.Reason == "FailedScheduling" {
+			return true, nil
+		}
+	}
+	return false, nil
+}