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

storage/testing/utils: add helper functions

Browse Source
This commit is contained in:
Lukasz Szaszkiewicz 2023-09-15 12:26:11 +02:00
parent bad6b29b9b
commit 3a96baf3fa
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
View File

@ -187,6 +187,29 @@ func testCheckStop(t *testing.T, w watch.Interface) {
} }
} }
func testCheckResultsInStrictOrder(t *testing.T, w watch.Interface, expectedEvents []watch.Event) {
for _, expectedEvent := range expectedEvents {
testCheckResult(t, w, expectedEvent)
}
}
func testCheckResultsInRandomOrder(t *testing.T, w watch.Interface, expectedEvents []watch.Event) {
for range expectedEvents {
testCheckResultFunc(t, w, func(actualEvent watch.Event) {
ExpectContains(t, "unexpected event", toInterfaceSlice(expectedEvents), actualEvent)
})
}
}
func testCheckNoMoreResults(t *testing.T, w watch.Interface) {
select {
case e := <-w.ResultChan():
t.Errorf("Unexpected: %#v event received, expected no events", e)
case <-time.After(time.Second):
return
}
}
func toInterfaceSlice[T any](s []T) []interface{} { func toInterfaceSlice[T any](s []T) []interface{} {
result := make([]interface{}, len(s)) result := make([]interface{}, len(s))
for i, v := range s { for i, v := range s {