kubernetes/pkg/kubelet/prober/prober_manager_test.go

func init() { … }

var defaultProbe …

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

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

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

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

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

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

func (m *manager) extractedReadinessHandling() { … }

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

func expectProbes(m *manager, expectedProbes []probeKey) error { … }

const interval …

// Wait for the given workers to exit & clean up.
func waitForWorkerExit(t *testing.T, m *manager, workerPaths []probeKey) error { … }

// Wait for the given workers to exit & clean up.
func waitForReadyStatus(t *testing.T, m *manager, ready bool) error { … }

// cleanup running probes to avoid leaking goroutines.
func cleanup(t *testing.T, m *manager) { … }