code: func NewOperationGenerator(kubeClient clientset.Interface,
  	volumePluginMgr *volume.VolumePluginMgr,
  	recorder record.EventRecorder,
  	checkNodeCapabilitiesBeforeMount bool,
  	blkUtil volumepathhandler.BlockVolumePathHandler) OperationGenerator {
  
  	return &operationGenerator{
  		kubeClient:                       kubeClient,
  		volumePluginMgr:                  volumePluginMgr,
  		recorder:                         recorder,
  		checkNodeCapabilitiesBeforeMount: checkNodeCapabilitiesBeforeMount,
  		blkUtil:                          blkUtil,
  	}
  }
docs: // NewOperationGenerator is returns instance of operationGenerator