testing

Documentation

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, ...)
• 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, ...)
• 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)
• func RunTestListContinuation(ctx context.Context, t *testing.T, store storage.Interface, ...)
• func RunTestListContinuationWithFilter(ctx context.Context, t *testing.T, store storage.Interface, ...)
• func RunTestListInconsistentContinuation(ctx context.Context, t *testing.T, store storage.Interface, ...)
• func RunTestListPaginationRareObject(ctx context.Context, t *testing.T, store storage.Interface, ...)
• 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, ...)
• func RunTestWatchInitializationSignal(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

Functions

func CreateList

func CreateList(prefix string, helper storage.Interface, list runtime.Object) error

CreateList will properly create a list using the storage interface.

func CreateObjList

func CreateObjList(prefix string, helper storage.Interface, items []runtime.Object) error

CreateObjList will create a list from the array of objects.

func DeepEqualSafePodSpec

func DeepEqualSafePodSpec() example.PodSpec

DeepEqualSafePodSpec returns an example.PodSpec safe for deep-equal operations.

func ExpectContains

func ExpectContains(t *testing.T, msg string, expectedList []interface{}, got interface{})

func ExpectNoDiff

func ExpectNoDiff(t *testing.T, msg string, expected, got interface{})

func RunOptionalTestProgressNotify

func RunOptionalTestProgressNotify(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestConditionalDelete(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestConsistentList

func RunTestConsistentList(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer)

func RunTestCount

func RunTestCount(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestCreate

func RunTestCreate(ctx context.Context, t *testing.T, store storage.Interface, validation KeyValidation)

func RunTestCreateWithKeyExist

func RunTestCreateWithKeyExist(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestCreateWithTTL

func RunTestCreateWithTTL(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestDeleteTriggerWatch

func RunTestDeleteTriggerWatch(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestDeleteWithSuggestion

func RunTestDeleteWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestGet(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestGetListNonRecursive

func RunTestGetListNonRecursive(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestGuaranteedUpdateWithTTL(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestList

func RunTestList(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestListWithoutPaging(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestUnconditionalDelete(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestValidateDeletionWithSuggestion

func RunTestValidateDeletionWithSuggestion(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestWatch

func RunTestWatch(ctx context.Context, t *testing.T, store storage.Interface)

func RunTestWatchContextCancel

func RunTestWatchContextCancel(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestWatchFromNoneZero(ctx context.Context, t *testing.T, store storage.Interface)

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 RunTestWatchInitializationSignal(ctx context.Context, t *testing.T, store storage.Interface)

Types

type CallsValidation

type CallsValidation func(t *testing.T, pageSize, estimatedProcessedObjects uint64)

type Compaction

type Compaction func(ctx context.Context, t *testing.T, resourceVersion string)

type InterfaceWithPrefixTransformer

type InterfaceWithPrefixTransformer interface {
	storage.Interface

	UpdatePrefixTransformer(PrefixTransformerModifier) func()
}

type KeyValidation

type KeyValidation func(ctx context.Context, t *testing.T, key string)

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