Method RestoreTenant

dgraphapi/cluster.go:478–520

RestoreTenant restore specific namespace

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

// RestoreTenant restore specific namespace
func (hc *HTTPClient) RestoreTenant(c Cluster, backupPath string, backupId string,
	incrFrom, backupNum int, fromNamespace uint64) error {

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

	query := `mutation restoreTenant( $location: String!, $backupId: String,
		$incrFrom: Int, $backupNum: Int, $encKey: String,$fromNamespace: Int! ) {
				restoreTenant(input: {restoreInput: { location: $location, backupId: $backupId, 
				incrementalFrom: $incrFrom, backupNum: $backupNum,
			encryptionKeyFile: $encKey },fromNamespace:$fromNamespace}) {
			code
			message
		}
	}`
	vars := map[string]interface{}{"location": backupPath, "backupId": backupId, "backupNum": backupNum,
		"encKey": encKey, "fromNamespace": fromNamespace, "incrFrom": incrFrom}

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

	var restoreResp struct {
		RestoreTenant struct {
			Code    string
			Message string
		}
	}
	if err := json.Unmarshal(resp, &restoreResp); err != nil {
		return errors.Wrap(err, "error unmarshalling restore response")
	}
	if restoreResp.RestoreTenant.Code != "Success" {
		return fmt.Errorf("restoreTenant failed, response: %+v", restoreResp.RestoreTenant)
	}
	return nil
}

// WaitForRestore waits for restore to complete on all alphas
func WaitForRestore(c Cluster) error {