Function PullImages

pkg/dockerutil/docker_compose.go:358–407

PullImages pulls images in parallel if they don't exist locally If pullAlways is true, it will always pull Otherwise, it will only pull if the image doesn't exist

(images []string, pullAlways bool)

// If pullAlways is true, it will always pull
// Otherwise, it will only pull if the image doesn't exist
func PullImages(images []string, pullAlways bool) error {
	if len(images) == 0 {
		return nil
	}

	composeYamlPull, err := CreateComposeProject("name: compose-yaml-pull")
	if err != nil {
		return err
	}

	for _, image := range images {
		if image == "" {
			continue
		}
		if !pullAlways {
			if imageExists, _ := ImageExistsLocally(image); imageExists {
				continue
			}
		}
		service := sanitizeServiceName(image)
		if _, exists := composeYamlPull.Services[service]; exists {
			continue
		}
		composeYamlPull.Services[service] = types.ServiceConfig{
			Image: image,
		}
		util.Debug(`Pulling image for %s ("%s" service)`, image, service)
	}

	if len(composeYamlPull.Services) == 0 {
		util.Debug("All images already exist locally, no pull needed")
		return nil
	}

	if !output.JSONOutput && isatty.IsTerminal(os.Stdin.Fd()) {
		err = ComposeWithStreams(&ComposeCmdOpts{
			ComposeYaml: composeYamlPull,
			Action:      []string{"pull"},
			Env:         []string{"COMPOSE_DISABLE_ENV_FILE=1"},
		}, nil, os.Stdout, os.Stderr)
	} else {
		_, _, err = ComposeCmd(&ComposeCmdOpts{
			ComposeYaml: composeYamlPull,
			Action:      []string{"pull"},
			Env:         []string{"COMPOSE_DISABLE_ENV_FILE=1"},
		})
	}

	return err
}

// Pull pulls image if it doesn't exist locally
func Pull(image string) error {