kubernetes/pkg/kubelet/config/config_test.go

const TestSource …

func expectEmptyChannel(t *testing.T, ch <-chan interface{ … }

type sortedPods …

func (s sortedPods) Len() int { … }

func (s sortedPods) Swap(i, j int) { … }

func (s sortedPods) Less(i, j int) bool { … }

type mockPodStartupSLIObserver …

func (m *mockPodStartupSLIObserver) ObservedPodOnWatch(pod *v1.Pod, when time.Time) { … }

func CreateValidPod(name, namespace string) *v1.Pod { … }

func CreatePodUpdate(op kubetypes.PodOperation, source string, pods ...*v1.Pod) kubetypes.PodUpdate { … }

func createPodConfigTester(ctx context.Context, mode PodConfigNotificationMode) (chan<- interface{ … }

func expectPodUpdate(t *testing.T, ch <-chan kubetypes.PodUpdate, expected ...kubetypes.PodUpdate) { … }

func expectNoPodUpdate(t *testing.T, ch <-chan kubetypes.PodUpdate) { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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