Method createContainers

dgraphtest/local_cluster.go:251–289

()

}

func (c *LocalCluster) createContainers() error {
	var wg sync.WaitGroup
	errChan := make(chan error, len(c.zeros)+len(c.alphas))

	for _, zo := range c.zeros {
		wg.Add(1)
		go func(z *zero) {
			defer wg.Done()
			cid, err := c.createContainer(z)
			if err != nil {
				errChan <- err
				return
			}
			z.containerID = cid
		}(zo)
	}

	for _, aa := range c.alphas {
		wg.Add(1)
		go func(a *alpha) {
			defer wg.Done()
			cid, err := c.createContainer(a)
			if err != nil {
				errChan <- err
				return
			}
			a.containerID = cid
		}(aa)
	}

	wg.Wait()
	close(errChan)

	for err := range errChan {
		return err
	}

	return nil
}

func (c *LocalCluster) createContainer(dc dnode) (string, error) {
	cmd := dc.cmd(c)