kubernetes/pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

var fakeCreatedAt …

var containerRestartPolicyAlways …

func createTestRuntimeManager() (*apitest.FakeRuntimeService, *apitest.FakeImageService, *kubeGenericRuntimeManager, error) { … }

func customTestRuntimeManager(keyring *credentialprovider.BasicDockerKeyring) (*apitest.FakeRuntimeService, *apitest.FakeImageService, *kubeGenericRuntimeManager, error) { … }

type sandboxTemplate …

type containerTemplate …

// makeAndSetFakePod is a helper function to create and set one fake sandbox for a pod and
// one fake container for each of its container.
func makeAndSetFakePod(t *testing.T, m *kubeGenericRuntimeManager, fakeRuntime *apitest.FakeRuntimeService,
	pod *v1.Pod) (*apitest.FakePodSandbox, []*apitest.FakeContainer) { … }

// makeFakePodSandbox creates a fake pod sandbox based on a sandbox template.
func makeFakePodSandbox(t *testing.T, m *kubeGenericRuntimeManager, template sandboxTemplate) *apitest.FakePodSandbox { … }

// makeFakePodSandboxes creates a group of fake pod sandboxes based on the sandbox templates.
// The function guarantees the order of the fake pod sandboxes is the same with the templates.
func makeFakePodSandboxes(t *testing.T, m *kubeGenericRuntimeManager, templates []sandboxTemplate) []*apitest.FakePodSandbox { … }

// makeFakeContainer creates a fake container based on a container template.
func makeFakeContainer(t *testing.T, m *kubeGenericRuntimeManager, template containerTemplate) *apitest.FakeContainer { … }

// makeFakeContainers creates a group of fake containers based on the container templates.
// The function guarantees the order of the fake containers is the same with the templates.
func makeFakeContainers(t *testing.T, m *kubeGenericRuntimeManager, templates []containerTemplate) []*apitest.FakeContainer { … }

// makeTestContainer creates a test api container.
func makeTestContainer(name, image string) v1.Container { … }

// makeTestPod creates a test api pod.
func makeTestPod(podName, podNamespace, podUID string, containers []v1.Container) *v1.Pod { … }

// verifyPods returns true if the two pod slices are equal.
func verifyPods(a, b []*kubecontainer.Pod) bool { … }

func verifyFakeContainerList(fakeRuntime *apitest.FakeRuntimeService, expected sets.Set[string]) (sets.Set[string], bool) { … }

type cRecord …

type cRecordList …

func (b cRecordList) Len() int      { … }

func (b cRecordList) Swap(i, j int) { … }

func (b cRecordList) Less(i, j int) bool { … }

func verifyContainerStatuses(t *testing.T, runtime *apitest.FakeRuntimeService, expected []*cRecord, desc string) { … }

func TestNewKubeRuntimeManager(t *testing.T) { … }

func TestVersion(t *testing.T) { … }

func TestContainerRuntimeType(t *testing.T) { … }

func TestGetPodStatus(t *testing.T) { … }

func TestStopContainerWithNotFoundError(t *testing.T) { … }

func TestGetPodStatusWithNotFoundError(t *testing.T) { … }

func TestGetPods(t *testing.T) { … }

func TestGetPodsSorted(t *testing.T) { … }

func TestKillPod(t *testing.T) { … }

func TestSyncPod(t *testing.T) { … }

func TestSyncPodWithConvertedPodSysctls(t *testing.T) { … }

func TestPruneInitContainers(t *testing.T) { … }

func TestSyncPodWithInitContainers(t *testing.T) { … }

// A helper function to get a basic pod and its status assuming all sandbox and
// containers are running and ready.
func makeBasePodAndStatus() (*v1.Pod, *kubecontainer.PodStatus) { … }

func TestComputePodActions(t *testing.T) { … }

func getKillMap(pod *v1.Pod, status *kubecontainer.PodStatus, cIndexes []int) map[kubecontainer.ContainerID]containerToKillInfo { … }

func getKillMapWithInitContainers(pod *v1.Pod, status *kubecontainer.PodStatus, cIndexes []int) map[kubecontainer.ContainerID]containerToKillInfo { … }

func verifyActions(t *testing.T, expected, actual *podActions, desc string) { … }

func TestComputePodActionsWithInitContainers(t *testing.T) { … }

func testComputePodActionsWithInitContainers(t *testing.T, sidecarContainersEnabled bool) { … }

func makeBasePodAndStatusWithInitContainers() (*v1.Pod, *kubecontainer.PodStatus) { … }

func TestComputePodActionsWithRestartableInitContainers(t *testing.T) { … }

func makeBasePodAndStatusWithRestartableInitContainers() (*v1.Pod, *kubecontainer.PodStatus) { … }

func TestComputePodActionsWithInitAndEphemeralContainers(t *testing.T) { … }

func testComputePodActionsWithInitAndEphemeralContainers(t *testing.T, sidecarContainersEnabled bool) { … }

func TestSyncPodWithSandboxAndDeletedPod(t *testing.T) { … }

func makeBasePodAndStatusWithInitAndEphemeralContainers() (*v1.Pod, *kubecontainer.PodStatus) { … }

func TestComputePodActionsForPodResize(t *testing.T) { … }

func TestUpdatePodContainerResources(t *testing.T) { … }

func TestToKubeContainerImageVolumes(t *testing.T) { … }

func TestGetImageVolumes(t *testing.T) { … }