Skip to content

Commit d564c23

Browse files
authored
[MongoDB Replication] Raw Change Streams (#591)
* Add rawChangeStream implementation. * Use the new rawChangeStream(). * Remove old openChangeStream. * Use raw responses. * Defer parsing change stream documents. * Redo replication metrics. * Cleanup. * Fix collection-level testing. * Add retries for rawChangeStream. * Re-use session for retries. * Fix killCursors. * Handle startAfter. * Improve abort handling; add comments. * Add tests for resuming streams. * Improve and test abort handling. * Rename test. * Add test for replicating from multiple databases in the same cluster. * Changeset. * Fix `batchesSeen`. * Rename options.
1 parent 203233d commit d564c23

File tree

7 files changed

+1019
-499
lines changed

7 files changed

+1019
-499
lines changed
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
'@powersync/service-module-mongodb': minor
3+
---
4+
5+
Use custom MongoDB change stream implementation to get better low-level control.

0 commit comments

Comments
 (0)