Function ComposeCmd

pkg/dockerutil/docker_compose.go:90–196

ComposeCmd executes docker-compose commands via shell. returns stdout, stderr, error/nil

(cmd *ComposeCmdOpts)

// ComposeCmd executes docker-compose commands via shell.
// returns stdout, stderr, error/nil
func ComposeCmd(cmd *ComposeCmdOpts) (string, string, error) {
	var arg []string
	var stdout bytes.Buffer
	var stderr string

	_, err := DownloadDockerComposeIfNeeded()
	if err != nil {
		return "", "", err
	}

	if cmd.ProjectName != "" {
		arg = append(arg, "-p", cmd.ProjectName)
	}

	if cmd.ComposeYaml != nil {
		// Read from stdin
		arg = append(arg, "-f", "-")
	} else {
		for _, file := range cmd.ComposeFiles {
			arg = append(arg, "-f", file)
		}
	}

	for _, profile := range cmd.Profiles {
		arg = append(arg, "--profile", profile)
	}

	arg = append(arg, cmd.Action...)

	path, err := globalconfig.GetDockerComposePath()
	if err != nil {
		return "", "", err
	}

	ctx := context.Background()
	if cmd.Timeout > 0 {
		var cancel context.CancelFunc
		ctx, cancel = context.WithTimeout(ctx, cmd.Timeout)
		defer cancel()
	}
	proc := exec.CommandContext(ctx, path, arg...)
	proc.Stdout = &stdout
	if cmd.ComposeYaml != nil {
		yamlBytes, err := cmd.ComposeYaml.MarshalYAML()
		if err != nil {
			return "", "", err
		}
		yamlBytes = util.EscapeDollarSign(yamlBytes)
		proc.Stdin = strings.NewReader(string(yamlBytes))
	} else {
		proc.Stdin = os.Stdin
	}
	proc.Env = append(os.Environ(), cmd.Env...)

	stderrPipe, err := proc.StderrPipe()
	if err != nil {
		return "", "", fmt.Errorf("failed to proc.StderrPipe(): %v", err)
	}