diff --git a/pkg/kube/wait.go b/pkg/kube/wait.go index 5bbc4fce6..27ede15db 100644 --- a/pkg/kube/wait.go +++ b/pkg/kube/wait.go @@ -139,6 +139,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error { return false, err } pods = append(pods, list...) + case *appsv1.DaemonSet: + list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels) + if err != nil { + return false, err + } + pods = append(pods, list...) + case *appsv1beta2.DaemonSet: + list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels) + if err != nil { + return false, err + } + pods = append(pods, list...) case *appsv1.StatefulSet: list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels) if err != nil { @@ -163,6 +175,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error { return false, err } pods = append(pods, list...) + case *appsv1beta2.ReplicaSet: + list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels) + if err != nil { + return false, err + } + pods = append(pods, list...) + case *appsv1.ReplicaSet: + list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels) + if err != nil { + return false, err + } + pods = append(pods, list...) case *v1.PersistentVolumeClaim: claim, err := kcs.CoreV1().PersistentVolumeClaims(value.Namespace).Get(value.Name, metav1.GetOptions{}) if err != nil {