limitations under the License.
*/

package statusupdater

import (
	"fmt"
	"k8s.io/klog/v2"

	"k8s.io/apimachinery/pkg/types"
)

func NewFakeNodeStatusUpdater(returnError bool) NodeStatusUpdater {
	return &fakeNodeStatusUpdater{
		returnError: returnError,
	}
}

type fakeNodeStatusUpdater struct {
	returnError bool
}

		fakeKubeClient,
		volumePluginMgr,
		fakeRecorder,
		fakeHandler))
	informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc())
	nsu := statusupdater.NewFakeNodeStatusUpdater(false /* returnError */)
	nodeLister := informerFactory.Core().V1().Nodes().Lister()
	reconciler := NewReconciler(