Function uploadWithMap

agent/app/service/backup.go:466–507

(taskItem task.Task, accountMap map[string]backupClientHelper, src, dst, accountIDs string, downloadAccountID, retry uint)

}

func uploadWithMap(taskItem task.Task, accountMap map[string]backupClientHelper, src, dst, accountIDs string, downloadAccountID, retry uint) error {
	accounts := strings.Split(accountIDs, ",")
	for _, account := range accounts {
		if len(account) == 0 {
			continue
		}
		itemBackup, ok := accountMap[account]
		if !ok {
			continue
		}
		if itemBackup.hasBackup {
			continue
		}
		if !itemBackup.isOk {
			taskItem.LogFailed(i18n.GetMsgWithDetail("LoadBackupFailed", itemBackup.message))
			continue
		}
		name := itemBackup.name
		if itemBackup.name == "localhost" {
			name = i18n.GetMsgByKey("Localhost")
		}
		taskItem.LogStart(i18n.GetMsgWithMap("UploadFile", map[string]interface{}{
			"file":   path.Join(itemBackup.backupPath, dst),
			"backup": name,
		}))
		for i := 0; i < int(retry)+1; i++ {
			_, err := itemBackup.client.Upload(src, path.Join(itemBackup.backupPath, dst))
			taskItem.LogWithStatus(i18n.GetMsgByKey("Upload"), err)
			if err != nil {
				if account == fmt.Sprintf("%d", downloadAccountID) {
					return err
				}
			} else {
				break
			}
		}
		itemBackup.hasBackup = true
		accountMap[account] = itemBackup
	}
	os.RemoveAll(src)
	return nil
}

func newClient(account *model.BackupAccount, isEncrypt bool) (cloud_storage.CloudStorageClient, error) {
	varMap := make(map[string]interface{})