package testing
import "k8s.io/apiserver/pkg/storage/testing"
Index ¶
- func CreateList(prefix string, helper storage.Interface, list runtime.Object) error
- func CreateObjList(prefix string, helper storage.Interface, items []runtime.Object) error
- func DeepEqualSafePodSpec() example.PodSpec
- func ExpectContains(t *testing.T, msg string, expectedList []interface{}, got interface{})
- func ExpectNoDiff(t *testing.T, msg string, expected, got interface{})
- func RunOptionalTestProgressNotify(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestConditionalDelete(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestConsistentList(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
- func RunTestCount(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestCreate(ctx context.Context, t *testing.T, store storage.Interface, validation KeyValidation)
- func RunTestCreateWithKeyExist(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestCreateWithTTL(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestDeleteTriggerWatch(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestDeleteWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestDeleteWithSuggestionAndConflict(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestDeleteWithSuggestionOfDeletedObject(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestGet(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestGetListNonRecursive(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestGuaranteedUpdate(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer, validation KeyValidation)
- func RunTestGuaranteedUpdateChecksStoredData(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
- func RunTestGuaranteedUpdateWithConflict(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestGuaranteedUpdateWithSuggestionAndConflict(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestGuaranteedUpdateWithTTL(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestList(ctx context.Context, t *testing.T, store storage.Interface, ignoreWatchCacheTests bool)
- func RunTestListContinuation(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
- func RunTestListContinuationWithFilter(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
- func RunTestListInconsistentContinuation(ctx context.Context, t *testing.T, store storage.Interface, compaction Compaction)
- func RunTestListPaginationRareObject(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
- func RunTestListWithoutPaging(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestPreconditionalDeleteWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestTransformationFailure(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
- func RunTestUnconditionalDelete(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestValidateDeletionWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestWatch(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestWatchContextCancel(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestWatchDeleteEventObjectHaveLatestRV(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestWatchError(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
- func RunTestWatchFromNoneZero(ctx context.Context, t *testing.T, store storage.Interface)
- func RunTestWatchFromZero(ctx context.Context, t *testing.T, store storage.Interface, compaction Compaction)
- func RunTestWatchInitializationSignal(ctx context.Context, t *testing.T, store storage.Interface)
- func TestClusterScopedWatch(ctx context.Context, t *testing.T, store storage.Interface)
- func TestNamespaceScopedWatch(ctx context.Context, t *testing.T, store storage.Interface)
- type CallsValidation
- type Compaction
- type InterfaceWithPrefixTransformer
- type KeyValidation
- type PrefixTransformer
- func NewPrefixTransformer(prefix []byte, stale bool) *PrefixTransformer
- func (p *PrefixTransformer) GetReadsAndReset() uint64
- func (p *PrefixTransformer) TransformFromStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, bool, error)
- func (p *PrefixTransformer) TransformToStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, error)
- type PrefixTransformerModifier
- type StorageInjectingListErrors
Functions ¶
func CreateList ¶
CreateList will properly create a list using the storage interface.
func CreateObjList ¶
CreateObjList will create a list from the array of objects.
func DeepEqualSafePodSpec ¶
DeepEqualSafePodSpec returns an example.PodSpec safe for deep-equal operations.
func ExpectContains ¶
func ExpectNoDiff ¶
func RunOptionalTestProgressNotify ¶
RunOptionalTestProgressNotify tests ProgressNotify feature of ListOptions. Given this feature is currently not explicitly used by higher layers of Kubernetes (it rather is used by wrappers of storage.Interface to implement its functionalities) this test is currently considered optional.
func RunTestConditionalDelete ¶
func RunTestConsistentList ¶
func RunTestConsistentList(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
func RunTestCount ¶
func RunTestCreate ¶
func RunTestCreate(ctx context.Context, t *testing.T, store storage.Interface, validation KeyValidation)
func RunTestCreateWithKeyExist ¶
func RunTestCreateWithTTL ¶
func RunTestDeleteTriggerWatch ¶
func RunTestDeleteWithSuggestion ¶
func RunTestDeleteWithSuggestionAndConflict ¶
func RunTestDeleteWithSuggestionAndConflict(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestDeleteWithSuggestionOfDeletedObject ¶
func RunTestDeleteWithSuggestionOfDeletedObject(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestGet ¶
func RunTestGetListNonRecursive ¶
func RunTestGuaranteedUpdate ¶
func RunTestGuaranteedUpdate(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer, validation KeyValidation)
func RunTestGuaranteedUpdateChecksStoredData ¶
func RunTestGuaranteedUpdateChecksStoredData(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
func RunTestGuaranteedUpdateWithConflict ¶
func RunTestGuaranteedUpdateWithConflict(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestGuaranteedUpdateWithSuggestionAndConflict ¶
func RunTestGuaranteedUpdateWithSuggestionAndConflict(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestGuaranteedUpdateWithTTL ¶
func RunTestList ¶
func RunTestList(ctx context.Context, t *testing.T, store storage.Interface, ignoreWatchCacheTests bool)
func RunTestListContinuation ¶
func RunTestListContinuation(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
func RunTestListContinuationWithFilter ¶
func RunTestListContinuationWithFilter(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
func RunTestListInconsistentContinuation ¶
func RunTestListInconsistentContinuation(ctx context.Context, t *testing.T, store storage.Interface, compaction Compaction)
func RunTestListPaginationRareObject ¶
func RunTestListPaginationRareObject(ctx context.Context, t *testing.T, store storage.Interface, validation CallsValidation)
func RunTestListWithoutPaging ¶
func RunTestPreconditionalDeleteWithSuggestion ¶
func RunTestPreconditionalDeleteWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestTransformationFailure ¶
func RunTestTransformationFailure(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
func RunTestUnconditionalDelete ¶
func RunTestValidateDeletionWithSuggestion ¶
func RunTestValidateDeletionWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestWatch ¶
func RunTestWatchContextCancel ¶
func RunTestWatchDeleteEventObjectHaveLatestRV ¶
func RunTestWatchDeleteEventObjectHaveLatestRV(ctx context.Context, t *testing.T, store storage.Interface)
func RunTestWatchError ¶
func RunTestWatchError(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)
func RunTestWatchFromNoneZero ¶
func RunTestWatchFromZero ¶
func RunTestWatchFromZero(ctx context.Context, t *testing.T, store storage.Interface, compaction Compaction)
RunTestWatchFromZero tests that - watch from 0 should sync up and grab the object added before - watch from 0 is able to return events for objects whose previous version has been compacted
func RunTestWatchInitializationSignal ¶
func TestClusterScopedWatch ¶
It tests watches of cluster-scoped resources.
func TestNamespaceScopedWatch ¶
It tests watch of namespace-scoped resources.
Types ¶
type CallsValidation ¶
type Compaction ¶
type InterfaceWithPrefixTransformer ¶
type InterfaceWithPrefixTransformer interface {
storage.Interface
UpdatePrefixTransformer(PrefixTransformerModifier) func()
}
type KeyValidation ¶
type PrefixTransformer ¶
type PrefixTransformer struct {
// contains filtered or unexported fields
}
PrefixTransformer adds and verifies that all data has the correct prefix on its way in and out.
func NewPrefixTransformer ¶
func NewPrefixTransformer(prefix []byte, stale bool) *PrefixTransformer
func (*PrefixTransformer) GetReadsAndReset ¶
func (p *PrefixTransformer) GetReadsAndReset() uint64
func (*PrefixTransformer) TransformFromStorage ¶
func (p *PrefixTransformer) TransformFromStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, bool, error)
func (*PrefixTransformer) TransformToStorage ¶
func (p *PrefixTransformer) TransformToStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, error)
type PrefixTransformerModifier ¶
type PrefixTransformerModifier func(*PrefixTransformer) value.Transformer
type StorageInjectingListErrors ¶
type StorageInjectingListErrors struct {
storage.Interface
Errors int
// contains filtered or unexported fields
}
StorageInjectingListErrors injects a dummy error for first N GetList calls.
func (*StorageInjectingListErrors) ErrorsConsumed ¶
func (s *StorageInjectingListErrors) ErrorsConsumed() (bool, error)
func (*StorageInjectingListErrors) GetList ¶
func (s *StorageInjectingListErrors) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error
Source Files ¶
store_tests.go utils.go watcher_tests.go
- Version
- v0.27.14
- Published
- May 15, 2024
- Platform
- windows/amd64
- Imports
- 32 packages
- Last checked
- 2 seconds ago –
Tools for package owners.