Method Restore

dgraphapi/cluster.go:413–475

Restore performs restore on Dgraph cluster from the given path to backup

(c Cluster, backupPath string,
	backupId string, incrFrom, backupNum int)

// Restore performs restore on Dgraph cluster from the given path to backup
func (hc *HTTPClient) Restore(c Cluster, backupPath string,
	backupId string, incrFrom, backupNum int) error {
	repoDir, err := c.GetRepoDir()
	if err != nil {
		return errors.Wrapf(err, "error getting repo directory")
	}

	// incremental restore was introduced in commit 8b3712e93ed2435bea52d957f7b69976c6cfc55b
	incrRestoreSupported, err := IsHigherVersion(c.GetVersion(), "8b3712e93ed2435bea52d957f7b69976c6cfc55b", repoDir)
	if err != nil {
		return errors.Wrapf(err, "error checking incremental restore support")
	}
	if !incrRestoreSupported && incrFrom != 0 {
		return errors.New("incremental restore is not supported by the cluster")
	}

	encKey, err := c.GetEncKeyPath()
	if err != nil {
		return errors.Wrapf(err, "error getting encryption key path")
	}

	var varPart, queryPart string
	if incrRestoreSupported {
		varPart = "$incrFrom: Int, "
		queryPart = " incrementalFrom: $incrFrom,"
	}
	query := fmt.Sprintf(`mutation restore($location: String!, $backupId: String,
			%v$backupNum: Int, $encKey: String) {
		restore(input: {location: $location, backupId: $backupId,%v
				backupNum: $backupNum, encryptionKeyFile: $encKey}) {
			code
			message
		}
	}`, varPart, queryPart)
	vars := map[string]interface{}{"location": backupPath, "backupId": backupId,
		"backupNum": backupNum, "encKey": encKey}
	if incrRestoreSupported {
		vars["incrFrom"] = incrFrom
	}

	params := GraphQLParams{
		Query:     query,
		Variables: vars,
	}
	resp, err := hc.RunGraphqlQuery(params, true)
	if err != nil {
		return err
	}

	var restoreResp struct {
		Restore struct {
			Code    string
			Message string
		}
	}
	if err := json.Unmarshal(resp, &restoreResp); err != nil {
		return errors.Wrap(err, "error unmarshalling restore response")
	}