Function runContainerCommandRaw

agent/app/service/container.go:1513–1554

(cli *client.Client, containerID string, command []string)

}

func runContainerCommandRaw(cli *client.Client, containerID string, command []string) ([]byte, error) {
	ctx := context.Background()
	resp, err := cli.ContainerExecCreate(ctx, containerID, container.ExecOptions{
		Cmd:          command,
		AttachStdout: true,
		AttachStderr: true,
	})
	if err != nil {
		return nil, err
	}
	hijack, err := cli.ContainerExecAttach(ctx, resp.ID, container.ExecAttachOptions{})
	if err != nil {
		return nil, err
	}
	defer hijack.Close()

	raw, err := io.ReadAll(hijack.Reader)
	if err != nil {
		return nil, err
	}
	var stdout bytes.Buffer
	var stderr bytes.Buffer
	if _, err := stdcopy.StdCopy(&stdout, &stderr, bytes.NewReader(raw)); err != nil {
		return nil, err
	}
	output := strings.TrimSpace(stdout.String())
	errorOutput := strings.TrimSpace(stderr.String())
	info, err := cli.ContainerExecInspect(ctx, resp.ID)
	if err != nil {
		return nil, err
	}
	if info.ExitCode != 0 {
		if len(errorOutput) != 0 {
			return nil, fmt.Errorf("%s", errorOutput)
		}
		if len(output) == 0 {
			return nil, fmt.Errorf("container command failed with exit code %d", info.ExitCode)
		}
		return nil, fmt.Errorf("%s", output)
	}
	return stdout.Bytes(), nil
}

func runContainerCommandStream(cli *client.Client, containerID string, command []string) (io.ReadCloser, error) {
	ctx := context.Background()