Skip to content

Commit 6720aed

Browse files
committed
Update redb version
1 parent aecdea6 commit 6720aed

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

Cargo.lock

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

crates/hotfix/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ futures = "^0.3.28"
2727
hotfix-message = { version = "0.0.23", path = "../hotfix-message" }
2828
mongodb = { version = "^3.2", optional = true }
2929
pki-types = { package = "rustls-pki-types", version = "^1" }
30-
redb = { version = "^1.1.0", optional = true }
30+
redb = { version = "^2.6", optional = true }
3131
rustls = "^0.21.5"
3232
rustls-pemfile = "^2.2"
3333
serde = { workspace = true, features = ["derive"] }

crates/hotfix/src/store/redb.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use crate::store::MessageStore;
22
use anyhow::{bail, Result};
33
use chrono::{DateTime, Utc};
4-
use redb::{Database, ReadOnlyTable, ReadableTable, TableDefinition, TableError};
4+
use redb::{Database, ReadOnlyTable, TableDefinition, TableError};
55
use std::path::Path;
66

77
const MESSAGES_TABLE: TableDefinition<u64, &[u8]> = TableDefinition::new("messages");
@@ -49,7 +49,7 @@ impl RedbMessageStore {
4949
meta_table.insert(SENDER_KEY, sender_seq_number)?;
5050
meta_table.insert(TARGET_KEY, target_seq_number)?;
5151
let mut messages_table = write_txn.open_table(MESSAGES_TABLE)?;
52-
messages_table.drain::<u64>(..)?;
52+
messages_table.extract_if(|_, _| true)?.for_each(drop);
5353
}
5454
write_txn.commit()?;
5555
Ok(())

0 commit comments

Comments
 (0)