kubernetes/test/integration/apimachinery/watchlist_test.go

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

// TODO(#115478): refactor with e2e/apimachinery/watchlist
func verifyStore(t *testing.T, ctx context.Context, clientSet kubernetes.Interface, store cache.Store, namespace *v1.Namespace) { … }

type byName …

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

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

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

func newSecret(name string) *v1.Secret { … }

type wrappedStore …

func (s *wrappedStore) Replace(items []interface{ … }

func (s *wrappedStore) setCancelOnReplace(ctxCancel context.CancelFunc) { … }

type wrappedListWatch …

func (lw *wrappedListWatch) SetClient(ctx context.Context, clientSet kubernetes.Interface, ns *v1.Namespace) { … }