opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(region): add RequestResizeDiskOnHost to SESXiHostDriver

Browse Source
This commit is contained in:
rainzm
2020-11-17 14:48:29 +08:00
parent a1bc77a40e
commit 8c17cdd5e2
1 changed files with 32 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/hostdrivers/esxi.go
+32
View File
@@ -262,6 +262,38 @@ func (self *SESXiHostDriver) RequestPrepareSaveDiskOnHost(ctx context.Context, h
return err
}
func (self *SESXiHostDriver) RequestResizeDiskOnHost(ctx context.Context, host *models.SHost, storage *models.SStorage, disk *models.SDisk, sizeMb int64, task taskman.ITask) error {
guest := disk.GetGuest()
if guest == nil {
return fmt.Errorf("unable to find guest has disk %s", disk.GetId())
}
spec := struct {
HostInfo vcenter.SVCenterAccessInfo
VMId string
DiskId string
SizeMb int64
}{}
account := host.GetCloudaccount()
accessInfo, err := account.GetVCenterAccessInfo(host.ExternalId)
if err != nil {
return err
}
spec.HostInfo = accessInfo
spec.DiskId = disk.GetExternalId()
spec.VMId = guest.GetExternalId()
spec.SizeMb = sizeMb
body := jsonutils.NewDict()
body.Add(jsonutils.Marshal(spec), "disk")
url := fmt.Sprintf("/disks/agent/resize/%s", disk.Id)
header := task.GetTaskRequestHeader()
_, err = host.EsxiRequest(ctx, httputils.POST, url, header, body)
return err
}
func (self *SESXiHostDriver) RequestSaveUploadImageOnHost(ctx context.Context, host *models.SHost, disk *models.SDisk, imageId string, task taskman.ITask, data jsonutils.JSONObject) error {
imagePath, _ := data.GetString("backup")