if node.Name == failedNode {
			if len(node.Status.VolumesAttached) != 0 {
				t.Fatalf("len(node.Status.VolumesAttached) Expected: <0> Actual: <%v>", len(node.Status.VolumesAttached))
			}
		} else {
			if len(node.Status.VolumesAttached) != 1 {
				t.Fatalf("len(node.Status.VolumesAttached) Expected: <1> Actual: <%v>", len(node.Status.VolumesAttached))
			}
		}
	}
}

	Images          []ContainerImageApplyConfiguration     `json:"images,omitempty"`
	VolumesInUse    []v1.UniqueVolumeName                  `json:"volumesInUse,omitempty"`
	VolumesAttached []AttachedVolumeApplyConfiguration     `json:"volumesAttached,omitempty"`
	Config          *NodeConfigStatusApplyConfiguration    `json:"config,omitempty"`
	RuntimeHandlers []NodeRuntimeHandlerApplyConfiguration `json:"runtimeHandlers,omitempty"`
}

			stopCh := runVolumeManager(manager)
			defer close(stopCh)

			podManager.SetPods([]*v1.Pod{pod})

			// Fake node status update
			go simulateVolumeInUseUpdate(
				v1.UniqueVolumeName(node.Status.VolumesAttached[0].Name),
				stopCh,
				manager)

			err = manager.WaitForAttachAndMount(context.Background(), pod)
			if err != nil && !test.expectError {
				t.Errorf("Expected success: %v", err)
			}

	}

	if len(reconstructedVolumes) > 0 {
		// Add the volumes to ASW
		rc.updateStates(reconstructedVolumes)

		// Remember to update devicePath from node.status.volumesAttached
		rc.volumesNeedUpdateFromNodeStatus = reconstructedVolumeNames
	}
	klog.V(2).InfoS("Volume reconstruction finished")
}

	nodeutil "k8s.io/component-helpers/node/util"
	"k8s.io/klog/v2"
	"k8s.io/kubernetes/pkg/controller/volume/attachdetach/cache"
)

// NodeStatusUpdater defines a set of operations for updating the
// VolumesAttached field in the Node Status.
type NodeStatusUpdater interface {
	// Gets a list of node statuses that should be updated from the actual state
	// of the world and updates them.
	UpdateNodeStatuses(logger klog.Logger) error

    },
    "images": [
      {
        "names": [
          "namesValue"
        ],
        "sizeBytes": 2
      }
    ],
    "volumesInUse": [
      "volumesInUseValue"
    ],
    "volumesAttached": [
      {
        "name": "nameValue",
        "devicePath": "devicePathValue"
      }
    ],
    "config": {
      "assigned": {
        "configMap": {
          "namespace": "namespaceValue",

	// Arrange
	intreeToCSITranslator := csitrans.New()
	node := &v1.Node{
		ObjectMeta: metav1.ObjectMeta{
			Name: string(nodeName),
		},
		Spec: v1.NodeSpec{},
		Status: v1.NodeStatus{
			VolumesAttached: []v1.AttachedVolume{
				{
					Name:       v1.UniqueVolumeName(fmt.Sprintf("fake-plugin/%s", "pd.csi.storage.gke.io-fake-device1")),
					DevicePath: "fake/path",
				},
			},
		},
	}

    osImage: osImageValue
    systemUUID: systemUUIDValue
  phase: phaseValue
  runtimeHandlers:
  - features:
      recursiveReadOnlyMounts: true
    name: nameValue
  volumesAttached:
  - devicePath: devicePathValue
    name: nameValue
  volumesInUse:

    osImage: osImageValue
    systemUUID: systemUUIDValue
  phase: phaseValue
  runtimeHandlers:
  - features:
      recursiveReadOnlyMounts: true
    name: nameValue
  volumesAttached:
  - devicePath: devicePathValue
    name: nameValue
  volumesInUse:

    kubeletVersion: kubeletVersionValue
    machineID: machineIDValue
    operatingSystem: operatingSystemValue
    osImage: osImageValue
    systemUUID: systemUUIDValue
  phase: phaseValue
  volumesAttached:
  - devicePath: devicePathValue
    name: nameValue
  volumesInUse: