scheduler

package

v0.1.13 Latest Latest Go to latest Published: May 23, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MonitorScheduler struct {
	// contains filtered or unexported fields
}

MonitorScheduler 监控任务调度器

func NewMonitorScheduler(monitorService *service.MonitorService, logger *zap.Logger) *MonitorScheduler

NewMonitorScheduler 创建监控任务调度器

func (s *MonitorScheduler) AddTask(monitorID string, interval int) error

AddTask 添加监控任务

func (s *MonitorScheduler) GetTaskCount() int

GetTaskCount 获取任务数量

func (s *MonitorScheduler) GetTaskStatus() map[string]interface{}

GetTaskStatus 获取任务状态

func (s *MonitorScheduler) LoadTasks()

LoadTasks 加载所有启用的监控任务

func (s *MonitorScheduler) RemoveTask(monitorID string)

RemoveTask 删除监控任务

func (s *MonitorScheduler) Start(ctx context.Context)

Start 启动调度器

func (s *MonitorScheduler) Stop()

Stop 停止调度器

func (s *MonitorScheduler) UpdateTask(monitorID string, interval int) error

UpdateTask 更新监控任务（先删除再添加）

type MonitorTask struct {
	ID      string       // 监控任务 ID
	EntryID cron.EntryID // cron 任务的 ID
}

MonitorTask 调度任务（轻量级，仅存储必要信息）