Merge pull request #251 from ryankwilliams/deployment-available-condi…

…tion

Add condition for checking if a deployment is available

klient/wait/conditions/conditions.go

@@ -27,6 +27,7 @@ import (
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	apimachinerywait "k8s.io/apimachinery/pkg/util/wait"
 
 	"sigs.k8s.io/e2e-framework/klient/k8s"
@@ -292,3 +293,13 @@ func (c *Condition) JobCompleted(job k8s.Object) apimachinerywait.ConditionWithC
 func (c *Condition) JobFailed(job k8s.Object) apimachinerywait.ConditionWithContextFunc {
 	return c.JobConditionMatch(job, batchv1.JobFailed, v1.ConditionTrue)
 }
+
+// DeploymentAvailable is a helper function used to check if the deployment condition appsv1.DeploymentAvailable
+// has reached v1.ConditionTrue state
+func (c *Condition) DeploymentAvailable(name, namespace string) apimachinerywait.ConditionWithContextFunc {
+	return c.DeploymentConditionMatch(
+		&appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: name, Namespace: namespace}},
+		appsv1.DeploymentAvailable,
+		v1.ConditionTrue,
+	)
+}

klient/wait/wait_test.go

@@ -237,3 +237,12 @@ func TestResourceMatch(t *testing.T) {
 	}
 	log.Info("Done")
 }
+
+func TestDeploymentAvailable(t *testing.T) {
+	var err error
+	deployment := createDeployment("d7", 2, t)
+	err = For(conditions.New(getResourceManager()).DeploymentAvailable(deployment.Name, deployment.Namespace))
+	if err != nil {
+		t.Error("failed waiting for deployment to become available")
+	}
+}