code: func (keys *watchBrokerKeys) watchResync(resyncReg resync.Registration) {
  	for resyncStatus := range resyncReg.StatusChan() {
  		if resyncStatus.ResyncStatus() == resync.Started {
  			err := keys.resync()
  			if err != nil {
  				// We are not able to propagate it somewhere else.
  				logrus.DefaultLogger().Errorf("getting resync data failed: %v", err)
  				// TODO NICE-to-HAVE publish the err using the transport asynchronously
  			}
  		}
  		resyncStatus.Ack()
  	}
  }
docs: // resyncReg.StatusChan == Started => resync