Function TestReaderWaitsForCacheSync

pkg/cache/cache_test.go:2670–2725

(t *testing.T)

}

func TestReaderWaitsForCacheSync(t *testing.T) {
	t.Parallel()
	for _, readerFailOnMissingInformer := range []bool{true, false} {
		t.Run(fmt.Sprintf("ReaderFailOnMissingInformer=%v", readerFailOnMissingInformer), func(t *testing.T) {
			t.Parallel()
			synctest.Test(t, func(t *testing.T) {
				g := NewWithT(t)

				fakeInformer := controllertest.NewFakeInformer()
				c, err := cache.New(&rest.Config{}, cache.Options{
					ReaderFailOnMissingInformer: readerFailOnMissingInformer,
					Mapper:                      &fakeRESTMapper{},
					NewInformer: func(kcache.ListerWatcher, runtime.Object, time.Duration, kcache.Indexers) kcache.SharedIndexInformer {
						return fakeInformer
					},
				})
				g.Expect(err).NotTo(HaveOccurred())

				ctx, cancel := context.WithCancel(t.Context())
				defer cancel()
				cacheDone := make(chan struct{})
				go func() {
					g.Expect(c.Start(ctx)).To(Succeed())
					close(cacheDone)
				}()
				synctest.Wait() // Let the cache finish starting
				_, err = c.GetInformer(ctx, &corev1.Service{}, cache.BlockUntilSynced(false))
				g.Expect(err).ToNot(HaveOccurred())

				listCtx, listCtxCancel := context.WithTimeout(ctx, time.Second)
				defer listCtxCancel()
				services := &corev1.ServiceList{}
				err = c.List(listCtx, services)
				g.Expect(err).To(HaveOccurred())
				g.Expect(apierrors.IsTimeout(err)).To(BeTrue())

				getCtx, getCtxCancel := context.WithTimeout(ctx, time.Second)
				defer getCtxCancel()
				err = c.Get(getCtx, client.ObjectKey{Name: "default", Namespace: "kubernetes"}, &corev1.Service{})
				g.Expect(err).To(HaveOccurred())
				g.Expect(apierrors.IsTimeout(err)).To(BeTrue())

				fakeInformer.Synced()

				g.Expect(c.List(ctx, services)).To(Succeed())

				err = c.Get(getCtx, client.ObjectKey{Name: "default", Namespace: "kubernetes"}, &corev1.Service{})
				g.Expect(err).To(HaveOccurred())
				g.Expect(apierrors.IsNotFound(err)).To(BeTrue())

				cancel()
				<-cacheDone
			})
		})
	}
}

func TestIndexFieldDoesNotBlock(t *testing.T) {