kubernetes/pkg/scheduler/util/assumecache/assume_cache_test.go

type testInformer …

func (i *testInformer) AddEventHandler(handler cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error) { … }

func (i *testInformer) add(obj interface{ … }

func (i *testInformer) update(obj interface{ … }

func (i *testInformer) delete(obj interface{ … }

func makeObj(name, version, namespace string) metav1.Object { … }

func newTest(t *testing.T) (ktesting.TContext, *AssumeCache, *testInformer) { … }

func newTestWithIndexer(t *testing.T, indexName string, indexFunc cache.IndexFunc) (ktesting.TContext, *AssumeCache, *testInformer) { … }

func verify(tCtx ktesting.TContext, cache *AssumeCache, key string, expectedObject, expectedAPIObject interface{ … }

func verifyList(tCtx ktesting.TContext, assumeCache *AssumeCache, expectedObjs []interface{ … }

type mockEventHandler …

type event …

func (m *mockEventHandler) OnAdd(obj interface{ … }

func (m *mockEventHandler) OnUpdate(oldObj, obj interface{ … }

func (m *mockEventHandler) OnDelete(obj interface{ … }

func (m *mockEventHandler) verifyAndFlush(tCtx ktesting.TContext, expectedEvents []event) { … }

func (m *mockEventHandler) sortEvents(cmp func(objI, objJ interface{ … }

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

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

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

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

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

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

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