Function TestDockerContainerRestartCount

integration/tests/api/docker_test.go:436–472

Check that restart count is captured in labels.

(t *testing.T)

// Check that restart count is captured in labels.
func TestDockerContainerRestartCount(t *testing.T) {
	fm := framework.New(t)
	defer fm.Cleanup()

	containerName := fmt.Sprintf("test-restart-count-%d", os.Getpid())
	// Run a container that runs briefly then exits with failure, with restart policy
	// The sleep gives cAdvisor time to detect the container between restarts
	fm.Docker().Run(framework.DockerRunArgs{
		Image: "registry.k8s.io/busybox:1.27",
		Args: []string{
			"--name", containerName,
			"--restart", "on-failure:5",
		},
	}, "sh", "-c", "sleep 3 && exit 1")

	// Wait for container to show up initially
	waitForContainer(containerName, fm)

	// Wait for at least one restart to occur
	time.Sleep(5 * time.Second)

	request := &info.ContainerInfoRequest{
		NumStats: 1,
	}

	// Query the container - it should still be running or restarting
	containerInfo, err := fm.Cadvisor().Client().DockerContainer(containerName, request)
	require.NoError(t, err, "Container should still be available during restart cycle")
	sanityCheck(containerName, containerInfo, t)

	// Check that restart count label is present and greater than 0
	restartCount, ok := containerInfo.Spec.Labels["restartcount"]
	require.True(t, ok, "restartcount label should be present")
	count, err := strconv.Atoi(restartCount)
	require.NoError(t, err)
	assert.GreaterOrEqual(t, count, 1, "Restart count should be at least 1")
}

// Check the DiskIo ContainerStats.
func TestDockerContainerDiskIoStats(t *testing.T) {