Method EveryInterval

pkg/core/scheduler.go:209–261

EveryInterval 每隔一段时间执行

(interval time.Duration, callback TaskCallback)

// EveryInterval 每隔一段时间执行
func (s *Scheduler) EveryInterval(interval time.Duration, callback TaskCallback) (string, error) {
	if interval <= 0 {
		return "", fmt.Errorf("interval must be positive, got %v", interval)
	}

	s.mu.Lock()
	defer s.mu.Unlock()

	id := generateTaskID("interval")
	ticker := time.NewTicker(interval)
	stopCh := make(chan struct{})

	task := &IntervalTask{
		ID:       id,
		Interval: interval,
		Callback: callback,
		ticker:   ticker,
		stopCh:   stopCh,
	}

	s.intervalTasks[id] = task

	// 启动定时器
	s.wg.Add(1)
	go func() {
		defer s.wg.Done()

		for {
			select {
			case <-ticker.C:
				// 执行回调
				if err := callback(s.ctx); err != nil {
					schedulerLog.Warn(s.ctx, "interval task callback error", map[string]any{"task_id": id, "error": err})
				}

				// 通知触发
				if s.opts.OnTrigger != nil {
					s.opts.OnTrigger(id, fmt.Sprintf("interval:%v", interval), TriggerKindInterval)
				}

			case <-stopCh:
				ticker.Stop()
				return

			case <-s.ctx.Done():
				ticker.Stop()
				return
			}
		}
	}()

	return id, nil
}

// Schedule 使用调度规格创建任务
func (s *Scheduler) Schedule(spec string, callback TaskCallback) (string, error) {