feat: add log alerting function to api

Author: CutebreadCat

api/mw/monitor/monitor.go

@@ -41,22 +41,60 @@ type MonitorConfig struct {
 var (
 	apiMonitorInstance  *apiMonitor
 	apiMonitorStartOnce sync.Once
+	apiMonitorStop      = func(context.Context) {}
 )
 
-func StartAPIMonitor(cfg MonitorConfig) {
+// StartAPIMonitor 启动 API 监控后台检查，并返回用于优雅停止监控的函数。
+// 停止函数会等待后台检查 goroutine 退出，便于服务关闭时完成资源清理。
+func StartAPIMonitor(cfg MonitorConfig) func(context.Context) {
+	// 监控进程生命周期与服务进程一致，只允许初始化一次。
 	apiMonitorStartOnce.Do(func() {
 		apiMonitorInstance = newAPIMonitor(cfg)
 		if !apiMonitorInstance.enabled() {
+			// 未启用监控时不启动后台任务，返回默认的空操作停止函数。
 			return
 		}
 
+		interval := apiMonitorInstance.checkInterval()
+		if interval <= 0 {
+			// 无效的检查间隔不能用于创建 ticker，避免启动时 panic。
+			return
+		}
+
+		// cancel 用于通知后台任务退出，done 用于确认检查 goroutine 已结束。
+		ctx, cancel := context.WithCancel(context.Background())
+		checkDone := make(chan struct{})
 		go func() {
+			defer close(checkDone)
+
+			ticker := time.NewTicker(interval)
+			defer ticker.Stop()
+
 			for {
-				time.Sleep(apiMonitorInstance.checkInterval())
-				apiMonitorInstance.check()
+				select {
+				case <-ticker.C:
+					// 定期清理滑动窗口并检查各路由的错误率。
+					apiMonitorInstance.check()
+				case <-ctx.Done():
+					// 服务关闭时优先响应取消信号，不再执行新的检查。
+					return
+				}
 			}
 		}()
+
+		apiMonitorStop = func(ctx context.Context) {
+			cancel()
+			// 等待检查循环退出，避免服务关闭后仍残留后台任务。
+			select {
+			case <-checkDone:
+			case <-ctx.Done():
+				return
+			}
+		}
 	})
+
+	// API 服务会在 OnShutdown hook 中调用该函数。
+	return apiMonitorStop
 }
 
 func APIMonitorMiddleware() app.HandlerFunc {

api/mw/monitor/monitor_test.go

@@ -17,6 +17,8 @@ limitations under the License.
 package monitor
 
 import (
+	"context"
+	"sync"
 	"testing"
 	"time"
 
@@ -108,6 +110,34 @@ func TestMonitorRecordSkipsDisabledAndBlacklisted(t *testing.T) {
 	assert.Equal(t, "/api/bar", enabled.events[0].route)
 }
 
+func TestStartAPIMonitorStopReturnsBeforeNextCheck(t *testing.T) {
+	apiMonitorInstance = nil
+	apiMonitorStartOnce = sync.Once{}
+	apiMonitorStop = func(context.Context) {}
+	defer func() {
+		apiMonitorInstance = nil
+		apiMonitorStartOnce = sync.Once{}
+		apiMonitorStop = func(context.Context) {}
+	}()
+
+	stop := StartAPIMonitor(MonitorConfig{
+		Enabled:       true,
+		CheckInterval: time.Hour,
+	})
+
+	done := make(chan struct{})
+	go func() {
+		stop(context.Background())
+		close(done)
+	}()
+
+	select {
+	case <-done:
+	case <-time.After(time.Second):
+		t.Fatal("api monitor stop should not wait for the next check interval")
+	}
+}
+
 func TestMonitorAlertCooldownAndRecover(t *testing.T) {
 	monitor := newAPIMonitor(MonitorConfig{
 		Enabled:       true,