Method LiveLoad

dgraphtest/load.go:234–280

LiveLoad runs the live loader with provided options

(opts LiveOpts)

// LiveLoad runs the live loader with provided options
func (c *LocalCluster) LiveLoad(opts LiveOpts) error {
	log.Printf("[INFO] updating DQL schema from [%v]", strings.Join(opts.SchemaFiles, " "))
	if err := setDQLSchema(c, opts.SchemaFiles); err != nil {
		return err
	}
	log.Printf("[INFO] updating GraphQL schema from [%v]", strings.Join(opts.GqlSchemaFiles, " "))
	if err := setGraphQLSchema(c, opts.GqlSchemaFiles); err != nil {
		return err
	}

	var alphaURLs []string
	for i, aa := range c.alphas {
		url, err := aa.alphaURL(c)
		if err != nil {
			return errors.Wrapf(err, "error finding URL for alpha #%v", i)
		}
		alphaURLs = append(alphaURLs, url)
	}
	zeroURL, err := c.zeros[0].zeroURL(c)
	if err != nil {
		return errors.Wrap(err, "error finding URL of first zero")
	}

	args := []string{
		"live",
		"--files", strings.Join(opts.DataFiles, ","),
		"--alpha", strings.Join(alphaURLs, ","),
		"--zero", zeroURL,
	}
	if c.conf.acl {
		args = append(args, fmt.Sprintf("--creds=user=%s;password=%s;namespace=%d",
			dgraphapi.DefaultUser, dgraphapi.DefaultPassword, x.RootNamespace))
	}
	if c.conf.encryption {
		args = append(args, fmt.Sprintf("--encryption=key-file=%v", c.encKeyPath))
	}

	log.Printf("[INFO] running live loader with args: [%v]", strings.Join(args, " "))
	cmd := exec.Command(c.HostDgraphBinaryPath(), args...)
	if out, err := cmd.CombinedOutput(); err != nil {
		return errors.Wrapf(err, "error running live loader: %v", string(out))
	} else {
		log.Printf("[INFO] ==== output for live loader ====")
		log.Println(string(out))
	}
	return nil
}

// findGrootAndGuardians returns the UIDs of groot user and guardians group
func findGrootAndGuardians(c *LocalCluster) (string, string, error) {