We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3da2a8b commit 8fb997eCopy full SHA for 8fb997e
1 file changed
libsql/src/database.rs
@@ -388,6 +388,18 @@ cfg_replication! {
388
t => Err(Error::FreezeNotSupported(format!("{:?}", t)))
389
}
390
391
+
392
+ /// Get the maximum replication index returned from a write performed using any connection created using this Database object.
393
+ pub fn max_write_replication_index(&self) -> Option<FrameNo> {
394
+ let index = self
395
+ .max_write_replication_index
396
+ .load(std::sync::atomic::Ordering::SeqCst);
397
+ if index == 0 {
398
+ None
399
+ } else {
400
+ Some(index)
401
+ }
402
403
404
405
0 commit comments