Perform WAL checkpointing ten times per second

Qqwy · Qqwy · commit 3e99a4c72cb0 · 2026-04-01T13:59:13.000+02:00
diff --git a/Cargo.toml b/Cargo.toml
@@ -9,7 +9,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.34.3"
+version = "0.34.4"
 
 
 [workspace.lints.clippy]
diff --git a/opsqueue/src/db/mod.rs b/opsqueue/src/db/mod.rs
@@ -256,7 +256,7 @@ impl DBPools {
     }
 
     pub async fn periodically_checkpoint_wal(&self) {
-        const EXPLICIT_WAL_CHECK_INTERVAL: Duration = Duration::from_secs(1);
+        const EXPLICIT_WAL_CHECK_INTERVAL: Duration = Duration::from_millis(100);
         let mut interval = tokio::time::interval(EXPLICIT_WAL_CHECK_INTERVAL);
         loop {
             let _ = self.perform_explicit_wal_checkpoint().await;

Original file line number	Diff line number	Diff line change
`@@ -256,7 +256,7 @@ impl DBPools {`
`256`	`256`	`}`
`257`	`257`
`258`	`258`	`pub async fn periodically_checkpoint_wal(&self) {`
`259`		`- const EXPLICIT_WAL_CHECK_INTERVAL: Duration = Duration::from_secs(1);`
	`259`	`+ const EXPLICIT_WAL_CHECK_INTERVAL: Duration = Duration::from_millis(100);`
`260`	`260`	`let mut interval = tokio::time::interval(EXPLICIT_WAL_CHECK_INTERVAL);`
`261`	`261`	`loop {`
`262`	`262`	`let _ = self.perform_explicit_wal_checkpoint().await;`