Explorar o código

integration: check Canceled is true in compacted watch response

Anthony Romano %!s(int64=8) %!d(string=hai) anos
pai
achega
ebcfdd1a3d
Modificáronse 1 ficheiros con 3 adicións e 0 borrados
  1. 3 0
      clientv3/integration/watch_test.go

+ 3 - 0
clientv3/integration/watch_test.go

@@ -514,6 +514,9 @@ func TestWatchCompactRevision(t *testing.T) {
 	if wresp.Err() != rpctypes.ErrCompacted {
 		t.Fatalf("wresp.Err() expected %v, but got %v", rpctypes.ErrCompacted, wresp.Err())
 	}
+	if !wresp.Canceled {
+		t.Fatalf("wresp.Canceled expected true, got %+v", wresp)
+	}
 
 	// ensure the channel is closed
 	if wresp, ok = <-wch; ok {