fix watch keyspace (tikv#6528)

close tikv#6527 Signed-off-by: AmoebaProtozoa <8039876+AmoebaProtozoa@users.noreply.github.com>
rleungx · Aug 2, 2023 · 558037e · 558037e
1 parent 1fbd6f5
commit 558037e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/keyspace_service.go b/server/keyspace_service.go
@@ -74,7 +74,7 @@ func (s *KeyspaceServer) WatchKeyspaces(request *keyspacepb.WatchKeyspacesReques
 	}
 	ctx, cancel := context.WithCancel(s.Context())
 	defer cancel()
-	startKey := path.Join(s.rootPath, endpoint.KeyspaceMetaPrefix())
+	startKey := path.Join(s.rootPath, endpoint.KeyspaceMetaPrefix()) + "/"
 
 	keyspaces := make([]*keyspacepb.KeyspaceMeta, 0)
 	putFn := func(kv *mvccpb.KeyValue) error {
@@ -106,7 +106,7 @@ func (s *KeyspaceServer) WatchKeyspaces(request *keyspacepb.WatchKeyspacesReques
 		putFn,
 		deleteFn,
 		postEventFn,
-		clientv3.WithPrefix(),
+		clientv3.WithRange(clientv3.GetPrefixRangeEnd(startKey)),
 	)
 	s.serverLoopWg.Add(1)
 	go watcher.StartWatchLoop()