code: func (a *aggregator) resetNotifyTimer(duration time.Duration) {
  	l.Debugln(a, "Resetting notifyTimer to", duration.String())
  	a.notifyTimerNeedsReset = false
  	a.notifyTimer.Reset(duration)
  }
docs: // resetNotifyTimer should only ever be called when notifyTimer has stopped
  // and notifyTimer.C been read from. Otherwise, call resetNotifyTimerIfNeeded.