- valuesValue
        matchFields:
        - key: keyValue
          operator: operatorValue
          values:
          - valuesValue
    resourceHandles:
    - data: dataValue
      driverName: driverNameValue
      structuredData:
        nodeName: nodeNameValue
        results:
        - namedResources:
            name: nameValue
          vendorRequestParameters:
            apiVersion: example.com/v1

      "kind": "kindValue",
      "name": "nameValue"
    },
    "allocationMode": "allocationModeValue"
  },
  "status": {
    "driverName": "driverNameValue",
    "allocation": {
      "resourceHandles": [
        {
          "driverName": "driverNameValue",
          "data": "dataValue",
          "structuredData": {
            "vendorClassParameters": {
              "apiVersion": "example.com/v1",

}

func autoConvert_v1alpha2_DriverRequests_To_resource_DriverRequests(in *v1alpha2.DriverRequests, out *resource.DriverRequests, s conversion.Scope) error {
	out.DriverName = in.DriverName
	if err := runtime.Convert_runtime_RawExtension_To_runtime_Object(&in.VendorParameters, &out.VendorParameters, s); err != nil {
		return err
	}
	if in.Requests != nil {
		in, out := &in.Requests, &out.Requests

			klog.Error(log("attacher.VolumesAreAttached failed to get CSIPersistentVolumeSource: %v", err))
			continue
		}
		driverName := pvSrc.Driver
		volumeHandle := pvSrc.VolumeHandle

		skip, err := c.plugin.skipAttach(driverName)
		if err != nil {
			klog.Error(log("Failed to check CSIDriver for %s: %s", driverName, err))
		} else {
			if skip {
				// This volume is not attachable, pretend it's attached
				attached[spec] = true

	return nodeClient, conn, nil
}

func newCsiDriverClient(driverName csiDriverName) (*csiDriverClient, error) {
	if driverName == "" {
		return nil, fmt.Errorf("driver name is empty")
	}

	existingDriver, driverExists := csiDrivers.Get(string(driverName))
	if !driverExists {
		return nil, fmt.Errorf("driver name %s not found in the list of registered CSI drivers", driverName)
	}

	nodeV1ClientCreator := newV1NodeClient

			targetPath:    "/mnt/foo",
		},
	}

	for _, tc := range tests {
		metricsGetter := &metricsCsi{volumeID: tc.volumeID, targetPath: tc.targetPath}
		metricsGetter.csiClient = &csiDriverClient{
			driverName: "com.google.gcepd",
			nodeV1ClientCreator: func(addr csiAddr, m *MetricsManager) (csipbv1.NodeClient, io.Closer, error) {
				nodeClient := fake.NewNodeClientWithVolumeStats(true /* VolumeStatsCapable */)

}

type ResourceSliceWrapper struct {
	resourcev1alpha2.ResourceSlice
}

func MakeResourceSlice(nodeName, driverName string) *ResourceSliceWrapper {
	wrapper := new(ResourceSliceWrapper)
	wrapper.Name = nodeName + "-" + driverName
	wrapper.NodeName = nodeName
	wrapper.DriverName = driverName
	return wrapper
}

func (wrapper *ResourceSliceWrapper) Obj() *resourcev1alpha2.ResourceSlice {

apiVersion: storage.k8s.io/v1alpha1
driverName: driverNameValue
kind: VolumeAttributesClass
metadata:
  annotations:
    annotationsKey: annotationsValue
  creationTimestamp: "2008-01-01T01:01:01Z"
  deletionGracePeriodSeconds: 10
  deletionTimestamp: "2009-01-01T01:01:01Z"
  finalizers:
  - finalizersValue
  generateName: generateNameValue
  generation: 7
  labels:
    labelsKey: labelsValue
  managedFields:

apiVersion: storage.k8s.io/v1alpha1
driverName: driverNameValue
kind: VolumeAttributesClass
metadata:
  annotations:
    annotationsKey: annotationsValue
  creationTimestamp: "2008-01-01T01:01:01Z"
  deletionGracePeriodSeconds: 10
  deletionTimestamp: "2009-01-01T01:01:01Z"
  finalizers:
  - finalizersValue
  generateName: generateNameValue
  generation: 7
  labels:
    labelsKey: labelsValue
  managedFields:

        "apiVersion": "apiVersionValue",
        "time": "2004-01-01T01:01:01Z",
        "fieldsType": "fieldsTypeValue",
        "fieldsV1": {},
        "subresource": "subresourceValue"
      }
    ]
  },
  "driverName": "driverNameValue",
  "parameters": {
    "parametersKey": "parametersValue"
  }