kubernetes/test/integration/apiserver/watchcache_test.go

// setup create kube-apiserver backed up by two separate etcds,
// with one of them containing events and the other all other objects.
func multiEtcdSetup(ctx context.Context, t *testing.T) (clientset.Interface, framework.TearDownFunc) { … }

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

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