Skip to content

Commit db39e09

Browse files
paolomainardiMatthew Fisher
authored andcommitted
adding other missing apiVersions
(cherry picked from commit b065ffe)
1 parent e3a8b80 commit db39e09

File tree

1 file changed

+24
-0
lines changed

1 file changed

+24
-0
lines changed

pkg/kube/wait.go

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error {
139139
return false, err
140140
}
141141
pods = append(pods, list...)
142+
case *appsv1.DaemonSet:
143+
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
144+
if err != nil {
145+
return false, err
146+
}
147+
pods = append(pods, list...)
148+
case *appsv1beta2.DaemonSet:
149+
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
150+
if err != nil {
151+
return false, err
152+
}
153+
pods = append(pods, list...)
142154
case *appsv1.StatefulSet:
143155
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
144156
if err != nil {
@@ -163,6 +175,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error {
163175
return false, err
164176
}
165177
pods = append(pods, list...)
178+
case *appsv1beta2.ReplicaSet:
179+
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
180+
if err != nil {
181+
return false, err
182+
}
183+
pods = append(pods, list...)
184+
case *appsv1.ReplicaSet:
185+
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
186+
if err != nil {
187+
return false, err
188+
}
189+
pods = append(pods, list...)
166190
case *v1.PersistentVolumeClaim:
167191
claim, err := kcs.CoreV1().PersistentVolumeClaims(value.Namespace).Get(value.Name, metav1.GetOptions{})
168192
if err != nil {

0 commit comments

Comments
 (0)