kubernetes/pkg/kubelet/status/status_manager_test.go

type mutablePodManager …

// Generate new instance of test pod with the same initial value.
func getTestPod() *v1.Pod { … }

// After adding reconciliation, if status in pod manager is different from the cached status, a reconciliation
// will be triggered, which will mess up all the old unit test.
// To simplify the implementation of unit test, we add testSyncBatch() here, it will make sure the statuses in
// pod manager the same with cached ones before syncBatch(true) so as to avoid reconciling.
func (m *manager) testSyncBatch() { … }

func newTestManager(kubeClient clientset.Interface) *manager { … }

func generateRandomMessage() string { … }

func getRandomPodStatus() v1.PodStatus { … }

func verifyActions(t *testing.T, manager *manager, expectedActions []core.Action) { … }

func verifyUpdates(t *testing.T, manager *manager, expectedUpdates int) { … }

func (m *manager) consumeUpdates() int { … }

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

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

func getReadyPodStatus() v1.PodStatus { … }

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

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

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

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

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

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

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

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

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

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

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

// shuffle returns a new shuffled list of container statuses.
func shuffle(statuses []v1.ContainerStatus) []v1.ContainerStatus { … }

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

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

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

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

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

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

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

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

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

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

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

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

func expectPodStatus(t *testing.T, m *manager, pod *v1.Pod) v1.PodStatus { … }

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

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

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

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

func getAction() core.GetAction { … }

func patchAction() core.PatchAction { … }

func deleteAction() core.DeleteAction { … }

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

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

func statusEqual(left, right v1.PodStatus) bool { … }

func conditionsEqual(left, right []v1.PodCondition) bool { … }

func getPodStatus() v1.PodStatus { … }