kubernetes/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

func init() { … }

// GetPodAttrs returns labels and fields of a given object for filtering purposes.
func GetPodAttrs(obj runtime.Object) (labels.Set, fields.Set, error) { … }

// PodToSelectableFields returns a field set that represents the object
// TODO: fields are not labels, and the validation rules for them do not apply.
func PodToSelectableFields(pod *example.Pod) fields.Set { … }

func AddObjectMetaFieldsSet(source fields.Set, objectMeta *metav1.ObjectMeta, hasNamespaceField bool) fields.Set { … }

func checkStorageInvariants(ctx context.Context, t *testing.T, key string) { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func checkStorageCalls(t *testing.T, pageSize, estimatedProcessedObjects uint64) { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type tearDownFunc …

type setupOptions …

type setupOption …

func withDefaults(options *setupOptions) { … }

func withClusterScopedKeyFunc(options *setupOptions) { … }

func withSpecNodeNameIndexerFuncs(options *setupOptions) { … }

func testSetup(t *testing.T, opts ...setupOption) (context.Context, *Cacher, tearDownFunc) { … }

func testSetupWithEtcdServer(t testing.TB, opts ...setupOption) (context.Context, *Cacher, *etcd3testing.EtcdTestServer, tearDownFunc) { … }

func testSetupWithEtcdAndCreateWrapper(t *testing.T, opts ...setupOption) (storage.Interface, tearDownFunc) { … }

type createWrapper …

func (c *createWrapper) Create(ctx context.Context, key string, obj, out runtime.Object, ttl uint64) error { … }

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

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