feat: adds slow log for controller recorder updaters

deepflowio · Aug 13, 2024 · b12d022 · b12d022
1 parent 1d38c5b
commit b12d022
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/server/controller/recorder/domain.go b/server/controller/recorder/domain.go
@@ -231,7 +231,9 @@ func (d *domain) getUpdatersInOrder(cloudData cloudmodel.Resource) []updater.Res
 // TODO common
 func (r *domain) executeUpdaters(updatersInUpdateOrder []updater.ResourceUpdater) {
 	for _, updater := range updatersInUpdateOrder {
+		log.Infof("updater %s started", updater.GetResourceType(), r.metadata.LogPrefixes)
 		updater.HandleAddAndUpdate()
+		log.Infof("updater %s completed", updater.GetResourceType(), r.metadata.LogPrefixes)
 	}
 
 	// 删除操作的顺序，是创建的逆序
@@ -241,9 +243,13 @@ func (r *domain) executeUpdaters(updatersInUpdateOrder []updater.ResourceUpdater
 	vmPodNodeConnectionUpdater := updatersInUpdateOrder[len(updatersInUpdateOrder)-2]
 	// 因为 processUpdater 是 -1，VMPodNodeConnection 是 -2，特殊处理后，逆序删除从 -3 开始
 	for i := len(updatersInUpdateOrder) - 3; i >= 0; i-- {
+		log.Infof("updater %s started", updatersInUpdateOrder[i].GetResourceType(), r.metadata.LogPrefixes)
 		updatersInUpdateOrder[i].HandleDelete()
+		log.Infof("updater %s started", updatersInUpdateOrder[i].GetResourceType(), r.metadata.LogPrefixes)
 	}
+	log.Infof("updater %s started", processUpdater.GetResourceType(), r.metadata.LogPrefixes)
 	processUpdater.HandleDelete()
+	log.Infof("updater %s completed", processUpdater.GetResourceType(), r.metadata.LogPrefixes)
 	vmPodNodeConnectionUpdater.HandleDelete()
 }