func RunTestWatch(ctx context.Context, t *testing.T, store storage.Interface) { … } // It tests that // - first occurrence of objects should notify Add event // - update should trigger Modified event // - update that gets filtered should trigger Deleted event func testWatch(ctx context.Context, t *testing.T, store storage.Interface, recursive bool) { … } // RunTestWatchFromZero tests that // - watch from 0 should sync up and grab the object added before // - For testing with etcd, watch from 0 is able to return events for objects // whose previous version has been compacted. If testing with cacher, we // expect compaction to be nil. 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) { … } // 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 RunOptionalTestProgressNotify(ctx context.Context, t *testing.T, store storage.Interface) { … } // It tests watches of cluster-scoped resources. func RunTestClusterScopedWatch(ctx context.Context, t *testing.T, store storage.Interface) { … } // It tests watch of namespace-scoped resources. func RunTestNamespaceScopedWatch(ctx context.Context, t *testing.T, store storage.Interface) { … } // RunOptionalTestWatchDispatchBookmarkEvents tests whether bookmark events are sent. // This feature is currently implemented in watch cache layer, so this is optional. // // TODO(#109831): ProgressNotify feature is effectively implementing the same // // functionality, so we should refactor this functionality to share the same input. func RunTestWatchDispatchBookmarkEvents(ctx context.Context, t *testing.T, store storage.Interface, expectedWatchBookmarks bool) { … } // RunOptionalTestWatchBookmarksWithCorrectResourceVersion tests whether bookmark events are // sent with correct resource versions. // This feature is currently implemented in watch cache layer, so this is optional. // // TODO(#109831): ProgressNotify feature is effectively implementing the same // // functionality, so we should refactor this functionality to share the same input. func RunTestOptionalWatchBookmarksWithCorrectResourceVersion(ctx context.Context, t *testing.T, store storage.Interface) { … } // RunSendInitialEventsBackwardCompatibility test backward compatibility // when SendInitialEvents option is set against various implementations. // Backward compatibility is defined as RV = "" || RV = "O" and AllowWatchBookmark is set to false. // In that case we expect a watch request to be established. func RunSendInitialEventsBackwardCompatibility(ctx context.Context, t *testing.T, store storage.Interface) { … } // RunWatchSemantics test the following cases: // // +-----------------+---------------------+-------------------+ // | ResourceVersion | AllowWatchBookmarks | SendInitialEvents | // +=================+=====================+===================+ // | Unset | true/false | true/false | // | 0 | true/false | true/false | // | 1 | true/false | true/false | // | Current | true/false | true/false | // +-----------------+---------------------+-------------------+ // where: // - false indicates the value of the param was set to "false" by a test case // - true indicates the value of the param was set to "true" by a test case func RunWatchSemantics(ctx context.Context, t *testing.T, store storage.Interface) { … } // RunWatchSemanticInitialEventsExtended checks if the bookmark event // marking the end of the list stream contains the global RV. // // note that this scenario differs from the one in RunWatchSemantics // by adding the pod to a different ns to advance the global RV 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 { … }
Codebase Browser
kubernetes