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

var nevererrc …

type testLW …

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

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

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

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

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

// TestReflectorWatchStoppedBefore ensures that neither List nor Watch are
// called if the stop channel is closed before Reflector.watch is called.
func TestReflectorWatchStoppedBefore(t *testing.T) { … }

// TestReflectorWatchStoppedAfter ensures that neither the watcher is stopped if
// the stop channel is closed after Reflector.watch has started watching.
func TestReflectorWatchStoppedAfter(t *testing.T) { … }

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

// TestReflectorHandleWatchStoppedBefore ensures that handleWatch stops when
// stopCh is already closed before handleWatch was called. It also ensures that
// ResultChan is only called once and that Stop is called after ResultChan.
func TestReflectorHandleWatchStoppedBefore(t *testing.T) { … }

// TestReflectorHandleWatchStoppedAfter ensures that handleWatch stops when
// stopCh is closed after handleWatch was called. It also ensures that
// ResultChan is only called once and that Stop is called after ResultChan.
func TestReflectorHandleWatchStoppedAfter(t *testing.T) { … }

// TestReflectorHandleWatchResultChanClosedBefore ensures that handleWatch
// stops when the result channel is closed before handleWatch was called.
func TestReflectorHandleWatchResultChanClosedBefore(t *testing.T) { … }

// TestReflectorHandleWatchResultChanClosedAfter ensures that handleWatch
// stops when the result channel is closed after handleWatch has started watching.
func TestReflectorHandleWatchResultChanClosedAfter(t *testing.T) { … }

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

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

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

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

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

type fakeBackoff …

func (f *fakeBackoff) Backoff() clock.Timer { … }

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

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

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

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

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

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

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

// TestReflectorResyncWithResourceVersion ensures that a reflector keeps track of the ResourceVersion and sends
// it in relist requests to prevent the reflector from traveling back in time if the relist is to a api-server or
// etcd that is partitioned and serving older data than the reflector has already processed.
func TestReflectorResyncWithResourceVersion(t *testing.T) { … }

// TestReflectorExpiredExactResourceVersion tests that a reflector handles the behavior of kubernetes 1.16 an earlier
// where if the exact ResourceVersion requested is not available for a List request for a non-zero ResourceVersion,
// an "Expired" error is returned if the ResourceVersion has expired (etcd has compacted it).
// (In kubernetes 1.17, or when the watch cache is enabled, the List will instead return the list that is no older than
// the requested ResourceVersion).
func TestReflectorExpiredExactResourceVersion(t *testing.T) { … }

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

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

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

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

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

type storeWithRV …

func (s *storeWithRV) UpdateResourceVersion(resourceVersion string) { … }

func newStoreWithRV() *storeWithRV { … }

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

const fakeItemsNum …

const exemptObjectIndex …

const pageNum …

func getPodListItems(start int, numItems int) (string, string, *v1.PodList) { … }

func getConfigmapListItems(start int, numItems int) (string, string, *v1.ConfigMapList) { … }

type TestPagingPodsLW …

func newPageTestLW(totalPageNum int) *TestPagingPodsLW { … }

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

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

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

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

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

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

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

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