Method mounts

dgraphtest/dgraph.go:320–359

(c *LocalCluster)

}

func (a *alpha) mounts(c *LocalCluster) ([]mount.Mount, error) {
	var mounts []mount.Mount
	binMount, err := mountBinary(c)
	if err != nil {
		return nil, err
	}
	mounts = append(mounts, binMount)

	if c.conf.acl || c.conf.encryption {
		mounts = append(mounts, mount.Mount{
			Type:     mount.TypeBind,
			Source:   c.tempSecretsDir,
			Target:   secretsMountPath,
			ReadOnly: true,
		})
	}

	if c.conf.bulkOutDirForMount != "" {
		pDir := filepath.Join(c.conf.bulkOutDirForMount, strconv.Itoa(a.id/c.conf.replicas), "p")
		if err := os.MkdirAll(pDir, os.ModePerm); err != nil {
			return nil, errors.Wrap(err, "erorr creating bulk dir")
		}
		mounts = append(mounts, mount.Mount{
			Type:     mount.TypeBind,
			Source:   pDir,
			Target:   DefaultAlphaPDir,
			ReadOnly: false,
		})
	}

	for dir, vol := range c.conf.volumes {
		mounts = append(mounts, mount.Mount{
			Type:     mount.TypeVolume,
			Source:   vol,
			Target:   dir,
			ReadOnly: false,
		})
	}
	return mounts, nil
}

func (a *alpha) healthURL(c *LocalCluster) (string, error) {
	publicPort, err := publicPort(c.dcli, a, alphaHttpPort)