code: func (p *processorListener) shouldResync(now time.Time) bool {
  	p.resyncLock.Lock()
  	defer p.resyncLock.Unlock()
  
  	if p.resyncPeriod == 0 {
  		return false
  	}
  
  	return now.After(p.nextResync) || now.Equal(p.nextResync)
  }
docs: // shouldResync deterimines if the listener needs a resync. If the listener's resyncPeriod is 0,
  // this always returns false.