Skip to content

Commit 9d94e47

Browse files
author
Keerthan Mala
committed
fix(cleaner): builder taking high CPU
1 parent 7df5844 commit 9d94e47

1 file changed

Lines changed: 14 additions & 9 deletions

File tree

pkg/cleaner/cleaner.go

Lines changed: 14 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -26,16 +26,21 @@ func Run(gitHome string, nsLister k8s.NamespaceWatcher, fs sys.FS) error {
2626
log.Printf("unable to get watch events (%s)", err)
2727
}
2828
for {
29-
event := <-watcher.ResultChan()
30-
if event.Type == "DELETED" {
31-
switch event.Object.(type) {
32-
case (*api.Namespace):
33-
namespace := event.Object.(*api.Namespace)
34-
appToDelete := gitHome + "/" + namespace.ObjectMeta.Name + dotGitSuffix
35-
if err := fs.RemoveAll(appToDelete); err != nil {
36-
log.Printf("Cleaner error removing deleted app %s (%s)", appToDelete, err)
29+
select {
30+
case event, ok := <-watcher.ResultChan():
31+
if !ok {
32+
break
33+
}
34+
if event.Type == "DELETED" {
35+
switch event.Object.(type) {
36+
case (*api.Namespace):
37+
namespace := event.Object.(*api.Namespace)
38+
appToDelete := gitHome + "/" + namespace.ObjectMeta.Name + dotGitSuffix
39+
if err := fs.RemoveAll(appToDelete); err != nil {
40+
log.Printf("Cleaner error removing deleted app %s (%s)", appToDelete, err)
41+
}
42+
default:
3743
}
38-
default:
3944
}
4045
}
4146
}

0 commit comments

Comments
 (0)