kubernetes/staging/src/k8s.io/client-go/tools/cache/reflector_watchlist_test.go

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

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

func verifyRequestOptions(t *testing.T, lw *fakeListWatcher, expectedRequestOptions []metav1.ListOptions) { … }

func verifyListCounter(t *testing.T, lw *fakeListWatcher, expectedListCounter int) { … }

func verifyWatchCounter(t *testing.T, lw *fakeListWatcher, expectedWatchCounter int) { … }

type byName …

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

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

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

func verifyStore(t *testing.T, s Store, expectedPods []v1.Pod) { … }

func makePod(name, rv string) *v1.Pod { … }

func testData() (*fakeListWatcher, Store, *Reflector, chan struct{ … }

type fakeListWatcher …

func (lw *fakeListWatcher) List(options metav1.ListOptions) (runtime.Object, error) { … }

func (lw *fakeListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error) { … }

func (lw *fakeListWatcher) StopAndRecreateWatch() { … }