feat: Query ctx snapshots (#212)

* feat: seq_snapshots field for query context * chore: make * chore: comment * refactor: new type * chore: rename * chore: not fmt stuff
2025-02-06 15:19:12 +08:00
parent 683e9d10ae
commit b5d172fe61
5 changed files with 2277 additions and 445 deletions
@@ -26,6 +26,14 @@ message QueryContext {
  string timezone = 4;
  map<string, string> extensions = 5;
  uint32 channel = 6;
+  SequenceSnapshot seq_snapshot = 7;
+}
+
+message SequenceSnapshot{
+  // mapping of RegionId to SequenceNumber, for snapshot read, meaning that the
+  // read should only container data that was committed before(and include) the
+  // given sequence number
+  map<uint64, uint64> seq_snapshot = 7;
 }

 message RequestHeader {