kubernetes/staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

var scheme …

var codecs …

const defaultTestPrefix …

func init() { … }

func newPod() runtime.Object { … }

func newPodList() runtime.Object { … }

func checkStorageInvariants(etcdClient *clientv3.Client, codec runtime.Codec) storagetesting.KeyValidation { … }

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 TestGetListNonRecursive(t *testing.T) { … }

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

type storeWithPrefixTransformer …

func (s *storeWithPrefixTransformer) UpdatePrefixTransformer(modifier storagetesting.PrefixTransformerModifier) func() { … }

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 TestList(t *testing.T) { … }

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

func checkStorageCallsInvariants(transformer *storagetesting.PrefixTransformer, recorder *clientRecorder) storagetesting.CallsValidation { … }

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

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

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

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

func compactStorage(etcdClient *clientv3.Client) storagetesting.Compaction { … }

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

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

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

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

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

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

func newTestLeaseManagerConfig() LeaseManagerConfig { … }

func newTestTransformer() value.Transformer { … }

type clientRecorder …

func (r *clientRecorder) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { … }

func (r *clientRecorder) GetReadsAndReset() uint64 { … }

type setupOptions …

type setupOption …

func withClientConfig(config *embed.Config) setupOption { … }

func withPrefix(prefix string) setupOption { … }

func withLeaseConfig(leaseConfig LeaseManagerConfig) setupOption { … }

func withRecorder() setupOption { … }

func withDefaults(options *setupOptions) { … }

var _ …

func testSetup(t testing.TB, opts ...setupOption) (context.Context, *store, *kubernetes.Client) { … }

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

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

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

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

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

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