给scanner的部分event增加执行时间统计

scanner/internal/event/agent_cache_gc.go

@@ -40,8 +40,11 @@ func (t *AgentCacheGC) TryMerge(other Event) bool {
 
 func (t *AgentCacheGC) Execute(execCtx ExecuteContext) {
 	log := logger.WithType[AgentCacheGC]("Event")
+	startTime := time.Now()
 	log.Debugf("begin with %v", logger.FormatStruct(t.AgentCacheGC))
-	defer log.Debugf("end")
+	defer func() {
+		log.Debugf("end, time: %v", time.Since(startTime))
+	}()
 
 	// TODO unavailable的节点需不需要发送任务？
 

scanner/internal/event/agent_check_cache.go

@@ -40,9 +40,11 @@ func (t *AgentCheckCache) TryMerge(other Event) bool {
 
 func (t *AgentCheckCache) Execute(execCtx ExecuteContext) {
 	log := logger.WithType[AgentCheckCache]("Event")
+	startTime := time.Now()
 	log.Debugf("begin with %v", logger.FormatStruct(t.AgentCheckCache))
-	defer log.Debugf("end")
-
+	defer func() {
+		log.Debugf("end, time: %v", time.Since(startTime))
+	}()
 	// TODO unavailable的节点需不需要发送任务？
 
 	agtCli, err := stgglb.AgentMQPool.Acquire(t.NodeID)

scanner/internal/event/agent_storage_gc.go

@@ -37,8 +37,11 @@ func (t *AgentStorageGC) TryMerge(other Event) bool {
 
 func (t *AgentStorageGC) Execute(execCtx ExecuteContext) {
 	log := logger.WithType[AgentStorageGC]("Event")
+	startTime := time.Now()
 	log.Debugf("begin with %v", logger.FormatStruct(t.AgentStorageGC))
-	defer log.Debugf("end")
+	defer func() {
+		log.Debugf("end, time: %v", time.Since(startTime))
+	}()
 
 	// TODO unavailable的节点需不需要发送任务？
 

scanner/internal/event/check_package_redundancy.go

@@ -51,8 +51,11 @@ func (t *CheckPackageRedundancy) TryMerge(other Event) bool {
 
 func (t *CheckPackageRedundancy) Execute(execCtx ExecuteContext) {
 	log := logger.WithType[CheckPackageRedundancy]("Event")
+	startTime := time.Now()
 	log.Debugf("begin with %v", logger.FormatStruct(t.CheckPackageRedundancy))
-	defer log.Debugf("end")
+	defer func() {
+		log.Debugf("end, time: %v", time.Since(startTime))
+	}()
 
 	coorCli, err := stgglb.CoordinatorMQPool.Acquire()
 	if err != nil {

scanner/internal/event/clean_pinned.go

@@ -5,6 +5,7 @@ import (
 	"math"
 	"math/rand"
 	"sync"
+	"time"
 
 	"github.com/samber/lo"
 	"gitlink.org.cn/cloudream/common/pkgs/bitmap"
@@ -44,8 +45,11 @@ func (t *CleanPinned) TryMerge(other Event) bool {
 
 func (t *CleanPinned) Execute(execCtx ExecuteContext) {
 	log := logger.WithType[CleanPinned]("Event")
+	startTime := time.Now()
 	log.Debugf("begin with %v", logger.FormatStruct(t.CleanPinned))
-	defer log.Debugf("end")
+	defer func() {
+		log.Debugf("end, time: %v", time.Since(startTime))
+	}()
 
 	coorCli, err := stgglb.CoordinatorMQPool.Acquire()
 	if err != nil {