added error handling

This commit is contained in:
2023-08-04 01:08:02 +02:00
parent 078fd60454
commit 79f0395de4
6 changed files with 259 additions and 118 deletions

View File

@@ -40,7 +40,7 @@ public class KubernetesService : IKubernetesService
CreateKubernetesClient(clusterContext);
}
public IEnumerable<Namespace> GetNamespaces()
public async Task<IEnumerable<Namespace>> GetNamespacesAsync()
{
var namespaces = _kubernetesClient.CoreV1.ListNamespace();
var namespaceList = namespaces != null
@@ -49,9 +49,9 @@ public class KubernetesService : IKubernetesService
return namespaceList;
}
public IEnumerable<Pod> GetPods(string namespaceName)
public async Task<IEnumerable<Pod>> GetPodsAsync(string namespaceName, CancellationToken cancellationToken = default)
{
var pods = _kubernetesClient.CoreV1.ListNamespacedPod(namespaceName);
var pods = await _kubernetesClient.CoreV1.ListNamespacedPodAsync(namespaceName, cancellationToken: cancellationToken);
var podList = pods != null
? pods.Items.Select(n =>
new Pod