Function TestPodDualStack

integration/pod_dualstack_test.go:34–109

(t *testing.T)

)

func TestPodDualStack(t *testing.T) {
	testPodLogDir := t.TempDir()

	t.Log("Create a sandbox")
	sb, sbConfig := PodSandboxConfigWithCleanup(t, "sandbox", "dualstack", WithPodLogDirectory(testPodLogDir))

	var (
		testImage     = images.Get(images.BusyBox)
		containerName = "test-container"
	)

	EnsureImageExists(t, testImage)

	t.Log("Create a container to print env")
	var command ContainerOpts
	if goruntime.GOOS == "windows" {
		command = WithCommand("ipconfig")
	} else {
		command = WithCommand("ip", "address", "show", "dev", "eth0")
	}
	cnConfig := ContainerConfig(
		containerName,
		testImage,
		command,
		WithLogPath(containerName),
	)
	cn, err := runtimeService.CreateContainer(sb, cnConfig, sbConfig)
	require.NoError(t, err)

	t.Log("Start the container")
	require.NoError(t, runtimeService.StartContainer(cn))

	t.Log("Wait for container to finish running")
	require.NoError(t, Eventually(func() (bool, error) {
		s, err := runtimeService.ContainerStatus(cn)
		if err != nil {
			return false, err
		}
		if s.GetState() == runtime.ContainerState_CONTAINER_EXITED {
			return true, nil
		}
		return false, nil
	}, time.Second, 30*time.Second))

	content, err := os.ReadFile(filepath.Join(testPodLogDir, containerName))
	assert.NoError(t, err)
	status, err := runtimeService.PodSandboxStatus(sb)
	require.NoError(t, err)
	ip := status.GetNetwork().GetIp()
	additionalIps := status.GetNetwork().GetAdditionalIps()

	var ipv4Regex, ipv6Regex string
	if goruntime.GOOS == "windows" {
		ipv4Regex = "^\\s*IPv4 Address"
		ipv6Regex = "^\\s*IPv6 Address"
	} else {
		ipv4Regex = "inet .* scope global"
		ipv6Regex = "inet6 .* scope global"