codex-storage/cs-codex-dist-tests
1
0
Fork 0
mirror of https://github.com/codex-storage/cs-codex-dist-tests.git synced 2025-02-10 19:16:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adds names to kube wait functions

Browse Source
This commit is contained in:
benbierens 2024-04-14 08:56:22 +02:00
parent a2e4869403
commit d847c4f3ec
No known key found for this signature in database
GPG Key ID: 877D2C2E09A22F3A
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
Framework/KubernetesWorkflow/K8sController.cs
View File

@ -868,7 +868,7 @@ namespace KubernetesWorkflow
private void WaitUntilNamespaceCreated() private void WaitUntilNamespaceCreated()
{ {
WaitUntil(() => IsNamespaceOnline(K8sNamespace)); WaitUntil(() => IsNamespaceOnline(K8sNamespace), nameof(WaitUntilNamespaceCreated));
} }
private void WaitUntilDeploymentOnline(string deploymentName) private void WaitUntilDeploymentOnline(string deploymentName)
@ -877,7 +877,7 @@ namespace KubernetesWorkflow
{ {
var deployment = client.Run(c => c.ReadNamespacedDeployment(deploymentName, K8sNamespace)); var deployment = client.Run(c => c.ReadNamespacedDeployment(deploymentName, K8sNamespace));
return deployment?.Status.AvailableReplicas != null && deployment.Status.AvailableReplicas > 0; return deployment?.Status.AvailableReplicas != null && deployment.Status.AvailableReplicas > 0;
}); }, nameof(WaitUntilDeploymentOnline));
} }
private void WaitUntilDeploymentOffline(string deploymentName) private void WaitUntilDeploymentOffline(string deploymentName)
@ -887,7 +887,7 @@ namespace KubernetesWorkflow
var deployments = client.Run(c => c.ListNamespacedDeployment(K8sNamespace)); var deployments = client.Run(c => c.ListNamespacedDeployment(K8sNamespace));
var deployment = deployments.Items.SingleOrDefault(d => d.Metadata.Name == deploymentName); var deployment = deployments.Items.SingleOrDefault(d => d.Metadata.Name == deploymentName);
return deployment == null || deployment.Status.AvailableReplicas == 0; return deployment == null || deployment.Status.AvailableReplicas == 0;
}); }, nameof(WaitUntilDeploymentOffline));
} }
private void WaitUntilPodsForDeploymentAreOffline(RunningDeployment deployment) private void WaitUntilPodsForDeploymentAreOffline(RunningDeployment deployment)
@ -896,10 +896,10 @@ namespace KubernetesWorkflow
{ {
var pods = FindPodsByLabel(deployment.PodLabel); var pods = FindPodsByLabel(deployment.PodLabel);
return !pods.Any(); return !pods.Any();
}); }, nameof(WaitUntilPodsForDeploymentAreOffline));
} }
private void WaitUntil(Func<bool> predicate) private void WaitUntil(Func<bool> predicate, string msg)
{ {
var sw = Stopwatch.Begin(log, true); var sw = Stopwatch.Begin(log, true);
try try
@ -908,7 +908,7 @@ namespace KubernetesWorkflow
} }
finally finally
{ {
sw.End("", 1); sw.End(msg, 1);
} }
} }