func (udevWatcher *UdevWatcher) performPeriodicReconciliation(updateInterval time.Duration) {
	udevWatcher.updateIntervalTicker = time.NewTicker(updateInterval)
	for {
		select {
		case <-udevWatcher.updateIntervalTicker.C:
			if err := udevWatcher.reconcileOnce(); err != nil {
				log.Warnf("Udev watcher reconciliation failed: %v", err)
			}
		case <-udevWatcher.ctx.Done():
			udevWatcher.updateIntervalTicker.Stop()
			return
		}
	}
}
func (udevWatcher *UdevWatcher) performPeriodicReconciliation(updateInterval time.Duration) {
	udevWatcher.updateIntervalTicker = time.NewTicker(updateInterval)
	for {
		select {
		case <-udevWatcher.updateIntervalTicker.C:
			if err := udevWatcher.reconcileOnce(); err != nil {
				log.Warnf("Udev watcher reconciliation failed: %v", err)
			}
		case <-udevWatcher.ctx.Done():
			udevWatcher.updateIntervalTicker.Stop()
			return
		}
	}
}
func ( udevWatcher * UdevWatcher ) performPeriodicReconciliation ( updateInterval time . Duration ) { udevWatcher . updateIntervalTicker = time . NewTicker ( updateInterval ) for { select { case <- udevWatcher . updateIntervalTicker . C : if err := udevWatcher . reconcileOnce ( ) ; err != nil { log . Warnf ( " " , err ) } case <- udevWatcher . ctx . Done ( ) : udevWatcher . updateIntervalTicker . Stop ( ) return } } }
// performPeriodicReconciliation is used to periodically invoke the
// reconciliation process based on a ticker
performPeriodicReconciliation is used to periodically invoke the reconciliation process based on a ticker