github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 18:00:08 +00:00
Code Issues Projects Releases Wiki Activity

pkg/storage/testing/watcher_tests: RunWatchSemantics checks if the storage has been primed with init data

Browse Source
This commit is contained in:
Lukasz Szaszkiewicz 2024-09-20 09:37:53 +02:00
parent de735be512
commit e7e2123feb
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
View File

@ -1460,6 +1460,21 @@ func RunWatchSemantics(ctx context.Context, t *testing.T, store storage.Interfac
createdPods = append(createdPods, out) createdPods = append(createdPods, out)
} }
if len(createdPods) > 0 {
// this list call ensures that the cache has seen the created pods.
// this makes the watch request below deterministic.
listObject := &example.PodList{}
opts := storage.ListOptions{
Predicate: storage.Everything,
Recursive: true,
ResourceVersion: createdPods[len(createdPods)-1].ResourceVersion,
ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
}
err := store.GetList(ctx, fmt.Sprintf("/pods/%s", ns), opts, listObject)
require.NoError(t, err)
require.Len(t, listObject.Items, len(createdPods))
}
if scenario.useCurrentRV { if scenario.useCurrentRV {
currentStorageRV, err := storage.GetCurrentResourceVersionFromStorage(ctx, store, func() runtime.Object { return &example.PodList{} }, "/pods", "") currentStorageRV, err := storage.GetCurrentResourceVersionFromStorage(ctx, store, func() runtime.Object { return &example.PodList{} }, "/pods", "")
require.NoError(t, err) require.NoError(t, err)