kubernetes/pkg/kubelet/pleg/generic_test.go

const testContainerRuntimeType …

const largeChannelCap …

type TestGenericPLEG …

func newTestGenericPLEG() *TestGenericPLEG { … }

func newTestGenericPLEGWithChannelSize(eventChannelCap int) *TestGenericPLEG { … }

func getEventsFromChannel(ch <-chan *PodLifecycleEvent) []*PodLifecycleEvent { … }

func createTestContainer(ID string, state kubecontainer.State) *kubecontainer.Container { … }

type sortableEvents …

func (a sortableEvents) Len() int      { … }

func (a sortableEvents) Swap(i, j int) { … }

func (a sortableEvents) Less(i, j int) bool { … }

func verifyEvents(t *testing.T, expected, actual []*PodLifecycleEvent) { … }

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

// TestEventChannelFull test when channel is full, the events will be discard.
func TestEventChannelFull(t *testing.T) { … }

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

func testReportMissingContainers(t *testing.T, numRelists int) { … }

func testReportMissingPods(t *testing.T, numRelists int) { … }

func newTestGenericPLEGWithRuntimeMock(runtimeMock kubecontainer.Runtime) *GenericPLEG { … }

func createTestPodsStatusesAndEvents(num int) ([]*kubecontainer.Pod, []*kubecontainer.PodStatus, []*PodLifecycleEvent) { … }

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

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

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

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

// Test detecting sandbox state changes.
func TestRelistingWithSandboxes(t *testing.T) { … }

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

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