Method createContainer

dgraphtest/local_cluster.go:291–344

(dc dnode)

}

func (c *LocalCluster) createContainer(dc dnode) (string, error) {
	cmd := dc.cmd(c)
	image := c.dgraphImage()
	mts, err := dc.mounts(c)
	if err != nil {
		return "", err
	}

	// Verify the network still exists before creating container
	ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)
	defer cancel()
	if c.net.id != "" {
		_, err := c.dcli.NetworkInspect(ctx, c.net.id, network.InspectOptions{})
		if err != nil {
			// Use mutex to prevent multiple goroutines from recreating network simultaneously
			c.netMutex.Lock()
			// Double-check after acquiring lock - another goroutine may have recreated it
			_, recheckErr := c.dcli.NetworkInspect(ctx, c.net.id, network.InspectOptions{})
			if recheckErr != nil {
				log.Printf("[WARNING] network %s (ID: %s) not found, recreating", c.net.name, c.net.id)
				if err := c.createNetwork(); err != nil {
					c.netMutex.Unlock()
					return "", errors.Wrap(err, "error recreating network")
				}
			}
			c.netMutex.Unlock()
		}
	}

	cconf := &container.Config{Cmd: cmd, Image: image, WorkingDir: dc.workingDir(), ExposedPorts: dc.ports()}
	// ApplyContainerUser is a public hook in dgraphtest/hooks.go; the
	// default is no-op. Downstream consumers that run dgraph as a
	// non-root user inside the test container override it to set
	// cconf.User to the host's uid:gid, so files the container writes
	// are readable on the host and bind-mounted host paths are readable
	// inside the container.
	ApplyContainerUser(cconf)
	hconf := &container.HostConfig{Mounts: mts, PublishAllPorts: true, PortBindings: dc.bindings(c.conf.portOffset)}
	networkConfig := &network.NetworkingConfig{
		EndpointsConfig: map[string]*network.EndpointSettings{
			c.net.name: {
				Aliases:   []string{dc.cname(), dc.aname()},
				NetworkID: c.net.id,
			},
		},
	}

	resp, err := c.dcli.ContainerCreate(ctx, cconf, hconf, networkConfig, nil, dc.cname())
	if err != nil {
		return "", errors.Wrapf(err, "error creating container %v", dc.cname())
	}

	return resp.ID, nil
}

func (c *LocalCluster) destroyContainers() error {
	ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)