(deploymentName string)
| 193 | } |
| 194 | |
| 195 | func markDeploymentReady(deploymentName string) { |
| 196 | namespacedName := namespacedName(deploymentName, testNamespace) |
| 197 | deploy := &appsv1.Deployment{} |
| 198 | Eventually(func() error { |
| 199 | err := k8sClient.Get(ctx, namespacedName, deploy) |
| 200 | if err != nil { |
| 201 | return err |
| 202 | } |
| 203 | deploy.Status.ReadyReplicas = 1 |
| 204 | deploy.Status.Replicas = 1 |
| 205 | deploy.Status.AvailableReplicas = 1 |
| 206 | deploy.Status.UpdatedReplicas = 1 |
| 207 | return k8sClient.Status().Update(ctx, deploy) |
| 208 | }, 30*time.Second, 250*time.Millisecond).Should(Succeed(), "Update Deployment to have 1 ready replica") |
| 209 | } |
| 210 | |
| 211 | func scaleDeploymentToZero(deploymentName string) { |
| 212 | namespacedName := namespacedName(deploymentName, testNamespace) |
no test coverage detected