Method EverySteps

pkg/core/scheduler.go:106–124

EverySteps 每 N 步执行一次

(every int, callback StepCallback)

// EverySteps 每 N 步执行一次
func (s *Scheduler) EverySteps(every int, callback StepCallback) (string, error) {
	if every <= 0 {
		return "", fmt.Errorf("every must be positive, got %d", every)
	}

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

	id := generateTaskID("step")
	task := &StepTask{
		ID:            id,
		Every:         every,
		Callback:      callback,
		LastTriggered: 0,
	}

	s.stepTasks[id] = task
	return id, nil
}

// OnStep 监听每一步
func (s *Scheduler) OnStep(callback StepCallback) func() {