github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-17 20:00:07 +00:00
Code Issues Projects Releases Wiki Activity

client-go testing: include event handler in List+Watch unit test

Browse Source 
The event handler must receive both object (the initial one from List, the
newer one from Watch) and it must be considered synced.
This commit is contained in:
Patrick Ohly
2026-01-14 11:57:24 +01:00
parent 6bfa727bee
commit 359aff0552
1 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
staging/src/k8s.io/client-go/testing/internal/listandwatch_test.go
View File

@@ -84,6 +84,17 @@ func testListAndWatch(t *testing.T) {
}, client), &v1.ConfigMap{}, defaultEventHandlerResyncPeriod, nil)
})
var adds, updates, deletes int
handle, err := configMapInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(_ any) { adds++ },
UpdateFunc: func(_, _ any) { updates++ },
DeleteFunc: func(_ any) { deletes++ },
})
if err != nil {
t.Fatalf("Unexpected error adding event handler: %v", err)
}
defer configMapInformer.RemoveEventHandler(handle)
configMapStore := configMapInformer.GetStore()
f.Start(stopCh)
f.WaitForCacheSync(stopCh)
@@ -100,7 +111,7 @@ func testListAndWatch(t *testing.T) {
Namespace: "default",
},
}
_, err := client.CoreV1().ConfigMaps(cm.Namespace).Create(ctx, cm, metav1.CreateOptions{})
_, err = client.CoreV1().ConfigMaps(cm.Namespace).Create(ctx, cm, metav1.CreateOptions{})
if err != nil {
t.Fatalf("Unexpected error creating ConfigMap: %v", err)
}
@@ -112,6 +123,13 @@ func testListAndWatch(t *testing.T) {
objs = configMapStore.List()
if len(objs) != 2 {
t.Fatalf("Unexpected item(s) in informer cache, want 2, got %d = %v", len(objs), objs)
t.Errorf("Unexpected item(s) in informer cache, want 2, got %d = %v", len(objs), objs)
}
if !handle.HasSynced() {
t.Error("Expected event handler to have synced, it didn't")
}
if adds != 2 || updates != 0 || deletes != 0 {
t.Errorf("Expected two new objects, got adds/updates/deletes %d/%d/%d", adds, updates, deletes)
}
}