kubernetes/pkg/kubelet/volumemanager/reconciler/reconciler.go

func (rc *reconciler) Run(stopCh <-chan struct{}

func (rc *reconciler) reconcile() {}