Method snapshotLoop

cli/scheduler/replay.go:197–214

snapshotLoop runs periodic writeSnapshot while the scheduler is up.

()

// snapshotLoop runs periodic writeSnapshot while the scheduler is up.
func (s *Scheduler) snapshotLoop() {
	defer close(s.snapDone)
	if s.cfg.SnapshotInterval <= 0 {
		return
	}
	t := time.NewTicker(s.cfg.SnapshotInterval)
	defer t.Stop()
	for {
		select {
		case <-s.ctx.Done():
			return
		case <-t.C:
			if err := s.writeSnapshotNow(); err != nil {
				s.logger.Warn("scheduler: snapshot failed", zap.Error(err))
			}
		}
	}
}

// gcLoop reaps terminal jobs past TTL.
func (s *Scheduler) gcLoop() {