|
|
@ -139,6 +139,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error {
|
|
|
|
return false, err
|
|
|
|
return false, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
pods = append(pods, list...)
|
|
|
|
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:
|
|
|
|
case *appsv1.StatefulSet:
|
|
|
|
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
|
|
|
|
list, err := getPods(kcs, value.Namespace, value.Spec.Selector.MatchLabels)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
@ -163,6 +175,18 @@ func (c *Client) waitForResources(timeout time.Duration, created Result) error {
|
|
|
|
return false, err
|
|
|
|
return false, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
pods = append(pods, list...)
|
|
|
|
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:
|
|
|
|
case *v1.PersistentVolumeClaim:
|
|
|
|
claim, err := kcs.CoreV1().PersistentVolumeClaims(value.Namespace).Get(value.Name, metav1.GetOptions{})
|
|
|
|
claim, err := kcs.CoreV1().PersistentVolumeClaims(value.Namespace).Get(value.Name, metav1.GetOptions{})
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|