@@ -8,22 +8,6 @@ import "github.com/moby/moby/api/types/common"

 // TODO(thaJeztah): make this a distinct type.

 type ExecCreateResponse = common.IDResponse

-// ExecOptions is a small subset of the Config struct that holds the configuration

-// for the exec feature of docker.

-type ExecOptions struct {

-	User         string   // User that will run the command

-	Privileged   bool     // Is the container in privileged mode

-	Tty          bool     // Attach standard streams to a tty.

-	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

-	AttachStdin  bool     // Attach the standard input, makes possible user interaction

-	AttachStderr bool     // Attach the standard error

-	AttachStdout bool     // Attach the standard output

-	DetachKeys   string   // Escape keys for detach

-	Env          []string // Environment variables

-	WorkingDir   string   // Working directory

-	Cmd          []string // Execution commands and args

-}

-

 // ExecInspect holds information returned by exec inspect.

 //

 // It is used by the client to unmarshal a [ExecInspectResponse],

new file mode 100644

@@ -0,0 +1,17 @@

+package container

+

+// ExecCreateRequest is a small subset of the Config struct that holds the configuration

+// for the exec feature of docker.

+type ExecCreateRequest struct {

+	User         string   // User that will run the command

+	Privileged   bool     // Is the container in privileged mode

+	Tty          bool     // Attach standard streams to a tty.

+	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

+	AttachStdin  bool     // Attach the standard input, makes possible user interaction

+	AttachStderr bool     // Attach the standard error

+	AttachStdout bool     // Attach the standard output

+	DetachKeys   string   // Escape keys for detach

+	Env          []string // Environment variables

+	WorkingDir   string   // Working directory

+	Cmd          []string // Execution commands and args

+}

@@ -70,7 +70,7 @@ type ContainerAPIClient interface {

 	ContainerCreate(ctx context.Context, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, platform *ocispec.Platform, containerName string) (container.CreateResponse, error)

 	ContainerDiff(ctx context.Context, container string) ([]container.FilesystemChange, error)

 	ContainerExecAttach(ctx context.Context, execID string, options ExecAttachOptions) (HijackedResponse, error)

-	ContainerExecCreate(ctx context.Context, container string, options container.ExecOptions) (container.ExecCreateResponse, error)

+	ContainerExecCreate(ctx context.Context, container string, options ExecCreateOptions) (container.ExecCreateResponse, error)

 	ContainerExecInspect(ctx context.Context, execID string) (container.ExecInspect, error)

 	ContainerExecResize(ctx context.Context, execID string, options ContainerResizeOptions) error

 	ContainerExecStart(ctx context.Context, execID string, options ExecStartOptions) error

@@ -9,8 +9,24 @@ import (

 	"github.com/moby/moby/api/types/versions"

 )

+// ExecCreateOptions is a small subset of the Config struct that holds the configuration

+// for the exec feature of docker.

+type ExecCreateOptions struct {

+	User         string   // User that will run the command

+	Privileged   bool     // Is the container in privileged mode

+	Tty          bool     // Attach standard streams to a tty.

+	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

+	AttachStdin  bool     // Attach the standard input, makes possible user interaction

+	AttachStderr bool     // Attach the standard error

+	AttachStdout bool     // Attach the standard output

+	DetachKeys   string   // Escape keys for detach

+	Env          []string // Environment variables

+	WorkingDir   string   // Working directory

+	Cmd          []string // Execution commands and args

+}

+

 // ContainerExecCreate creates a new exec configuration to run an exec process.

-func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string, options container.ExecOptions) (container.ExecCreateResponse, error) {

+func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string, options ExecCreateOptions) (container.ExecCreateResponse, error) {

 	containerID, err := trimID("container", containerID)

 	if err != nil {

 		return container.ExecCreateResponse{}, err

@@ -32,7 +48,21 @@ func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string,

 		options.ConsoleSize = nil

 	}

-	resp, err := cli.post(ctx, "/containers/"+containerID+"/exec", nil, options, nil)

+	req := container.ExecCreateRequest{

+		User:         options.User,

+		Privileged:   options.Privileged,

+		Tty:          options.Tty,

+		ConsoleSize:  options.ConsoleSize,

+		AttachStdin:  options.AttachStdin,

+		AttachStderr: options.AttachStderr,

+		AttachStdout: options.AttachStdout,

+		DetachKeys:   options.DetachKeys,

+		Env:          options.Env,

+		WorkingDir:   options.WorkingDir,

+		Cmd:          options.Cmd,

+	}

+

+	resp, err := cli.post(ctx, "/containers/"+containerID+"/exec", nil, req, nil)

 	defer ensureReaderClosed(resp)

 	if err != nil {

 		return container.ExecCreateResponse{}, err

@@ -22,14 +22,14 @@ func TestContainerExecCreateError(t *testing.T) {

 	)

 	assert.NilError(t, err)

-	_, err = client.ContainerExecCreate(context.Background(), "container_id", container.ExecOptions{})

+	_, err = client.ContainerExecCreate(context.Background(), "container_id", ExecCreateOptions{})

 	assert.Check(t, is.ErrorType(err, cerrdefs.IsInternal))

-	_, err = client.ContainerExecCreate(context.Background(), "", container.ExecOptions{})

+	_, err = client.ContainerExecCreate(context.Background(), "", ExecCreateOptions{})

 	assert.Check(t, is.ErrorType(err, cerrdefs.IsInvalidArgument))

 	assert.Check(t, is.ErrorContains(err, "value is empty"))

-	_, err = client.ContainerExecCreate(context.Background(), "    ", container.ExecOptions{})

+	_, err = client.ContainerExecCreate(context.Background(), "    ", ExecCreateOptions{})

 	assert.Check(t, is.ErrorType(err, cerrdefs.IsInvalidArgument))

 	assert.Check(t, is.ErrorContains(err, "value is empty"))

 }

@@ -42,7 +42,7 @@ func TestContainerExecCreateConnectionError(t *testing.T) {

 	client, err := NewClientWithOpts(WithAPIVersionNegotiation(), WithHost("tcp://no-such-host.invalid"))

 	assert.NilError(t, err)

-	_, err = client.ContainerExecCreate(context.Background(), "container_id", container.ExecOptions{})

+	_, err = client.ContainerExecCreate(context.Background(), "container_id", ExecCreateOptions{})

 	assert.Check(t, is.ErrorType(err, IsErrConnectionFailed))

 }

@@ -60,7 +60,7 @@ func TestContainerExecCreate(t *testing.T) {

 			if err := req.ParseForm(); err != nil {

 				return nil, err

 			}

-			execConfig := &container.ExecOptions{}

+			execConfig := &container.ExecCreateRequest{}

 			if err := json.NewDecoder(req.Body).Decode(execConfig); err != nil {

 				return nil, err

 			}

@@ -81,7 +81,7 @@ func TestContainerExecCreate(t *testing.T) {

 	)

 	assert.NilError(t, err)

-	r, err := client.ContainerExecCreate(context.Background(), "container_id", container.ExecOptions{

+	r, err := client.ContainerExecCreate(context.Background(), "container_id", ExecCreateOptions{

 		User: "user",

 	})

 	assert.NilError(t, err)

@@ -93,7 +93,7 @@ func (daemon *Daemon) getActiveContainer(name string) (*container.Container, err

 }

 // ContainerExecCreate sets up an exec in a running container.

-func (daemon *Daemon) ContainerExecCreate(name string, options *containertypes.ExecOptions) (string, error) {

+func (daemon *Daemon) ContainerExecCreate(name string, options *containertypes.ExecCreateRequest) (string, error) {

 	cntr, err := daemon.getActiveContainer(name)

 	if err != nil {

 		return "", err

@@ -14,7 +14,7 @@ import (

 // execBackend includes functions to implement to provide exec functionality.

 type execBackend interface {

-	ContainerExecCreate(name string, options *container.ExecOptions) (string, error)

+	ContainerExecCreate(name string, options *container.ExecCreateRequest) (string, error)

 	ContainerExecInspect(id string) (*backend.ExecInspect, error)

 	ContainerExecResize(ctx context.Context, name string, height, width uint32) error

 	ContainerExecStart(ctx context.Context, name string, options backend.ExecStartConfig) error

@@ -39,7 +39,7 @@ func (c *containerRouter) postContainerExecCreate(ctx context.Context, w http.Re

 		return err

 	}

-	execConfig := &container.ExecOptions{}

+	execConfig := &container.ExecCreateRequest{}

 	if err := httputils.ReadJSON(r, execConfig); err != nil {

 		return err

 	}

@@ -12,7 +12,6 @@ import (

 	"testing"

 	"time"

-	"github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/client"

 	"github.com/moby/moby/v2/integration-cli/checker"

 	"github.com/moby/moby/v2/integration-cli/cli"

@@ -65,7 +64,7 @@ func (s *DockerAPISuite) TestExecAPICreateContainerPaused(c *testing.T) {

 	assert.NilError(c, err)

 	defer apiClient.Close()

-	_, err = apiClient.ContainerExecCreate(testutil.GetContext(c), name, container.ExecOptions{

+	_, err = apiClient.ContainerExecCreate(testutil.GetContext(c), name, client.ExecCreateOptions{

 		Cmd: []string{"true"},

 	})

 	assert.ErrorContains(c, err, "Container "+name+" is paused, unpause the container before exec", "Expected message when creating exec command with Container %s is paused", name)

@@ -129,7 +128,7 @@ func (s *DockerAPISuite) TestExecAPIStartWithDetach(c *testing.T) {

 	assert.NilError(c, err)

 	defer apiClient.Close()

-	createResp, err := apiClient.ContainerExecCreate(ctx, name, container.ExecOptions{

+	createResp, err := apiClient.ContainerExecCreate(ctx, name, client.ExecCreateOptions{

 		Cmd:          []string{"true"},

 		AttachStderr: true,

 	})

@@ -10,7 +10,6 @@ import (

 	cerrdefs "github.com/containerd/errdefs"

 	"github.com/moby/moby/api/pkg/stdcopy"

-	"github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/api/types/filters"

 	swarmtypes "github.com/moby/moby/api/types/swarm"

 	"github.com/moby/moby/client"

@@ -312,7 +311,7 @@ func TestTemplatedConfig(t *testing.T) {

 	tasks := swarm.GetRunningTasks(ctx, t, c, serviceID)

 	assert.Assert(t, len(tasks) > 0, "no running tasks found for service %s", serviceID)

-	resp := swarm.ExecTask(ctx, t, d, tasks[0], container.ExecOptions{

+	resp := swarm.ExecTask(ctx, t, d, tasks[0], client.ExecCreateOptions{

 		Cmd:          []string{"/bin/cat", "/templated_config"},

 		AttachStdout: true,

 		AttachStderr: true,

@@ -327,7 +326,7 @@ func TestTemplatedConfig(t *testing.T) {

 	outBuf.Reset()

 	errBuf.Reset()

-	resp = swarm.ExecTask(ctx, t, d, tasks[0], container.ExecOptions{

+	resp = swarm.ExecTask(ctx, t, d, tasks[0], client.ExecCreateOptions{

 		Cmd:          []string{"mount"},

 		AttachStdout: true,

 		AttachStderr: true,

@@ -4,8 +4,8 @@ import (

 	"strings"

 	"testing"

-	containertypes "github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/api/types/versions"

+	"github.com/moby/moby/client"

 	"github.com/moby/moby/v2/integration/internal/container"

 	"gotest.tools/v3/assert"

 	"gotest.tools/v3/skip"

@@ -21,7 +21,7 @@ func TestExecConsoleSize(t *testing.T) {

 	cID := container.Run(ctx, t, apiClient, container.WithImage("busybox"))

 	result, err := container.Exec(ctx, apiClient, cID, []string{"stty", "size"},

-		func(ec *containertypes.ExecOptions) {

+		func(ec *client.ExecCreateOptions) {

 			ec.Tty = true

 			ec.ConsoleSize = &[2]uint{57, 123}

 		},

@@ -12,7 +12,6 @@ import (

 	cerrdefs "github.com/containerd/errdefs"

 	"github.com/moby/moby/api/types/common"

-	containertypes "github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/client"

 	"github.com/moby/moby/v2/integration/internal/build"

 	"github.com/moby/moby/v2/integration/internal/container"

@@ -34,7 +33,7 @@ func TestExecWithCloseStdin(t *testing.T) {

 	cID := container.Run(ctx, t, apiClient)

 	const expected = "closeIO"

-	execResp, err := apiClient.ContainerExecCreate(ctx, cID, containertypes.ExecOptions{

+	execResp, err := apiClient.ContainerExecCreate(ctx, cID, client.ExecCreateOptions{

 		AttachStdin:  true,

 		AttachStdout: true,

 		Cmd:          []string{"sh", "-c", "cat && echo " + expected},

@@ -89,7 +88,7 @@ func TestExec(t *testing.T) {

 	cID := container.Run(ctx, t, apiClient, container.WithTty(true), container.WithWorkingDir("/root"))

-	id, err := apiClient.ContainerExecCreate(ctx, cID, containertypes.ExecOptions{

+	id, err := apiClient.ContainerExecCreate(ctx, cID, client.ExecCreateOptions{

 		WorkingDir:   "/tmp",

 		Env:          []string{"FOO=BAR"},

 		AttachStdout: true,

@@ -127,7 +126,7 @@ func TestExecResize(t *testing.T) {

 	if runtime.GOOS == "windows" {

 		cmd = []string{"sleep", "240"}

 	}

-	resp, err := apiClient.ContainerExecCreate(ctx, cID, containertypes.ExecOptions{

+	resp, err := apiClient.ContainerExecCreate(ctx, cID, client.ExecCreateOptions{

 		Tty: true, // Windows requires a TTY for the resize to work, otherwise fails with "is not a tty: failed precondition", see https://github.com/moby/moby/pull/48665#issuecomment-2412530345

 		Cmd: cmd,

 	})

@@ -296,8 +295,8 @@ func TestExecUser(t *testing.T) {

 	withoutEtcGroups := container.WithImage(build.Do(ctx, t, apiClient, fakecontext.New(t, "", fakecontext.WithDockerfile("FROM busybox\nRUN rm /etc/group"))))

 	withoutEtcPasswd := container.WithImage(build.Do(ctx, t, apiClient, fakecontext.New(t, "", fakecontext.WithDockerfile("FROM busybox\nRUN rm /etc/passwd"))))

-	withUser := func(user string) func(options *containertypes.ExecOptions) {

-		return func(options *containertypes.ExecOptions) { options.User = user }

+	withUser := func(user string) func(options *client.ExecCreateOptions) {

+		return func(options *client.ExecCreateOptions) { options.User = user }

 	}

 	tests := []struct {

@@ -5,7 +5,6 @@ import (

 	"context"

 	"testing"

-	"github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/client"

 )

@@ -47,9 +46,9 @@ func (res ExecResult) AssertSuccess(t testing.TB) {

 // containing stdout, stderr, and exit code. Note:

 //   - this is a synchronous operation;

 //   - cmd stdin is closed.

-func Exec(ctx context.Context, apiClient client.APIClient, id string, cmd []string, ops ...func(*container.ExecOptions)) (ExecResult, error) {

+func Exec(ctx context.Context, apiClient client.APIClient, id string, cmd []string, ops ...func(*client.ExecCreateOptions)) (ExecResult, error) {

 	// prepare exec

-	execOptions := container.ExecOptions{

+	execOptions := client.ExecCreateOptions{

 		AttachStdout: true,

 		AttachStderr: true,

 		Cmd:          cmd,

@@ -87,7 +86,7 @@ func Exec(ctx context.Context, apiClient client.APIClient, id string, cmd []stri

 }

 // ExecT calls Exec() and aborts the test if an error occurs.

-func ExecT(ctx context.Context, t testing.TB, apiClient client.APIClient, id string, cmd []string, ops ...func(*container.ExecOptions)) ExecResult {

+func ExecT(ctx context.Context, t testing.TB, apiClient client.APIClient, id string, cmd []string, ops ...func(*client.ExecCreateOptions)) ExecResult {

 	t.Helper()

 	res, err := Exec(ctx, apiClient, id, cmd, ops...)

 	if err != nil {

@@ -6,7 +6,6 @@ import (

 	"testing"

 	"time"

-	"github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/api/types/filters"

 	swarmtypes "github.com/moby/moby/api/types/swarm"

 	"github.com/moby/moby/client"

@@ -211,7 +210,7 @@ func GetRunningTasks(ctx context.Context, t *testing.T, c client.ServiceAPIClien

 }

 // ExecTask runs the passed in exec config on the given task

-func ExecTask(ctx context.Context, t *testing.T, d *daemon.Daemon, task swarmtypes.Task, options container.ExecOptions) client.HijackedResponse {

+func ExecTask(ctx context.Context, t *testing.T, d *daemon.Daemon, task swarmtypes.Task, options client.ExecCreateOptions) client.HijackedResponse {

 	t.Helper()

 	apiClient := d.NewClientT(t)

 	defer apiClient.Close()

@@ -10,7 +10,6 @@ import (

 	cerrdefs "github.com/containerd/errdefs"

 	"github.com/moby/moby/api/pkg/stdcopy"

-	"github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/api/types/filters"

 	swarmtypes "github.com/moby/moby/api/types/swarm"

 	"github.com/moby/moby/client"

@@ -313,7 +312,7 @@ func TestTemplatedSecret(t *testing.T) {

 	tasks := swarm.GetRunningTasks(ctx, t, c, serviceID)

 	assert.Assert(t, len(tasks) > 0, "no running tasks found for service %s", serviceID)

-	resp := swarm.ExecTask(ctx, t, d, tasks[0], container.ExecOptions{

+	resp := swarm.ExecTask(ctx, t, d, tasks[0], client.ExecCreateOptions{

 		Cmd:          []string{"/bin/cat", "/run/secrets/templated_secret"},

 		AttachStdout: true,

 		AttachStderr: true,

@@ -328,7 +327,7 @@ func TestTemplatedSecret(t *testing.T) {

 	outBuf.Reset()

 	errBuf.Reset()

-	resp = swarm.ExecTask(ctx, t, d, tasks[0], container.ExecOptions{

+	resp = swarm.ExecTask(ctx, t, d, tasks[0], client.ExecCreateOptions{

 		Cmd:          []string{"mount"},

 		AttachStdout: true,

 		AttachStderr: true,

@@ -8,7 +8,6 @@ import (

 	"testing"

 	"time"

-	containertypes "github.com/moby/moby/api/types/container"

 	"github.com/moby/moby/api/types/events"

 	"github.com/moby/moby/api/types/filters"

 	"github.com/moby/moby/api/types/mount"

@@ -28,7 +27,7 @@ func TestEventsExecDie(t *testing.T) {

 	cID := container.Run(ctx, t, apiClient)

-	id, err := apiClient.ContainerExecCreate(ctx, cID, containertypes.ExecOptions{

+	id, err := apiClient.ContainerExecCreate(ctx, cID, client.ExecCreateOptions{

 		Cmd: []string{"echo", "hello"},

 	})

 	assert.NilError(t, err)

@@ -8,22 +8,6 @@ import "github.com/moby/moby/api/types/common"

 // TODO(thaJeztah): make this a distinct type.

 type ExecCreateResponse = common.IDResponse

-// ExecOptions is a small subset of the Config struct that holds the configuration

-// for the exec feature of docker.

-type ExecOptions struct {

-	User         string   // User that will run the command

-	Privileged   bool     // Is the container in privileged mode

-	Tty          bool     // Attach standard streams to a tty.

-	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

-	AttachStdin  bool     // Attach the standard input, makes possible user interaction

-	AttachStderr bool     // Attach the standard error

-	AttachStdout bool     // Attach the standard output

-	DetachKeys   string   // Escape keys for detach

-	Env          []string // Environment variables

-	WorkingDir   string   // Working directory

-	Cmd          []string // Execution commands and args

-}

-

 // ExecInspect holds information returned by exec inspect.

 //

 // It is used by the client to unmarshal a [ExecInspectResponse],

new file mode 100644

@@ -0,0 +1,17 @@

+package container

+

+// ExecCreateRequest is a small subset of the Config struct that holds the configuration

+// for the exec feature of docker.

+type ExecCreateRequest struct {

+	User         string   // User that will run the command

+	Privileged   bool     // Is the container in privileged mode

+	Tty          bool     // Attach standard streams to a tty.

+	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

+	AttachStdin  bool     // Attach the standard input, makes possible user interaction

+	AttachStderr bool     // Attach the standard error

+	AttachStdout bool     // Attach the standard output

+	DetachKeys   string   // Escape keys for detach

+	Env          []string // Environment variables

+	WorkingDir   string   // Working directory

+	Cmd          []string // Execution commands and args

+}

@@ -70,7 +70,7 @@ type ContainerAPIClient interface {

 	ContainerCreate(ctx context.Context, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, platform *ocispec.Platform, containerName string) (container.CreateResponse, error)

 	ContainerDiff(ctx context.Context, container string) ([]container.FilesystemChange, error)

 	ContainerExecAttach(ctx context.Context, execID string, options ExecAttachOptions) (HijackedResponse, error)

-	ContainerExecCreate(ctx context.Context, container string, options container.ExecOptions) (container.ExecCreateResponse, error)

+	ContainerExecCreate(ctx context.Context, container string, options ExecCreateOptions) (container.ExecCreateResponse, error)

 	ContainerExecInspect(ctx context.Context, execID string) (container.ExecInspect, error)

 	ContainerExecResize(ctx context.Context, execID string, options ContainerResizeOptions) error

 	ContainerExecStart(ctx context.Context, execID string, options ExecStartOptions) error

@@ -9,8 +9,24 @@ import (

 	"github.com/moby/moby/api/types/versions"

 )

+// ExecCreateOptions is a small subset of the Config struct that holds the configuration

+// for the exec feature of docker.

+type ExecCreateOptions struct {

+	User         string   // User that will run the command

+	Privileged   bool     // Is the container in privileged mode

+	Tty          bool     // Attach standard streams to a tty.

+	ConsoleSize  *[2]uint `json:",omitempty"` // Initial console size [height, width]

+	AttachStdin  bool     // Attach the standard input, makes possible user interaction

+	AttachStderr bool     // Attach the standard error

+	AttachStdout bool     // Attach the standard output

+	DetachKeys   string   // Escape keys for detach

+	Env          []string // Environment variables

+	WorkingDir   string   // Working directory

+	Cmd          []string // Execution commands and args

+}

+

 // ContainerExecCreate creates a new exec configuration to run an exec process.

-func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string, options container.ExecOptions) (container.ExecCreateResponse, error) {

+func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string, options ExecCreateOptions) (container.ExecCreateResponse, error) {

 	containerID, err := trimID("container", containerID)

 	if err != nil {

 		return container.ExecCreateResponse{}, err

@@ -32,7 +48,21 @@ func (cli *Client) ContainerExecCreate(ctx context.Context, containerID string,

 		options.ConsoleSize = nil

 	}

-	resp, err := cli.post(ctx, "/containers/"+containerID+"/exec", nil, options, nil)

+	req := container.ExecCreateRequest{

+		User:         options.User,

+		Privileged:   options.Privileged,

+		Tty:          options.Tty,

+		ConsoleSize:  options.ConsoleSize,

+		AttachStdin:  options.AttachStdin,

+		AttachStderr: options.AttachStderr,

+		AttachStdout: options.AttachStdout,

+		DetachKeys:   options.DetachKeys,

+		Env:          options.Env,

+		WorkingDir:   options.WorkingDir,

+		Cmd:          options.Cmd,

+	}

+

+	resp, err := cli.post(ctx, "/containers/"+containerID+"/exec", nil, req, nil)

 	defer ensureReaderClosed(resp)

 	if err != nil {

 		return container.ExecCreateResponse{}, err