Add support for backup & recovery service

Author: Pearl1594

cloudstack/BackupService.go

@@ -86,6 +86,8 @@ type VolumeServiceIface interface {
 	GetVolumesUsageHistoryByID(id string, opts ...OptionFunc) (*VolumesUsageHistory, int, error)
 	AssignVolume(p *AssignVolumeParams) (*AssignVolumeResponse, error)
 	NewAssignVolumeParams(volumeid string) *AssignVolumeParams
+	RestoreVolumeFromBackupAndAttachToVM(p *RestoreVolumeFromBackupAndAttachToVMParams) (*RestoreVolumeFromBackupAndAttachToVMResponse, error)
+	NewRestoreVolumeFromBackupAndAttachToVMParams(backupid string, virtualmachineid string, volumeid string) *RestoreVolumeFromBackupAndAttachToVMParams
 }
 
 type AttachVolumeParams struct {
@@ -6534,3 +6536,135 @@ type AssignVolumeResponse struct {
 	Zoneid                     string            `json:"zoneid"`
 	Zonename                   string            `json:"zonename"`
 }
+
+type RestoreVolumeFromBackupAndAttachToVMParams struct {
+	p map[string]interface{}
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) toURLValues() url.Values {
+	u := url.Values{}
+	if p.p == nil {
+		return u
+	}
+	if v, found := p.p["backupid"]; found {
+		u.Set("backupid", v.(string))
+	}
+	if v, found := p.p["virtualmachineid"]; found {
+		u.Set("virtualmachineid", v.(string))
+	}
+	if v, found := p.p["volumeid"]; found {
+		u.Set("volumeid", v.(string))
+	}
+	return u
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) SetBackupid(v string) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	p.p["backupid"] = v
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) ResetBackupid() {
+	if p.p != nil && p.p["backupid"] != nil {
+		delete(p.p, "backupid")
+	}
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) GetBackupid() (string, bool) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	value, ok := p.p["backupid"].(string)
+	return value, ok
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) SetVirtualmachineid(v string) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	p.p["virtualmachineid"] = v
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) ResetVirtualmachineid() {
+	if p.p != nil && p.p["virtualmachineid"] != nil {
+		delete(p.p, "virtualmachineid")
+	}
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) GetVirtualmachineid() (string, bool) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	value, ok := p.p["virtualmachineid"].(string)
+	return value, ok
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) SetVolumeid(v string) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	p.p["volumeid"] = v
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) ResetVolumeid() {
+	if p.p != nil && p.p["volumeid"] != nil {
+		delete(p.p, "volumeid")
+	}
+}
+
+func (p *RestoreVolumeFromBackupAndAttachToVMParams) GetVolumeid() (string, bool) {
+	if p.p == nil {
+		p.p = make(map[string]interface{})
+	}
+	value, ok := p.p["volumeid"].(string)
+	return value, ok
+}
+
+// You should always use this function to get a new RestoreVolumeFromBackupAndAttachToVMParams instance,
+// as then you are sure you have configured all required params
+func (s *VolumeService) NewRestoreVolumeFromBackupAndAttachToVMParams(backupid string, virtualmachineid string, volumeid string) *RestoreVolumeFromBackupAndAttachToVMParams {
+	p := &RestoreVolumeFromBackupAndAttachToVMParams{}
+	p.p = make(map[string]interface{})
+	p.p["backupid"] = backupid
+	p.p["virtualmachineid"] = virtualmachineid
+	p.p["volumeid"] = volumeid
+	return p
+}
+
+// Restore and attach a backed up volume to VM
+func (s *VolumeService) RestoreVolumeFromBackupAndAttachToVM(p *RestoreVolumeFromBackupAndAttachToVMParams) (*RestoreVolumeFromBackupAndAttachToVMResponse, error) {
+	resp, err := s.cs.newPostRequest("restoreVolumeFromBackupAndAttachToVM", p.toURLValues())
+	if err != nil {
+		return nil, err
+	}
+
+	var r RestoreVolumeFromBackupAndAttachToVMResponse
+	if err := json.Unmarshal(resp, &r); err != nil {
+		return nil, err
+	}
+
+	// If we have a async client, we need to wait for the async result
+	if s.cs.async {
+		b, err := s.cs.GetAsyncJobResult(r.JobID, s.cs.timeout)
+		if err != nil {
+			if err == AsyncTimeoutErr {
+				return &r, err
+			}
+			return nil, err
+		}
+
+		if err := json.Unmarshal(b, &r); err != nil {
+			return nil, err
+		}
+	}
+
+	return &r, nil
+}
+
+type RestoreVolumeFromBackupAndAttachToVMResponse struct {
+	Displaytext string `json:"displaytext"`
+	JobID       string `json:"jobid"`
+	Jobstatus   int    `json:"jobstatus"`
+	Success     bool   `json:"success"`
+}

cloudstack/BackupService_mock.go

@@ -111,6 +111,7 @@ type CloudStackClient struct {
 	Authentication          AuthenticationServiceIface
 	AutoScale               AutoScaleServiceIface
 	BGPPeer                 BGPPeerServiceIface
+	Backup                  BackupServiceIface
 	Baremetal               BaremetalServiceIface
 	BigSwitchBCF            BigSwitchBCFServiceIface
 	BrocadeVCS              BrocadeVCSServiceIface
@@ -238,6 +239,7 @@ func newClient(apiurl string, apikey string, secret string, async bool, verifyss
 	cs.Authentication = NewAuthenticationService(cs)
 	cs.AutoScale = NewAutoScaleService(cs)
 	cs.BGPPeer = NewBGPPeerService(cs)
+	cs.Backup = NewBackupService(cs)
 	cs.Baremetal = NewBaremetalService(cs)
 	cs.BigSwitchBCF = NewBigSwitchBCFService(cs)
 	cs.BrocadeVCS = NewBrocadeVCSService(cs)
@@ -338,6 +340,7 @@ func newMockClient(ctrl *gomock.Controller) *CloudStackClient {
 	cs.Authentication = NewMockAuthenticationServiceIface(ctrl)
 	cs.AutoScale = NewMockAutoScaleServiceIface(ctrl)
 	cs.BGPPeer = NewMockBGPPeerServiceIface(ctrl)
+	cs.Backup = NewMockBackupServiceIface(ctrl)
 	cs.Baremetal = NewMockBaremetalServiceIface(ctrl)
 	cs.BigSwitchBCF = NewMockBigSwitchBCFServiceIface(ctrl)
 	cs.BrocadeVCS = NewMockBrocadeVCSServiceIface(ctrl)
@@ -900,6 +903,14 @@ func NewBGPPeerService(cs *CloudStackClient) BGPPeerServiceIface {
 	return &BGPPeerService{cs: cs}
 }
 
+type BackupService struct {
+	cs *CloudStackClient
+}
+
+func NewBackupService(cs *CloudStackClient) BackupServiceIface {
+	return &BackupService{cs: cs}
+}
+
 type BaremetalService struct {
 	cs *CloudStackClient
 }

cloudstack/VolumeService.go

@@ -272,6 +272,7 @@ var layout = apiInfo{
 		"uploadVolume",
 		"listVolumesUsageHistory",
 		"assignVolume",
+		"restoreVolumeFromBackupAndAttachToVM",
 	},
 	"VPCService": {
 		"createPrivateGateway",
@@ -728,6 +729,26 @@ var layout = apiInfo{
 		"resetConfiguration",
 		"updateStorageCapabilities",
 	},
+	"BackupService": {
+		"addBackupRepository",
+		"createBackup",
+		"createBackupSchedule",
+		"createVMFromBackup",
+		"deleteBackup",
+		"deleteBackupOffering",
+		"deleteBackupRepository",
+		"deleteBackupSchedule",
+		"importBackupOffering",
+		"listBackupOfferings",
+		"listBackupProviderOfferings",
+		"listBackupProviders",
+		"listBackupRepositories",
+		"listBackupSchedule",
+		"listBackups",
+		"restoreBackup",
+		"updateBackupOffering",
+		"updateBackupSchedule",
+	},
 	"BrocadeVCSService": {
 		"addBrocadeVcsDevice",
 		"deleteBrocadeVcsDevice",