func RunTestWatch(ctx context.Context, t *testing.T, store storage.Interface) { … }
func testWatch(ctx context.Context, t *testing.T, store storage.Interface, recursive bool) { … }
func RunTestWatchFromZero(ctx context.Context, t *testing.T, store storage.Interface, compaction Compaction) { … }
func RunTestDeleteTriggerWatch(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatchFromNonZero(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestDelayedWatchDelivery(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatchError(ctx context.Context, t *testing.T, store InterfaceWithPrefixTransformer) { … }
func RunTestWatchContextCancel(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatcherTimeout(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatchDeleteEventObjectHaveLatestRV(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatchInitializationSignal(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunOptionalTestProgressNotify(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestClusterScopedWatch(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestNamespaceScopedWatch(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunTestWatchDispatchBookmarkEvents(ctx context.Context, t *testing.T, store storage.Interface, expectedWatchBookmarks bool) { … }
func RunTestOptionalWatchBookmarksWithCorrectResourceVersion(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunSendInitialEventsBackwardCompatibility(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunWatchSemantics(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunWatchSemanticInitialEventsExtended(ctx context.Context, t *testing.T, store storage.Interface) { … }
func RunWatchListMatchSingle(ctx context.Context, t *testing.T, store storage.Interface) { … }
func makePod(namePrefix string) *example.Pod { … }
type testWatchStruct …
func createPodPredicate(field fields.Selector, namespaceScoped bool, indexField []string) storage.SelectionPredicate { … }
func determinePodGetAttrFunc(namespaceScoped bool, indexField []string) storage.AttrFunc { … }
func namespacedScopedNodeNameAttrFunc(obj runtime.Object) (labels.Set, fields.Set, error) { … }
func clusterScopedNodeNameAttrFunc(obj runtime.Object) (labels.Set, fields.Set, error) { … }
func basePod(podName string) *example.Pod { … }
func basePodUpdated(podName string) *example.Pod { … }
func basePodAssigned(podName, nodeName string) *example.Pod { … }
func baseNamespacedPod(podName, namespace string) *example.Pod { … }
func baseNamespacedPodUpdated(podName, namespace string) *example.Pod { … }
func baseNamespacedPodAssigned(podName, namespace, nodeName string) *example.Pod { … }