Method createVolumes

internal/deploy/deployer.go:339–415

(ctx context.Context, project *composetypes.Project)

}

func (d *Deployer) createVolumes(ctx context.Context, project *composetypes.Project) error {
	// Project-filtered listing keeps the response small on hosts with many stacks.
	ownedList, err := d.cli.VolumeList(ctx, client.VolumeListOptions{
		Filters: make(client.Filters).Add("label", labelComposeProject+"="+project.Name),
	})
	if err != nil {
		return fmt.Errorf("listing volumes: %w", err)
	}
	ownedByName := make(map[string]struct{}, len(ownedList.Items))
	for _, v := range ownedList.Items {
		ownedByName[v.Name] = struct{}{}
	}

	// External volumes are looked up unfiltered, on demand (they are not project-labeled).
	var externalByName map[string]struct{}
	lookupExternal := func() error {
		if externalByName != nil {
			return nil
		}
		all, err := d.cli.VolumeList(ctx, client.VolumeListOptions{})
		if err != nil {
			return fmt.Errorf("listing external volumes: %w", err)
		}
		externalByName = make(map[string]struct{}, len(all.Items))
		for _, v := range all.Items {
			externalByName[v.Name] = struct{}{}
		}
		return nil
	}

	for name, volCfg := range project.Volumes {
		if bool(volCfg.External) {
			extName := volCfg.Name
			if extName == "" {
				extName = name
			}
			if err := lookupExternal(); err != nil {
				return err
			}
			if _, ok := externalByName[extName]; !ok {
				return fmt.Errorf("external volume %q not found", extName)
			}
			continue
		}

		fullName := volCfg.Name
		if fullName == "" {
			fullName = project.Name + "_" + name
		}

		if _, ok := ownedByName[fullName]; ok {
			log.Info().Str("volume", fullName).Msg("Volume already exists, skipping")
			continue
		}

		driver := volCfg.Driver
		if driver == "" {
			driver = "local"