Merge pull request #111 from dell/storagepool-volumes

Add GetStoragePoolVolumes api to get all volumes connected to given s…

instance.go

@@ -284,3 +284,18 @@ func (c *Client) GetSnapshotPolicy(
 	sps = append(sps, sp)
 	return sps, nil
 }
+
+// GetStoragePoolVolumes returns list of volumes connected to storage pool Storagepool by ID
+func (c *Client) GetStoragePoolVolumes(id string) ([]*types.Volume, error) {
+	defer TimeSpent("GetStoragePoolByID", time.Now())
+
+	path := fmt.Sprintf("/api/instances/StoragePool::%s/relationships/Volume", id)
+	var storagepoolVolumes []*types.Volume
+	err := c.getJSONWithRetry(
+		http.MethodGet, path, nil, &storagepoolVolumes)
+	if err != nil {
+		return nil, err
+	}
+
+	return storagepoolVolumes, err
+}

inttests/volume_test.go

@@ -779,3 +779,29 @@ func TestSetCompressionMethod(t *testing.T) {
 	err = deleteVolume(t, volID)
 	assert.Nil(t, err)
 }
+
+func TestGetStoragePoolVolumes(t *testing.T) {
+	name := fmt.Sprintf("%s-%s", testPrefix, "instanceCreated")
+
+	poolName := getStoragePoolName(t)
+	assert.NotNil(t, poolName)
+
+	pool := getStoragePool(t)
+	size := fmt.Sprintf("%d", defaultVolumeSize)
+
+	volParams := siotypes.VolumeParam{
+		VolumeSizeInKb: size,
+		VolumeType:     "ThinProvisioned",
+		Name:           name,
+	}
+
+	volResp, err := C.CreateVolume(&volParams, poolName, "")
+	assert.Nil(t, err)
+	assert.NotNil(t, volResp)
+
+	volumes, err := C.GetStoragePoolVolumes(pool.StoragePool.ID)
+	assert.Nil(t, err)
+	assert.NotNil(t, volumes)
+
+	deleteVolume(t, volResp.ID)
+}