"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "tests/integration/clientv3/watch_test.go" between
etcd-3.5.5.tar.gz and etcd-3.5.6.tar.gz

About: etcd is a distributed reliable key-value store for the most critical data of a distributed system (written in "Go").

watch_test.go  (etcd-3.5.5)	:	watch_test.go  (etcd-3.5.6)
skipping to change at line 343		skipping to change at line 343
if _, err := wctx.kv.Put(context.TODO(), key, val); err != nil {		if _, err := wctx.kv.Put(context.TODO(), key, val); err != nil {
t.Fatal(err)		t.Fatal(err)
}		}
select {		select {
case <-time.After(5 * time.Second):		case <-time.After(5 * time.Second):
t.Fatalf("watch timed out")		t.Fatalf("watch timed out")
case v, ok := <-wctx.ch:		case v, ok := <-wctx.ch:
if !ok {		if !ok {
t.Fatalf("unexpected watch close")		t.Fatalf("unexpected watch close")
}		}
		if err := v.Err(); err != nil {
		t.Fatalf("unexpected watch response error: %v", err)
		}
if string(v.Events[0].Kv.Value) != val {		if string(v.Events[0].Kv.Value) != val {
t.Fatalf("bad value got %v, wanted %v", v.Events[0].Kv.Va lue, val)		t.Fatalf("bad value got %v, wanted %v", v.Events[0].Kv.Va lue, val)
}		}
}		}
}		}
func TestWatchResumeInitRev(t *testing.T) {		func TestWatchResumeInitRev(t *testing.T) {
integration.BeforeTest(t)		integration.BeforeTest(t)
clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 1, U seBridge: true})		clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 1, U seBridge: true})
defer clus.Terminate(t)		defer clus.Terminate(t)
End of changes. 1 change blocks.
0 lines changed or deleted		3 lines changed or added

---