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

func makeTestPod(name string, resourceVersion uint64) *v1.Pod { … }

func makeTestPodDetails(name string, resourceVersion uint64, nodeName string, labels map[string]string) *v1.Pod { … }

func makeTestStoreElement(pod *v1.Pod) *storeElement { … }

type testWatchCache …

func (w *testWatchCache) getAllEventsSince(resourceVersion uint64, opts storage.ListOptions) ([]*watchCacheEvent, error) { … }

func (w *testWatchCache) getCacheIntervalForEvents(resourceVersion uint64, opts storage.ListOptions) (*watchCacheInterval, error) { … }

// newTestWatchCache just adds a fake clock.
func newTestWatchCache(capacity int, indexers *cache.Indexers) *testWatchCache { … }

type immediateTickerFactory …

func (t *immediateTickerFactory) NewTimer(d time.Duration) clock.Timer { … }

type immediateTicker …

func (t *immediateTicker) Reset(d time.Duration) (active bool) { … }

func (t *immediateTicker) C() <-chan time.Time { … }

func (t *immediateTicker) Stop() bool { … }

func (w *testWatchCache) RequestWatchProgress(ctx context.Context) error { … }

func (w *testWatchCache) Stop() { … }

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

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

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

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

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

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

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

type testLW …

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

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

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

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

func loadEventWithDuration(cache *testWatchCache, count int, interval time.Duration) { … }

func checkCacheElements(cache *testWatchCache) bool { … }

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

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

func BenchmarkWatchCache_updateCache(b *testing.B) { … }

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