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

type testListener …

func newTestListener(name string, resyncPeriod time.Duration, expected ...string) *testListener { … }

func (l *testListener) OnAdd(obj interface{ … }

func (l *testListener) OnUpdate(old, new interface{ … }

func (l *testListener) OnDelete(obj interface{ … }

func (l *testListener) handle(obj interface{ … }

func (l *testListener) ok() bool { … }

func (l *testListener) satisfiedExpectations() bool { … }

func eventHandlerCount(i SharedInformer) int { … }

func isStarted(i SharedInformer) bool { … }

func isRegistered(i SharedInformer, h ResourceEventHandlerRegistration) bool { … }

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

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

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

// verify that https://github.com/kubernetes/kubernetes/issues/59822 is fixed
func TestSharedInformerInitializationRace(t *testing.T) { … }

// TestSharedInformerWatchDisruption simulates a watch that was closed
// with updates to the store during that time. We ensure that handlers with
// resync and no resync see the expected state.
func TestSharedInformerWatchDisruption(t *testing.T) { … }

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

// TestSharedInformerStartRace is a regression test to ensure there is no race between
// Run and SetWatchErrorHandler, and Run and SetTransform.
func TestSharedInformerStartRace(t *testing.T) { … }

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

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

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

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

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

// Shows that many concurrent goroutines can be manipulating shared informer
// listeners without tripping it up. There are not really many assertions in this
// test. Meant to be run with -race to find race conditions
func TestSharedInformerHandlerAbuse(t *testing.T) { … }

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

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

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

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

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