Method createNetwork

dgraphtest/local_cluster.go:184–224

()

}

func (c *LocalCluster) createNetwork() error {
	c.net.name = c.conf.prefix + "-net"

	ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)
	defer cancel()

	// Check if network already exists
	existingNet, err := c.dcli.NetworkInspect(ctx, c.net.name, network.InspectOptions{})
	if err == nil {
		// Network exists, reuse it
		log.Printf("[INFO] reusing existing network %s (ID: %s)", c.net.name, existingNet.ID)
		c.net.id = existingNet.ID
		return nil
	}

	// Network doesn't exist, create it
	opts := network.CreateOptions{
		Driver: "bridge",
		IPAM:   &network.IPAM{Driver: "default"},
	}

	networkResp, err := c.dcli.NetworkCreate(ctx, c.net.name, opts)
	if err != nil {
		// If network already exists (race condition), try to inspect and reuse it
		if strings.Contains(err.Error(), "already exists") {
			log.Printf("[INFO] network %s already exists (race condition), inspecting", c.net.name)
			existingNet, inspectErr := c.dcli.NetworkInspect(ctx, c.net.name, network.InspectOptions{})
			if inspectErr == nil {
				log.Printf("[INFO] reusing existing network %s (ID: %s)", c.net.name, existingNet.ID)
				c.net.id = existingNet.ID
				return nil
			}
			// If inspect also fails, return original create error
			log.Printf("[WARNING] failed to inspect network after creation conflict: %v", inspectErr)
		}
		return errors.Wrap(err, "error creating network")
	}
	c.net.id = networkResp.ID

	return nil
}

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