@@ -79,7 +79,7 @@ func TestBuildSquashParent(t *testing.T) {

 	resp.Body.Close()

 	assert.NilError(t, err)

-	cid := container.Run(t, ctx, client,

+	cid := container.Run(ctx, t, client,

 		container.WithImage(name),

 		container.WithCmd("/bin/sh", "-c", "cat /hello"),

 	)

@@ -94,11 +94,11 @@ func TestBuildSquashParent(t *testing.T) {

 	assert.NilError(t, err)

 	assert.Check(t, is.Equal(strings.TrimSpace(actualStdout.String()), "hello\nworld"))

-	container.Run(t, ctx, client,

+	container.Run(ctx, t, client,

 		container.WithImage(name),

 		container.WithCmd("/bin/sh", "-c", "[ ! -f /remove_me ]"),

 	)

-	container.Run(t, ctx, client,

+	container.Run(ctx, t, client,

 		container.WithImage(name),

 		container.WithCmd("/bin/sh", "-c", `[ "$(echo $HELLO)" == "world" ]`),

 	)

@@ -50,7 +50,7 @@ func TestCheckpoint(t *testing.T) {

 	}

 	t.Log("Start a container")

-	cID := container.Run(t, ctx, client, container.WithMount(mnt))

+	cID := container.Run(ctx, t, client, container.WithMount(mnt))

 	poll.WaitOn(t,

 		container.IsInState(ctx, client, cID, "running"),

 		poll.WithDelay(100*time.Millisecond),

@@ -26,7 +26,7 @@ func TestCopyFromContainerPathDoesNotExist(t *testing.T) {

 	ctx := context.Background()

 	apiclient := testEnv.APIClient()

-	cid := container.Create(t, ctx, apiclient)

+	cid := container.Create(ctx, t, apiclient)

 	_, _, err := apiclient.CopyFromContainer(ctx, cid, "/dne")

 	assert.Check(t, client.IsErrNotFound(err))

@@ -40,7 +40,7 @@ func TestCopyFromContainerPathIsNotDir(t *testing.T) {

 	ctx := context.Background()

 	apiclient := testEnv.APIClient()

-	cid := container.Create(t, ctx, apiclient)

+	cid := container.Create(ctx, t, apiclient)

 	_, _, err := apiclient.CopyFromContainer(ctx, cid, "/etc/passwd/")

 	assert.Assert(t, is.ErrorContains(err, "not a directory"))

@@ -52,7 +52,7 @@ func TestCopyToContainerPathDoesNotExist(t *testing.T) {

 	ctx := context.Background()

 	apiclient := testEnv.APIClient()

-	cid := container.Create(t, ctx, apiclient)

+	cid := container.Create(ctx, t, apiclient)

 	err := apiclient.CopyToContainer(ctx, cid, "/dne", nil, types.CopyToContainerOptions{})

 	assert.Check(t, client.IsErrNotFound(err))

@@ -66,7 +66,7 @@ func TestCopyToContainerPathIsNotDir(t *testing.T) {

 	ctx := context.Background()

 	apiclient := testEnv.APIClient()

-	cid := container.Create(t, ctx, apiclient)

+	cid := container.Create(ctx, t, apiclient)

 	err := apiclient.CopyToContainer(ctx, cid, "/etc/passwd/", nil, types.CopyToContainerOptions{})

 	assert.Assert(t, is.ErrorContains(err, "not a directory"))

@@ -105,7 +105,7 @@ func TestCopyFromContainer(t *testing.T) {

 	assert.NilError(t, err)

 	assert.Assert(t, imageID != "")

-	cid := container.Create(t, ctx, apiClient, container.WithImage(imageID))

+	cid := container.Create(ctx, t, apiClient, container.WithImage(imageID))

 	for _, x := range []struct {

 		src    string

@@ -40,7 +40,7 @@ func TestContainerStartOnDaemonRestart(t *testing.T) {

 	ctx := context.Background()

-	cID := container.Create(t, ctx, c)

+	cID := container.Create(ctx, t, c)

 	defer c.ContainerRemove(ctx, cID, types.ContainerRemoveOptions{Force: true})

 	err := c.ContainerStart(ctx, cID, types.ContainerStartOptions{})

@@ -94,7 +94,7 @@ func TestDaemonRestartIpcMode(t *testing.T) {

 	ctx := context.Background()

 	// check the container is created with private ipc mode as per daemon default

-	cID := container.Run(t, ctx, c,

+	cID := container.Run(ctx, t, c,

 		container.WithCmd("top"),

 		container.WithRestartPolicy("always"),

 	)

@@ -113,7 +113,7 @@ func TestDaemonRestartIpcMode(t *testing.T) {

 	assert.Check(t, is.Equal(string(inspect.HostConfig.IpcMode), "private"))

 	// check a new container is created with shareable ipc mode as per new daemon default

-	cID = container.Run(t, ctx, c)

+	cID = container.Run(ctx, t, c)

 	defer c.ContainerRemove(ctx, cID, types.ContainerRemoveOptions{Force: true})

 	inspect, err = c.ContainerInspect(ctx, cID)

@@ -19,7 +19,7 @@ func TestDiff(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", `mkdir /foo; echo xyzzy > /foo/bar`))

+	cID := container.Run(ctx, t, client, container.WithCmd("sh", "-c", `mkdir /foo; echo xyzzy > /foo/bar`))

 	// Wait for it to exit as cannot diff a running container on Windows, and

 	// it will take a few seconds to exit. Also there's no way in Windows to

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

 	client := testEnv.APIClient()

 	// run top with detached mode

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	expected := "closeIO"

 	execResp, err := client.ContainerExecCreate(ctx, cID,

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

 	ctx := context.Background()

 	client := testEnv.APIClient()

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

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

 	id, err := client.ContainerExecCreate(ctx, cID,

 		types.ExecConfig{

@@ -125,7 +125,7 @@ func TestExecUser(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client, container.WithTty(true), container.WithUser("1:1"))

+	cID := container.Run(ctx, t, client, container.WithTty(true), container.WithUser("1:1"))

 	result, err := container.Exec(ctx, client, cID, []string{"id"})

 	assert.NilError(t, err)

@@ -25,7 +25,7 @@ func TestExportContainerAndImportImage(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithCmd("true"))

+	cID := container.Run(ctx, t, client, container.WithCmd("true"))

 	poll.WaitOn(t, container.IsStopped(ctx, client, cID), poll.WithDelay(100*time.Millisecond))

 	reference := "repo/testexp:v1"

@@ -67,7 +67,7 @@ func TestExportContainerAfterDaemonRestart(t *testing.T) {

 	defer d.Stop(t)

 	ctx := context.Background()

-	ctrID := container.Create(t, ctx, c)

+	ctrID := container.Create(ctx, t, c)

 	d.Restart(t)

@@ -22,7 +22,7 @@ func TestHealthCheckWorkdir(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client, container.WithTty(true), container.WithWorkingDir("/foo"), func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, container.WithTty(true), container.WithWorkingDir("/foo"), func(c *container.TestContainerConfig) {

 		c.Config.Healthcheck = &containertypes.HealthConfig{

 			Test:     []string{"CMD-SHELL", "if [ \"$PWD\" = \"/foo\" ]; then exit 0; else exit 1; fi;"},

 			Interval: 50 * time.Millisecond,

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

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	id := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	id := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.Config.Healthcheck = &containertypes.HealthConfig{

 			Test:     []string{"CMD-SHELL", "sleep 1"},

 			Interval: time.Second,

@@ -24,7 +24,7 @@ func TestInspectCpusetInConfigPre120(t *testing.T) {

 	name := "cpusetinconfig-pre120-" + t.Name()

 	// Create container with up to-date-API

-	container.Run(t, ctx, request.NewAPIClient(t), container.WithName(name),

+	container.Run(ctx, t, request.NewAPIClient(t), container.WithName(name),

 		container.WithCmd("true"),

 		func(c *container.TestContainerConfig) {

 			c.HostConfig.Resources.CpusetCpus = "0"

@@ -308,7 +308,7 @@ func TestIpcModeOlderClient(t *testing.T) {

 	ctx := context.Background()

 	// pre-check: default ipc mode in daemon is private

-	cID := container.Create(t, ctx, c, container.WithAutoRemove)

+	cID := container.Create(ctx, t, c, container.WithAutoRemove)

 	inspect, err := c.ContainerInspect(ctx, cID)

 	assert.NilError(t, err)

@@ -316,7 +316,7 @@ func TestIpcModeOlderClient(t *testing.T) {

 	// main check: using older client creates "shareable" container

 	c = request.NewAPIClient(t, client.WithVersion("1.39"))

-	cID = container.Create(t, ctx, c, container.WithAutoRemove)

+	cID = container.Create(ctx, t, c, container.WithAutoRemove)

 	inspect, err = c.ContainerInspect(ctx, cID)

 	assert.NilError(t, err)

@@ -18,7 +18,7 @@ func TestKillContainerInvalidSignal(t *testing.T) {

 	defer setupTest(t)()

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	id := container.Run(t, ctx, client)

+	id := container.Run(ctx, t, client)

 	err := client.ContainerKill(ctx, id, "0")

 	assert.Error(t, err, "Error response from daemon: Invalid signal: 0")

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

 		tc := tc

 		t.Run(tc.doc, func(t *testing.T) {

 			ctx := context.Background()

-			id := container.Run(t, ctx, client)

+			id := container.Run(ctx, t, client)

 			err := client.ContainerKill(ctx, id, tc.signal)

 			assert.NilError(t, err)

@@ -95,7 +95,7 @@ func TestKillWithStopSignalAndRestartPolicies(t *testing.T) {

 		tc := tc

 		t.Run(tc.doc, func(t *testing.T) {

 			ctx := context.Background()

-			id := container.Run(t, ctx, client,

+			id := container.Run(ctx, t, client,

 				container.WithRestartPolicy("always"),

 				func(c *container.TestContainerConfig) {

 					c.Config.StopSignal = tc.stopsignal

@@ -113,7 +113,7 @@ func TestKillStoppedContainer(t *testing.T) {

 	defer setupTest(t)()

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	id := container.Create(t, ctx, client)

+	id := container.Create(ctx, t, client)

 	err := client.ContainerKill(ctx, id, "SIGKILL")

 	assert.Assert(t, is.ErrorContains(err, ""))

 	assert.Assert(t, is.Contains(err.Error(), "is not running"))

@@ -124,7 +124,7 @@ func TestKillStoppedContainerAPIPre120(t *testing.T) {

 	defer setupTest(t)()

 	ctx := context.Background()

 	client := request.NewAPIClient(t, client.WithVersion("1.19"))

-	id := container.Create(t, ctx, client)

+	id := container.Create(ctx, t, client)

 	err := client.ContainerKill(ctx, id, "SIGKILL")

 	assert.NilError(t, err)

 }

@@ -137,7 +137,7 @@ func TestKillDifferentUserContainer(t *testing.T) {

 	ctx := context.Background()

 	client := request.NewAPIClient(t, client.WithVersion("1.19"))

-	id := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	id := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.Config.User = "daemon"

 	})

 	poll.WaitOn(t, container.IsInState(ctx, client, id, "running"), poll.WithDelay(100*time.Millisecond))

@@ -154,7 +154,7 @@ func TestInspectOomKilledTrue(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", "x=a; while true; do x=$x$x$x$x; done"), func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, container.WithCmd("sh", "-c", "x=a; while true; do x=$x$x$x$x; done"), func(c *container.TestContainerConfig) {

 		c.HostConfig.Resources.Memory = 32 * 1024 * 1024

 	})

@@ -172,7 +172,7 @@ func TestInspectOomKilledFalse(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", "echo hello world"))

+	cID := container.Run(ctx, t, client, container.WithCmd("sh", "-c", "echo hello world"))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))

@@ -24,7 +24,7 @@ func TestLinksEtcHostsContentMatch(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithNetworkMode("host"))

+	cID := container.Run(ctx, t, client, container.WithNetworkMode("host"))

 	res, err := container.Exec(ctx, client, cID, []string{"cat", "/etc/hosts"})

 	assert.NilError(t, err)

 	assert.Assert(t, is.Len(res.Stderr(), 0))

@@ -42,8 +42,8 @@ func TestLinksContainerNames(t *testing.T) {

 	containerA := "first_" + t.Name()

 	containerB := "second_" + t.Name()

-	container.Run(t, ctx, client, container.WithName(containerA))

-	container.Run(t, ctx, client, container.WithName(containerB), container.WithLinks(containerA+":"+containerA))

+	container.Run(ctx, t, client, container.WithName(containerA))

+	container.Run(ctx, t, client, container.WithName(containerB), container.WithLinks(containerA+":"+containerA))

 	f := filters.NewArgs(filters.Arg("name", containerA))

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

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	id := container.Run(t, ctx, client, container.WithCmd("sleep", "100000"))

+	id := container.Run(ctx, t, client, container.WithCmd("sleep", "100000"))

 	logs, err := client.ContainerLogs(ctx, id, types.ContainerLogsOptions{ShowStdout: true, Tail: "2"})

 	if logs != nil {

@@ -256,9 +256,9 @@ func TestContainerBindMountNonRecursive(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

 	containers := []string{

-		container.Run(t, ctx, client, container.WithMount(implicit), container.WithCmd(recursiveVerifier...)),

-		container.Run(t, ctx, client, container.WithMount(recursive), container.WithCmd(recursiveVerifier...)),

-		container.Run(t, ctx, client, container.WithMount(nonRecursive), container.WithCmd(nonRecursiveVerifier...)),

+		container.Run(ctx, t, client, container.WithMount(implicit), container.WithCmd(recursiveVerifier...)),

+		container.Run(ctx, t, client, container.WithMount(recursive), container.WithCmd(recursiveVerifier...)),

+		container.Run(ctx, t, client, container.WithMount(nonRecursive), container.WithCmd(nonRecursiveVerifier...)),

 	}

 	for _, c := range containers {

@@ -71,7 +71,7 @@ func TestNetworkLoopbackNat(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", fmt.Sprintf("stty raw && nc -w 5 %s 8080", endpoint.String())), container.WithTty(true), container.WithNetworkMode("container:"+serverContainerID))

+	cID := container.Run(ctx, t, client, container.WithCmd("sh", "-c", fmt.Sprintf("stty raw && nc -w 5 %s 8080", endpoint.String())), container.WithTty(true), container.WithNetworkMode("container:"+serverContainerID))

 	poll.WaitOn(t, container.IsStopped(ctx, client, cID), poll.WithDelay(100*time.Millisecond))

@@ -93,7 +93,7 @@ func startServerContainer(t *testing.T, msg string, port int) string {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithName("server-"+t.Name()), container.WithCmd("sh", "-c", fmt.Sprintf("echo %q | nc -lp %d", msg, port)), container.WithExposedPorts(fmt.Sprintf("%d/tcp", port)), func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, container.WithName("server-"+t.Name()), container.WithCmd("sh", "-c", fmt.Sprintf("echo %q | nc -lp %d", msg, port)), container.WithExposedPorts(fmt.Sprintf("%d/tcp", port)), func(c *container.TestContainerConfig) {

 		c.HostConfig.PortBindings = nat.PortMap{

 			nat.Port(fmt.Sprintf("%d/tcp", port)): []nat.PortBinding{

 				{

@@ -25,7 +25,7 @@ func TestPause(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	since := request.DaemonUnixTime(ctx, t, client, testEnv)

@@ -57,7 +57,7 @@ func TestPauseFailsOnWindowsServerContainers(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	err := client.ContainerPause(ctx, cID)

@@ -71,7 +71,7 @@ func TestPauseStopPausedContainer(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	err := client.ContainerPause(ctx, cID)

@@ -16,9 +16,9 @@ func TestPsFilter(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	prev := container.Create(t, ctx, client)

-	top := container.Create(t, ctx, client)

-	next := container.Create(t, ctx, client)

+	prev := container.Create(ctx, t, client)

+	top := container.Create(ctx, t, client)

+	next := container.Create(ctx, t, client)

 	containerIDs := func(containers []types.Container) []string {

 		var entries []string

@@ -36,7 +36,7 @@ func TestRemoveContainerWithRemovedVolume(t *testing.T) {

 	tempDir := fs.NewDir(t, "test-rm-container-with-removed-volume", fs.WithMode(0755))

 	defer tempDir.Remove()

-	cID := container.Run(t, ctx, client, container.WithCmd("true"), container.WithBind(tempDir.Path(), prefix+slash+"test"))

+	cID := container.Run(ctx, t, client, container.WithCmd("true"), container.WithBind(tempDir.Path(), prefix+slash+"test"))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))

 	err := os.RemoveAll(tempDir.Path())

@@ -59,7 +59,7 @@ func TestRemoveContainerWithVolume(t *testing.T) {

 	prefix, slash := getPrefixAndSlashFromDaemonPlatform()

-	cID := container.Run(t, ctx, client, container.WithCmd("true"), container.WithVolume(prefix+slash+"srv"))

+	cID := container.Run(ctx, t, client, container.WithCmd("true"), container.WithVolume(prefix+slash+"srv"))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))

 	insp, _, err := client.ContainerInspectWithRaw(ctx, cID, true)

@@ -82,7 +82,7 @@ func TestRemoveContainerRunning(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	err := client.ContainerRemove(ctx, cID, types.ContainerRemoveOptions{})

 	assert.Check(t, is.ErrorContains(err, "cannot remove a running container"))

@@ -93,7 +93,7 @@ func TestRemoveContainerForceRemoveRunning(t *testing.T) {

 	ctx := context.Background()

 	client := testEnv.APIClient()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	err := client.ContainerRemove(ctx, cID, types.ContainerRemoveOptions{

 		Force: true,

@@ -30,18 +30,18 @@ func TestRenameLinkedContainer(t *testing.T) {

 	aName := "a0" + t.Name()

 	bName := "b0" + t.Name()

-	aID := container.Run(t, ctx, client, container.WithName(aName))

-	bID := container.Run(t, ctx, client, container.WithName(bName), container.WithLinks(aName))

+	aID := container.Run(ctx, t, client, container.WithName(aName))

+	bID := container.Run(ctx, t, client, container.WithName(bName), container.WithLinks(aName))

 	err := client.ContainerRename(ctx, aID, "a1"+t.Name())

 	assert.NilError(t, err)

-	container.Run(t, ctx, client, container.WithName(aName))

+	container.Run(ctx, t, client, container.WithName(aName))

 	err = client.ContainerRemove(ctx, bID, types.ContainerRemoveOptions{Force: true})

 	assert.NilError(t, err)

-	bID = container.Run(t, ctx, client, container.WithName(bName), container.WithLinks(aName))

+	bID = container.Run(ctx, t, client, container.WithName(bName), container.WithLinks(aName))

 	inspect, err := client.ContainerInspect(ctx, bID)

 	assert.NilError(t, err)

@@ -54,7 +54,7 @@ func TestRenameStoppedContainer(t *testing.T) {

 	client := testEnv.APIClient()

 	oldName := "first_name" + t.Name()

-	cID := container.Run(t, ctx, client, container.WithName(oldName), container.WithCmd("sh"))

+	cID := container.Run(ctx, t, client, container.WithName(oldName), container.WithCmd("sh"))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))

 	inspect, err := client.ContainerInspect(ctx, cID)

@@ -76,7 +76,7 @@ func TestRenameRunningContainerAndReuse(t *testing.T) {

 	client := testEnv.APIClient()

 	oldName := "first_name" + t.Name()

-	cID := container.Run(t, ctx, client, container.WithName(oldName))

+	cID := container.Run(ctx, t, client, container.WithName(oldName))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	newName := "new_name" + stringid.GenerateRandomID()

@@ -90,7 +90,7 @@ func TestRenameRunningContainerAndReuse(t *testing.T) {

 	_, err = client.ContainerInspect(ctx, oldName)

 	assert.Check(t, is.ErrorContains(err, "No such container: "+oldName))

-	cID = container.Run(t, ctx, client, container.WithName(oldName))

+	cID = container.Run(ctx, t, client, container.WithName(oldName))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	inspect, err = client.ContainerInspect(ctx, cID)

@@ -104,7 +104,7 @@ func TestRenameInvalidName(t *testing.T) {

 	client := testEnv.APIClient()

 	oldName := "first_name" + t.Name()

-	cID := container.Run(t, ctx, client, container.WithName(oldName))

+	cID := container.Run(ctx, t, client, container.WithName(oldName))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	err := client.ContainerRename(ctx, oldName, "new:invalid")

@@ -132,7 +132,7 @@ func TestRenameAnonymousContainer(t *testing.T) {

 	_, err := client.NetworkCreate(ctx, networkName, types.NetworkCreate{})

 	assert.NilError(t, err)

-	cID := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.NetworkingConfig.EndpointsConfig = map[string]*network.EndpointSettings{

 			networkName: {},

 		}

@@ -155,7 +155,7 @@ func TestRenameAnonymousContainer(t *testing.T) {

 	if testEnv.OSType == "windows" {

 		count = "-n"

 	}

-	cID = container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	cID = container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.NetworkingConfig.EndpointsConfig = map[string]*network.EndpointSettings{

 			networkName: {},

 		}

@@ -175,7 +175,7 @@ func TestRenameContainerWithSameName(t *testing.T) {

 	client := testEnv.APIClient()

 	oldName := "old" + t.Name()

-	cID := container.Run(t, ctx, client, container.WithName(oldName))

+	cID := container.Run(ctx, t, client, container.WithName(oldName))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

 	err := client.ContainerRename(ctx, oldName, oldName)

@@ -198,12 +198,12 @@ func TestRenameContainerWithLinkedContainer(t *testing.T) {

 	client := testEnv.APIClient()

 	db1Name := "db1" + t.Name()

-	db1ID := container.Run(t, ctx, client, container.WithName(db1Name))

+	db1ID := container.Run(ctx, t, client, container.WithName(db1Name))

 	poll.WaitOn(t, container.IsInState(ctx, client, db1ID, "running"), poll.WithDelay(100*time.Millisecond))

 	app1Name := "app1" + t.Name()

 	app2Name := "app2" + t.Name()

-	app1ID := container.Run(t, ctx, client, container.WithName(app1Name), container.WithLinks(db1Name+":/mysql"))

+	app1ID := container.Run(ctx, t, client, container.WithName(app1Name), container.WithLinks(db1Name+":/mysql"))

 	poll.WaitOn(t, container.IsInState(ctx, client, app1ID, "running"), poll.WithDelay(100*time.Millisecond))

 	err := client.ContainerRename(ctx, app1Name, app2Name)

@@ -22,7 +22,7 @@ func TestResize(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

@@ -40,7 +40,7 @@ func TestResizeWithInvalidSize(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

@@ -55,7 +55,7 @@ func TestResizeWhenContainerNotStarted(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithCmd("echo"))

+	cID := container.Run(ctx, t, client, container.WithCmd("echo"))

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))

@@ -29,7 +29,7 @@ func TestKernelTCPMemory(t *testing.T) {

 		kernelMemoryTCP int64 = 200 * 1024 * 1024

 	)

-	cID := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.HostConfig.Resources = containertypes.Resources{

 			KernelMemoryTCP: kernelMemoryTCP,

 		}

@@ -65,7 +65,7 @@ func TestNISDomainname(t *testing.T) {

 		domainname = "baz.cyphar.com"

 	)

-	cID := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.Config.Hostname = hostname

 		c.Config.Domainname = domainname

 	})

@@ -25,7 +25,7 @@ func TestStats(t *testing.T) {

 	info, err := client.Info(ctx)

 	assert.NilError(t, err)

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))

@@ -54,7 +54,7 @@ func TestStopContainerWithTimeout(t *testing.T) {

 		d := d

 		t.Run(strconv.Itoa(d.timeout), func(t *testing.T) {

 			t.Parallel()

-			id := container.Run(t, ctx, client, testCmd)

+			id := container.Run(ctx, t, client, testCmd)

 			timeout := time.Duration(d.timeout) * time.Second

 			err := client.ContainerStop(ctx, id, &timeout)

@@ -78,7 +78,7 @@ func TestDeleteDevicemapper(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	id := container.Run(t, ctx, client, container.WithName("foo-"+t.Name()), container.WithCmd("echo"))

+	id := container.Run(ctx, t, client, container.WithName("foo-"+t.Name()), container.WithCmd("echo"))

 	poll.WaitOn(t, container.IsStopped(ctx, client, id), poll.WithDelay(100*time.Millisecond))

@@ -17,7 +17,7 @@ func TestStopContainerWithRestartPolicyAlways(t *testing.T) {

 	names := []string{"verifyRestart1-" + t.Name(), "verifyRestart2-" + t.Name()}

 	for _, name := range names {

-		container.Run(t, ctx, client,

+		container.Run(ctx, t, client,

 			container.WithName(name),

 			container.WithCmd("false"),

 			container.WithRestartPolicy("always"),

@@ -51,7 +51,7 @@ func TestStopContainerWithTimeout(t *testing.T) {

 		d := d

 		t.Run(strconv.Itoa(d.timeout), func(t *testing.T) {

 			t.Parallel()

-			id := container.Run(t, ctx, client, testCmd)

+			id := container.Run(ctx, t, client, testCmd)

 			timeout := time.Duration(d.timeout) * time.Second

 			err := client.ContainerStop(ctx, id, &timeout)

@@ -26,7 +26,7 @@ func TestUpdateMemory(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {

 		c.HostConfig.Resources = containertypes.Resources{

 			Memory: 200 * 1024 * 1024,

 		}

@@ -72,7 +72,7 @@ func TestUpdateCPUQuota(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client)

+	cID := container.Run(ctx, t, client)

 	for _, test := range []struct {

 		desc   string

@@ -140,7 +140,7 @@ func TestUpdatePidsLimit(t *testing.T) {

 		t.Run(test.desc, func(t *testing.T) {

 			// Using "network=host" to speed up creation (13.96s vs 6.54s)

-			cID := container.Run(t, ctx, apiClient, container.WithPidsLimit(test.initial), container.WithNetworkMode("host"))

+			cID := container.Run(ctx, t, apiClient, container.WithPidsLimit(test.initial), container.WithNetworkMode("host"))

 			_, err := c.ContainerUpdate(ctx, cID, containertypes.UpdateConfig{

 				Resources: containertypes.Resources{

@@ -17,7 +17,7 @@ func TestUpdateRestartPolicy(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", "sleep 1 && false"), func(c *container.TestContainerConfig) {

+	cID := container.Run(ctx, t, client, container.WithCmd("sh", "-c", "sleep 1 && false"), func(c *container.TestContainerConfig) {

 		c.HostConfig.RestartPolicy = containertypes.RestartPolicy{

 			Name:              "on-failure",

 			MaximumRetryCount: 3,

@@ -50,7 +50,7 @@ func TestUpdateRestartWithAutoRemove(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID := container.Run(t, ctx, client, container.WithAutoRemove)

+	cID := container.Run(ctx, t, client, container.WithAutoRemove)

 	_, err := client.ContainerUpdate(ctx, cID, containertypes.UpdateConfig{

 		RestartPolicy: containertypes.RestartPolicy{

@@ -39,7 +39,7 @@ func TestWaitNonBlocked(t *testing.T) {

 		t.Run(tc.doc, func(t *testing.T) {

 			t.Parallel()

 			ctx := context.Background()

-			containerID := container.Run(t, ctx, cli, container.WithCmd("sh", "-c", tc.cmd))

+			containerID := container.Run(ctx, t, cli, container.WithCmd("sh", "-c", tc.cmd))

 			poll.WaitOn(t, container.IsInState(ctx, cli, containerID, "exited"), poll.WithTimeout(30*time.Second), poll.WithDelay(100*time.Millisecond))

 			waitresC, errC := cli.ContainerWait(ctx, containerID, "")

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

 		t.Run(tc.doc, func(t *testing.T) {

 			t.Parallel()

 			ctx := context.Background()

-			containerID := container.Run(t, ctx, cli, container.WithCmd("sh", "-c", tc.cmd))

+			containerID := container.Run(ctx, t, cli, container.WithCmd("sh", "-c", tc.cmd))

 			poll.WaitOn(t, container.IsInState(ctx, cli, containerID, "running"), poll.WithTimeout(30*time.Second), poll.WithDelay(100*time.Millisecond))

 			waitresC, errC := cli.ContainerWait(ctx, containerID, "")

@@ -19,7 +19,7 @@ func TestCommitInheritsEnv(t *testing.T) {

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	cID1 := container.Create(t, ctx, client)

+	cID1 := container.Create(ctx, t, client)

 	commitResp1, err := client.ContainerCommit(ctx, cID1, types.ContainerCommitOptions{

 		Changes:   []string{"ENV PATH=/bin"},

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

 	expectedEnv1 := []string{"PATH=/bin"}

 	assert.Check(t, is.DeepEqual(expectedEnv1, image1.Config.Env))

-	cID2 := container.Create(t, ctx, client, container.WithImage(image1.ID))

+	cID2 := container.Create(ctx, t, client, container.WithImage(image1.ID))

 	commitResp2, err := client.ContainerCommit(ctx, cID2, types.ContainerCommitOptions{

 		Changes:   []string{"ENV PATH=/usr/bin:$PATH"},

@@ -20,7 +20,7 @@ func TestRemoveImageOrphaning(t *testing.T) {

 	img := "test-container-orphaning"

 	// Create a container from busybox, and commit a small change so we have a new image

-	cID1 := container.Create(t, ctx, client, container.WithCmd(""))

+	cID1 := container.Create(ctx, t, client, container.WithCmd(""))

 	commitResp1, err := client.ContainerCommit(ctx, cID1, types.ContainerCommitOptions{

 		Changes:   []string{`ENTRYPOINT ["true"]`},

 		Reference: img,

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

 	assert.Check(t, is.Equal(resp.ID, commitResp1.ID))

 	// Create a container from created image, and commit a small change with same reference name

-	cID2 := container.Create(t, ctx, client, container.WithImage(img), container.WithCmd(""))

+	cID2 := container.Create(ctx, t, client, container.WithImage(img), container.WithCmd(""))

 	commitResp2, err := client.ContainerCommit(ctx, cID2, types.ContainerCommitOptions{

 		Changes:   []string{`LABEL Maintainer="Integration Tests"`},

 		Reference: img,

@@ -22,8 +22,7 @@ type TestContainerConfig struct {

 }

 // Create creates a container with the specified options

-// nolint: golint

-func Create(t *testing.T, ctx context.Context, client client.APIClient, ops ...func(*TestContainerConfig)) string { // nolint: golint

+func Create(ctx context.Context, t *testing.T, client client.APIClient, ops ...func(*TestContainerConfig)) string {

 	t.Helper()

 	cmd := []string{"top"}

 	if runtime.GOOS == "windows" {

@@ -49,10 +48,9 @@ func Create(t *testing.T, ctx context.Context, client client.APIClient, ops ...f

 }

 // Run creates and start a container with the specified options

-// nolint: golint

-func Run(t *testing.T, ctx context.Context, client client.APIClient, ops ...func(*TestContainerConfig)) string { // nolint: golint

+func Run(ctx context.Context, t *testing.T, client client.APIClient, ops ...func(*TestContainerConfig)) string {

 	t.Helper()

-	id := Create(t, ctx, client, ops...)

+	id := Create(ctx, t, client, ops...)

 	err := client.ContainerStart(ctx, id, types.ContainerStartOptions{})

 	assert.NilError(t, err)

@@ -26,8 +26,7 @@ func Create(ctx context.Context, client client.APIClient, name string, ops ...fu

 }

 // CreateNoError creates a network with the specified options and verifies there were no errors

-// nolint: golint

-func CreateNoError(t *testing.T, ctx context.Context, client client.APIClient, name string, ops ...func(*types.NetworkCreate)) string { // nolint: golint

+func CreateNoError(ctx context.Context, t *testing.T, client client.APIClient, name string, ops ...func(*types.NetworkCreate)) string { // nolint: golint

 	t.Helper()

 	name, err := createNetwork(ctx, client, name, ops...)

@@ -27,10 +27,10 @@ func containsNetwork(nws []types.NetworkResource, networkID string) bool {

 // first network's ID as name.

 //

 // After successful creation, properties of all three networks is returned

-func createAmbiguousNetworks(t *testing.T, ctx context.Context, client dclient.APIClient) (string, string, string) { // nolint: golint

-	testNet := network.CreateNoError(t, ctx, client, "testNet")

-	idPrefixNet := network.CreateNoError(t, ctx, client, testNet[:12])

-	fullIDNet := network.CreateNoError(t, ctx, client, testNet)

+func createAmbiguousNetworks(ctx context.Context, t *testing.T, client dclient.APIClient) (string, string, string) {

+	testNet := network.CreateNoError(ctx, t, client, "testNet")

+	idPrefixNet := network.CreateNoError(ctx, t, client, testNet[:12])

+	fullIDNet := network.CreateNoError(ctx, t, client, testNet)

 	nws, err := client.NetworkList(ctx, types.NetworkListOptions{})

 	assert.NilError(t, err)

@@ -49,7 +49,7 @@ func TestNetworkCreateDelete(t *testing.T) {

 	ctx := context.Background()

 	netName := "testnetwork_" + t.Name()

-	network.CreateNoError(t, ctx, client, netName,

+	network.CreateNoError(ctx, t, client, netName,

 		network.WithCheckDuplicate(),

 	)

 	assert.Check(t, IsNetworkAvailable(client, netName))

@@ -70,7 +70,7 @@ func TestDockerNetworkDeletePreferID(t *testing.T) {

 	defer setupTest(t)()

 	client := testEnv.APIClient()

 	ctx := context.Background()

-	testNet, idPrefixNet, fullIDNet := createAmbiguousNetworks(t, ctx, client)

+	testNet, idPrefixNet, fullIDNet := createAmbiguousNetworks(ctx, t, client)

 	// Delete the network using a prefix of the first network's ID as name.

 	// This should the network name with the id-prefix, not the original network.

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

 	defer c.Close()

 	networkName := "Overlay" + t.Name()

-	overlayID := network.CreateNoError(t, context.Background(), c, networkName,

+	overlayID := network.CreateNoError(context.Background(), t, c, networkName,

 		network.WithDriver("overlay"),

 		network.WithCheckDuplicate(),

 	)

@@ -39,7 +39,7 @@ func TestDockerNetworkIpvlanPersistance(t *testing.T) {

 	// create a network specifying the desired sub-interface name

 	netName := "di-persist"

-	net.CreateNoError(t, context.Background(), c, netName,

+	net.CreateNoError(context.Background(), t, c, netName,

 		net.WithIPvlan("di-dummy0.70", ""),

 	)

@@ -105,7 +105,7 @@ func testIpvlanSubinterface(client dclient.APIClient) func(*testing.T) {

 		defer n.DeleteInterface(t, master)

 		netName := "di-subinterface"

-		net.CreateNoError(t, context.Background(), client, netName,

+		net.CreateNoError(context.Background(), t, client, netName,

 			net.WithIPvlan("di-dummy0.60", ""),

 		)

 		assert.Check(t, n.IsNetworkAvailable(client, netName))

@@ -130,7 +130,7 @@ func testIpvlanOverlapParent(client dclient.APIClient) func(*testing.T) {

 		n.CreateVlanInterface(t, master, parent, "30")

 		netName := "di-subinterface"

-		net.CreateNoError(t, context.Background(), client, netName,

+		net.CreateNoError(context.Background(), t, client, netName,

 			net.WithIPvlan(parent, ""),

 		)

 		assert.Check(t, n.IsNetworkAvailable(client, netName))

@@ -147,14 +147,14 @@ func testIpvlanL2NilParent(client dclient.APIClient) func(*testing.T) {

 	return func(t *testing.T) {

 		// ipvlan l2 mode - dummy parent interface is provisioned dynamically

 		netName := "di-nil-parent"

-		net.CreateNoError(t, context.Background(), client, netName,

+		net.CreateNoError(context.Background(), t, client, netName,

 			net.WithIPvlan("", ""),

 		)

 		assert.Check(t, n.IsNetworkAvailable(client, netName))

 		ctx := context.Background()

-		id1 := container.Run(t, ctx, client, container.WithNetworkMode(netName))

-		id2 := container.Run(t, ctx, client, container.WithNetworkMode(netName))

+		id1 := container.Run(ctx, t, client, container.WithNetworkMode(netName))

+		id2 := container.Run(ctx, t, client, container.WithNetworkMode(netName))

 		_, err := container.Exec(ctx, client, id2, []string{"ping", "-c", "1", id1})

 		assert.NilError(t, err)

@@ -164,15 +164,15 @@ func testIpvlanL2NilParent(client dclient.APIClient) func(*testing.T) {

 func testIpvlanL2InternalMode(client dclient.APIClient) func(*testing.T) {

 	return func(t *testing.T) {

 		netName := "di-internal"

-		net.CreateNoError(t, context.Background(), client, netName,

+		net.CreateNoError(context.Background(), t, client, netName,

 			net.WithIPvlan("", ""),

 			net.WithInternal(),

 		)

 		assert.Check(t, n.IsNetworkAvailable(client, netName))

 		ctx := context.Background()

-		id1 := container.Run(t, ctx, client, container.WithNetworkMode(netName))

-		id2 := container.Run(t, ctx, client, container.WithNetworkMode(netName))

+		id1 := container.Run(ctx, t, client, container.WithNetworkMode(netName))

+		id2 := container.Run(ctx, t, client, container.WithNetworkMode(netName))

 		timeoutCtx, cancel := context.WithTimeout(context.Background(), 1*time.Second)

 		defer cancel()

@@ -189,7 +189,7 @@ func testIpvlanL2InternalMode(client dclient.APIClient) func(*testing.T) {

 func testIpvlanL3NilParent(client dclient.APIClient) func(*testing.T) {

 	return func(t *testing.T) {

 		netName := "di-nil-parent-l3"

-		net.CreateNoError(t, context.Background(), client, netName,

+		net.CreateNoError(context.Background(), t, client, netName,

 			net.WithIPvlan("", "l3"),

 			net.WithIPAM("172.28.230.0/24", ""),