implement cache wipe in control loop

pluralsh · Sep 29, 2023 · a8d1286 · a8d1286
1 parent feba2e9
commit a8d1286
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/pkg/agent/agent.go b/pkg/agent/agent.go
@@ -87,6 +87,7 @@ func (agent *Agent) Run() {
 
 	for {
 		log.Info("fetching services for cluster")
+		agent.engine.WipeCache()
 		svcs, err := agent.consoleClient.GetServices()
 		if err != nil {
 			log.Error(err, "failed to fetch service list from deployments service")

diff --git a/pkg/sync/engine.go b/pkg/sync/engine.go
@@ -46,6 +46,11 @@ func (engine *Engine) RegisterHandlers() {
 	})
 }
 
+func (engine *Engine) WipeCache() {
+	engine.svcCache.Wipe()
+	engine.manifestCache.Wipe()
+}
+
 func isRoot(r *cache.Resource) bool {
 	return svcId(r) != nil && len(r.OwnerRefs) == 0
 }