energylink/pkg/services/alerting/scheduler.go

package alerting

import (
	"time"

	"github.com/grafana/grafana/pkg/log"
)

type SchedulerImpl struct {
	jobs map[int64]*AlertJob
}

func NewScheduler() Scheduler {
	return &SchedulerImpl{
		jobs: make(map[int64]*AlertJob, 0),
	}
}

func (s *SchedulerImpl) Update(rules []AlertRule) {
	log.Debug("Scheduler: Update()")

	jobs := make(map[int64]*AlertJob, 0)

	for i, rule := range rules {
		var job *AlertJob
		if s.jobs[rule.Id] != nil {
			job = s.jobs[rule.Id]
		} else {
			job = &AlertJob{
				Running:    false,
				RetryCount: 0,
			}
		}

		job.Rule = &rule
		job.Offset = int64(i)

		jobs[rule.Id] = job
	}

	log.Debug("Scheduler: Selected %d jobs", len(jobs))
	s.jobs = jobs
}

func (s *SchedulerImpl) Tick(tickTime time.Time, execQueue chan *AlertJob) {
	now := tickTime.Unix()

	log.Info("Alerting: Scheduler.Tick() %v", len(s.jobs))

	for _, job := range s.jobs {
		if now%job.Rule.Frequency == 0 && job.Running == false {
			log.Trace("Scheduler: Putting job on to exec queue: %s", job.Rule.Title)
			execQueue <- job
		}
	}
}