kubernetes/staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go

// verifies the cacheWatcher.process goroutine is properly cleaned up even if
// the writes to cacheWatcher.result channel is blocked.
func TestCacheWatcherCleanupNotBlockedByResult(t *testing.T) { … }

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

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

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

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

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

func makeWatchCacheEvent(rv uint64) *watchCacheEvent { … }

// TestCacheWatcherDraining verifies the cacheWatcher.process goroutine is properly cleaned up when draining was requested
func TestCacheWatcherDraining(t *testing.T) { … }

// TestCacheWatcherDrainingRequestedButNotDrained verifies the cacheWatcher.process goroutine is properly cleaned up when draining was requested
// but the client never actually get any data
func TestCacheWatcherDrainingRequestedButNotDrained(t *testing.T) { … }

// TestCacheWatcherDrainingNoBookmarkAfterResourceVersionReceived verifies if the watcher will be stopped
// when adding an item times out and the bookmarkAfterResourceVersion hasn't been received
func TestCacheWatcherDrainingNoBookmarkAfterResourceVersionReceived(t *testing.T) { … }

// TestCacheWatcherDrainingNoBookmarkAfterResourceVersionSent checks if the watcher's input
// channel is drained if the bookmarkAfterResourceVersion was received but not sent
func TestCacheWatcherDrainingNoBookmarkAfterResourceVersionSent(t *testing.T) { … }

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