nodeTaintsPolicy: nodeTaintsPolicyValue
        topologyKey: topologyKeyValue
        whenUnsatisfiable: whenUnsatisfiableValue
      volumes:
      - awsElasticBlockStore:
          fsType: fsTypeValue
          partition: 3
          readOnly: true
          volumeID: volumeIDValue
        azureDisk:
          cachingMode: cachingModeValue
          diskName: diskNameValue
          diskURI: diskURIValue

        "gcePersistentDisk": {
          "pdName": "pdNameValue",
          "fsType": "fsTypeValue",
          "partition": 3,
          "readOnly": true
        },
        "awsElasticBlockStore": {
          "volumeID": "volumeIDValue",
          "fsType": "fsTypeValue",
          "partition": 3,
          "readOnly": true
        },
        "gitRepo": {
          "repository": "repositoryValue",

                  "fsType": "fsTypeValue",
                  "partition": 3,
                  "readOnly": true
                },
                "awsElasticBlockStore": {
                  "volumeID": "volumeIDValue",
                  "fsType": "fsTypeValue",
                  "partition": 3,
                  "readOnly": true
                },
                "gitRepo": {

              "pdName": "pdNameValue",
              "fsType": "fsTypeValue",
              "partition": 3,
              "readOnly": true
            },
            "awsElasticBlockStore": {
              "volumeID": "volumeIDValue",
              "fsType": "fsTypeValue",
              "partition": 3,
              "readOnly": true
            },
            "gitRepo": {
              "repository": "repositoryValue",

	}
	for _, ref := range refs {
		if strings.HasPrefix(ref, pluginMountDir) {
			volumeID, err := filepath.Rel(pluginMountDir, ref)
			if err != nil {
				klog.Errorf("Failed to get volume id from mount %s - %v", mountPath, err)
				return "", err
			}
			return volumeID, nil
		}
	}

	return path.Base(mountPath), nil
}

	}
}

func TestAWSDiskConflicts(t *testing.T) {
	volState := v1.Volume{
		VolumeSource: v1.VolumeSource{
			AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
				VolumeID: "foo",
			},
		},
	}
	volState2 := v1.Volume{
		VolumeSource: v1.VolumeSource{
			AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
				VolumeID: "bar",
			},
		},
	}

	"k8s.io/kubernetes/pkg/controller"
	controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing"
	"k8s.io/kubernetes/pkg/volume"
	"k8s.io/kubernetes/pkg/volume/csimigration"
	"k8s.io/kubernetes/pkg/volume/util"
	"k8s.io/kubernetes/pkg/volume/util/operationexecutor"
	volumetypes "k8s.io/kubernetes/pkg/volume/util/types"
	"k8s.io/kubernetes/test/utils/ktesting"
)

func TestSyncHandler(t *testing.T) {

			initialClaims:   newClaimArray("claim3-3", "uid3-3", "10Gi", "volume3-3", v1.ClaimPending, nil, volume.AnnBoundByController, volume.AnnBindCompleted),
			expectedClaims:  newClaimArray("claim3-3", "uid3-3", "10Gi", "volume3-3", v1.ClaimBound, nil, volume.AnnBoundByController, volume.AnnBindCompleted),

	// volume is a string that references an already created Quobyte volume by name.
	Volume string `json:"volume" protobuf:"bytes,2,opt,name=volume"`

	// readOnly here will force the Quobyte volume to be mounted with read-only permissions.
	// Defaults to false.
	// +optional
	ReadOnly bool `json:"readOnly,omitempty" protobuf:"varint,3,opt,name=readOnly"`

	// user to map volume access to
	// Defaults to serivceaccount user

// is per volume or global setting:
//
//	0 - Enable 8dot3 name creation on all volumes on the system
//	1 - Disable 8dot3 name creation on all volumes on the system
//	2 - Set 8dot3 name creation on a per volume basis
//	3 - Disable 8dot3 name creation on all volumes except the system volume
//
// If global flag is set to 2, then per-volume flag needs to be examined:
//