Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

tests: add comments for clientv3test.TestWatchResumeInitRev

Browse Source 
Signed-off-by: Jin Dong <greenmoon55@gmail.com>
This commit is contained in:
greenmoon55 2023-11-08 00:00:23 -06:00 committed by Jin Dong
parent 7e00a1e42b
commit 00ce0116c5
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/clientv3/watch_test.go
View File

@ -350,6 +350,8 @@ func putAndWatch(t *testing.T, wctx *watchctx, key, val string) {
}
}
// TestWatchResumeInitRev tests watch resume with disconnect before the first event.
// It ensures that correct events are returned corresponding to the start revision.
func TestWatchResumeInitRev(t *testing.T) {
integration2.BeforeTest(t)
clus := integration2.NewCluster(t, &integration2.ClusterConfig{Size: 1, UseBridge: true})
@ -367,7 +369,10 @@ func TestWatchResumeInitRev(t *testing.T) {
t.Fatal(err)
}
// watch from revision 1
wch := clus.Client(0).Watch(context.Background(), "a", clientv3.WithRev(1), clientv3.WithCreatedNotify())
// response for the create watch request, no events are in this response
// the current revision of etcd should be 4
if resp, ok := <-wch; !ok || resp.Header.Revision != 4 {
t.Fatalf("got (%v, %v), expected create notification rev=4", resp, ok)
}
@ -392,6 +397,7 @@ func TestWatchResumeInitRev(t *testing.T) {
if len(resp.Events) == 0 {
t.Fatal("expected event on watch")
}
// Events should be put(a, 3) and put(a, 4)
if string(resp.Events[0].Kv.Value) != "3" {
t.Fatalf("expected value=3, got event %+v", resp.Events[0])
}