From f31ad4f9f0884285264d78160e7befd52a4b1e00 Mon Sep 17 00:00:00 2001 From: "M. Mert Yildiran" Date: Tue, 29 Nov 2022 03:59:09 +0300 Subject: [PATCH] :bug: Add cleaning procedures for the `front` pod --- resources/cleanResources.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/resources/cleanResources.go b/resources/cleanResources.go index 676878560..04bec142a 100644 --- a/resources/cleanResources.go +++ b/resources/cleanResources.go @@ -97,6 +97,11 @@ func waitUntilNamespaceDeleted(ctx context.Context, cancel context.CancelFunc, k func cleanUpRestrictedMode(ctx context.Context, kubernetesProvider *kubernetes.Provider, kubesharkResourcesNamespace string) []string { leftoverResources := make([]string, 0) + if err := kubernetesProvider.RemoveService(ctx, kubesharkResourcesNamespace, kubernetes.FrontServiceName); err != nil { + resourceDesc := fmt.Sprintf("Service %s in namespace %s", kubernetes.FrontServiceName, kubesharkResourcesNamespace) + handleDeletionError(err, resourceDesc, &leftoverResources) + } + if err := kubernetesProvider.RemoveService(ctx, kubesharkResourcesNamespace, kubernetes.HubServiceName); err != nil { resourceDesc := fmt.Sprintf("Service %s in namespace %s", kubernetes.HubServiceName, kubesharkResourcesNamespace) handleDeletionError(err, resourceDesc, &leftoverResources) @@ -153,6 +158,11 @@ func cleanUpRestrictedMode(ctx context.Context, kubernetesProvider *kubernetes.P handleDeletionError(err, resourceDesc, &leftoverResources) } + if err := kubernetesProvider.RemovePod(ctx, kubesharkResourcesNamespace, kubernetes.FrontPodName); err != nil { + resourceDesc := fmt.Sprintf("Pod %s in namespace %s", kubernetes.FrontPodName, kubesharkResourcesNamespace) + handleDeletionError(err, resourceDesc, &leftoverResources) + } + return leftoverResources }