Add Bulk Attach, Delete & Detach Volume

clients/instance/ibm-pi-volume.go

@@ -286,3 +286,17 @@ func (f *IBMPIVolumeClient) BulkVolumeDelete(body *models.VolumesDelete) (*model
 	}
 	return partialResp.Payload, nil
 }
+
+// Bulk volutme attach
+func (f *IBMPIVolumeClient) BulkVolumeAttach(pvmInstanceID string, body *models.VolumesAttach) (*models.VolumesAttachmentResponse, error) {
+	params := p_cloud_volumes.NewPcloudV2PvminstancesVolumesPostParams().WithContext(f.ctx).WithTimeout(helpers.PICreateTimeOut).
+		WithCloudInstanceID(f.cloudInstanceID).WithPvmInstanceID(pvmInstanceID).WithBody(body)
+	resp, err := f.session.Power.PCloudVolumes.PcloudV2PvminstancesVolumesPost(params, f.session.AuthInfo(f.cloudInstanceID))
+	if err != nil {
+		return nil, ibmpisession.SDKFailWithAPIError(err, fmt.Errorf(errors.AttachVolumesOperationFailed, body.VolumeIDs, err))
+	}
+	if resp == nil || resp.Payload == nil {
+		return nil, fmt.Errorf("failed to Attach volumes %s to server %s", body.VolumeIDs, pvmInstanceID)
+	}
+	return resp.Payload, nil
+}

errors/errors.go

@@ -71,6 +71,7 @@ const DetachVolumeOperationFailed = "failed to perform the Detach volume Operati
 const GetVolumeRemoteCopyRelationshipsOperationFailed = "failed to Get remote copy relationships of a volume %s for the cloud instance %s with error %w"
 const GetVolumeFlashCopyMappingOperationFailed = "failed to Get flash copy mapping of a volume %s for the cloud instance %s with error %w"
 const DetachVolumesOperationFailed = "failed to perfome the Detach volumes Operation V2 for pvminstance %s in cloud instance %s with error %w"
+const AttachVolumesOperationFailed = "failed to perform the Attach volume Operation for volumes %s with error %w"
 
 // start of volume onboarding
 const GetVolumeOnboardingOperationFailed = "failed to perform the Get Volume Onboarding Operation for volume-onboarding ID:%s for the cloud instance %s with error %w"

examples/bulk-volume-detach/main.go

@@ -125,7 +125,6 @@ func main() {
 		ImageID:    &imageID,
 		NetworkIDs: []string{networkID},
 		ServerName: &serverName,
-		VolumeIDs:  []string{volumeID, volumeID2},
 		Memory:     &memory,
 		Processors: &processors,
 		ProcType:   &procType,
@@ -156,16 +155,27 @@ func main() {
 	}
 	log.Printf("***************[6]****************** %+v \n", *getRespVM)
 	waitForInstanceAvailable(insID, powerClientVM)
+
+	log.Print("Attaching Volumes\n")
+	attachBody := &models.VolumesAttach{
+		VolumeIDs: []string{volumeID, volumeID2},
+	}
+	attachVolsResp, err := powerClientVolume.BulkVolumeAttach(insID, attachBody)
+	if err != nil {
+		log.Fatal(err)
+	}
+	log.Printf("***************[7]****************** %+v\n", *attachVolsResp)
+	time.Sleep(2 * time.Minute)
+
 	log.Print("Detaching Volumes\n")
 	detachBody := &models.VolumesDetach{
 		VolumeIDs: []string{volumeID, volumeID2},
 	}
-
 	createRespOkDetach, err := powerClientVolume.BulkVolumeDetach(insID, detachBody)
 	if err != nil {
 		log.Fatal(err)
 	}
-	log.Printf("***************[7]****************** %+v\n", *createRespOkDetach)
+	log.Printf("***************[8]****************** %+v\n", *createRespOkDetach)
 	log.Print("Deleting VM\n")
 	err = powerClientVM.Delete(insID)
 	if err != nil {