package consistencydetector

import "k8s.io/client-go/util/consistencydetector"

Index ¶

• func CheckDataConsistency[T runtime.Object, U any](ctx context.Context, identity string, lastSyncedResourceVersion string, listFn ListFunc[T], listItemTransformFunc TransformFunc, listOptions metav1.ListOptions, retrieveItemsFn RetrieveItemsFunc[U])
• func IsDataConsistencyDetectionForWatchListEnabled() bool
• func SetDataConsistencyDetectionForWatchListEnabledForTest(enabled bool) func()
• type ListFunc
• type RetrieveItemsFunc
• type TransformFunc

Functions ¶

func CheckDataConsistency ¶

func CheckDataConsistency[T runtime.Object, U any](ctx context.Context, identity string, lastSyncedResourceVersion string, listFn ListFunc[T], listItemTransformFunc TransformFunc, listOptions metav1.ListOptions, retrieveItemsFn RetrieveItemsFunc[U])

CheckDataConsistency exists solely for testing purposes. we cannot use checkWatchListDataConsistencyIfRequested because it is guarded by an environmental variable. we cannot manipulate the environmental variable because it will affect other tests in this package.

func IsDataConsistencyDetectionForWatchListEnabled ¶

func IsDataConsistencyDetectionForWatchListEnabled() bool

IsDataConsistencyDetectionForWatchListEnabled returns true when the KUBE_WATCHLIST_INCONSISTENCY_DETECTOR environment variable was set during a binary startup.

func SetDataConsistencyDetectionForWatchListEnabledForTest ¶

func SetDataConsistencyDetectionForWatchListEnabledForTest(enabled bool) func()

SetDataConsistencyDetectionForWatchListEnabledForTest allows to enable/disable data consistency detection for testing purposes. It returns a function that restores the original value.

Types ¶

type ListFunc ¶

type ListFunc[T runtime.Object] func(ctx context.Context, options metav1.ListOptions) (T, error)

type RetrieveItemsFunc ¶

type RetrieveItemsFunc[U any] func() []U

type TransformFunc ¶

type TransformFunc func(interface{}) (interface{}, error)

Source Files ¶

data_consistency_detector.go