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) {}