Skip to content

Commit 8836ff4

Browse files
committed
Bump dependencies
1 parent 5f19e27 commit 8836ff4

File tree

5 files changed

+19
-46
lines changed

5 files changed

+19
-46
lines changed

zerofs/Cargo.lock

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

zerofs/Cargo.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "zerofs"
3-
version = "1.0.5"
3+
version = "1.0.6"
44
edition = "2024"
55
description = "A high-performance filesystem that makes S3 your primary storage with NFS, 9P, and NBD support"
66
license = "AGPL-3.0"
@@ -30,7 +30,7 @@ vendored-protoc = ["dep:protobuf-src"]
3030

3131
[dependencies]
3232
console-subscriber = { version = "0.5", optional = true }
33-
slatedb = { git = "https://github.com/Barre/slatedb.git", rev = "da3a3a52958a5ba32a34d4cfc5d47569f6440373", features = [
33+
slatedb = { git = "https://github.com/Barre/slatedb.git", rev = "491de682bd6b029676601d10f6e3cfee4d6e80bf", features = [
3434
"wal_disable",
3535
] }
3636
fastant = "0.1.11"

zerofs/src/cli/server.rs

Lines changed: 13 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use slatedb::config::{
2121
ObjectStoreCacheOptions,
2222
};
2323
use slatedb::object_store::path::Path;
24-
use slatedb::{BlockTransformer, DbBuilder, DbReader};
24+
use slatedb::{BlockTransformer, CompactorBuilder, DbBuilder, DbReader};
2525
use std::path::PathBuf;
2626
use std::sync::Arc;
2727
use std::time::Duration;
@@ -448,21 +448,12 @@ pub async fn build_slatedb(
448448

449449
let wal_enabled = lsm_config.map(|c| c.wal_enabled()).unwrap_or(true);
450450

451-
let compactor_options = if disable_compactor {
452-
None
453-
} else {
454-
Some(slatedb::config::CompactorOptions {
455-
max_concurrent_compactions,
456-
max_sst_size: 256 * 1024 * 1024,
457-
..Default::default()
458-
})
459-
};
460-
461451
let settings = slatedb::config::Settings {
462452
wal_enabled,
463453
l0_max_ssts,
464454
l0_sst_size_bytes: 128 * 1024 * 1024,
465455
filter_bits_per_key: 10,
456+
compactor_options: None,
466457
object_store_cache_options: ObjectStoreCacheOptions {
467458
root_folder: Some(cache_config.root_folder.clone()),
468459
max_cache_size_bytes: Some(slatedb_object_cache_bytes),
@@ -471,7 +462,6 @@ pub async fn build_slatedb(
471462
},
472463
flush_interval: Some(std::time::Duration::from_secs(30)),
473464
max_unflushed_bytes,
474-
compactor_options,
475465
compression_codec: None, // Disable compression - we handle it in encryption layer
476466
garbage_collector_options: Some(GarbageCollectorOptions {
477467
wal_options: Some(GarbageCollectorDirectoryOptions {
@@ -519,19 +509,27 @@ pub async fn build_slatedb(
519509
info!("Opening database in read-write mode");
520510
}
521511

522-
let mut builder = DbBuilder::new(db_path, object_store)
512+
let mut builder = DbBuilder::new(db_path.clone(), object_store.clone())
523513
.with_settings(settings)
524514
.with_gc_runtime(runtime_handle.clone())
525515
.with_sst_block_size(slatedb::SstBlockSize::Block4Kib)
526-
.with_memory_cache(cache)
516+
.with_db_cache(cache)
527517
.with_block_transformer(block_transformer);
528518

529519
if let Some(wal_store) = wal_object_store {
530520
builder = builder.with_wal_object_store(wal_store);
531521
}
532522

533523
if !disable_compactor {
534-
builder = builder.with_compaction_runtime(runtime_handle.clone());
524+
let compactor = CompactorBuilder::new(db_path, object_store)
525+
.with_runtime(runtime_handle.clone())
526+
.with_options(slatedb::config::CompactorOptions {
527+
max_concurrent_compactions,
528+
max_sst_size: 256 * 1024 * 1024,
529+
..Default::default()
530+
});
531+
532+
builder = builder.with_compactor_builder(compactor);
535533
}
536534

537535
let slatedb = Arc::new(builder.build().await?);

zerofs/src/fs/mod.rs

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -286,18 +286,9 @@ impl ZeroFS {
286286
let block_transformer: Arc<dyn BlockTransformer> =
287287
ZeroFsBlockTransformer::new_arc(&test_key, CompressionConfig::default());
288288

289-
let settings = slatedb::config::Settings {
290-
compression_codec: None,
291-
compactor_options: Some(slatedb::config::CompactorOptions {
292-
..Default::default()
293-
}),
294-
..Default::default()
295-
};
296-
297289
let db_path = Path::from("test_slatedb");
298290
let slatedb = Arc::new(
299291
DbBuilder::new(db_path, object_store)
300-
.with_settings(settings)
301292
.with_block_transformer(block_transformer)
302293
.build()
303294
.await?,
@@ -2878,18 +2869,9 @@ mod tests {
28782869
let block_transformer: Arc<dyn BlockTransformer> =
28792870
ZeroFsBlockTransformer::new_arc(&test_key, CompressionConfig::default());
28802871

2881-
let settings = slatedb::config::Settings {
2882-
compression_codec: None,
2883-
compactor_options: Some(slatedb::config::CompactorOptions {
2884-
..Default::default()
2885-
}),
2886-
..Default::default()
2887-
};
2888-
28892872
let db_path = Path::from("test_slatedb");
28902873
let slatedb = Arc::new(
28912874
DbBuilder::new(db_path.clone(), object_store.clone())
2892-
.with_settings(settings)
28932875
.with_block_transformer(block_transformer)
28942876
.build()
28952877
.await

zerofs/tests/failpoints/mod.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -44,16 +44,9 @@ impl CrashTestContext {
4444

4545
/// Create a new filesystem instance
4646
async fn create_fs(&self) -> Arc<ZeroFS> {
47-
let settings = Settings {
48-
compression_codec: None,
49-
compactor_options: Some(slatedb::config::CompactorOptions::default()),
50-
..Default::default()
51-
};
52-
5347
let db_path = Path::from("slatedb");
5448
let slatedb = Arc::new(
5549
DbBuilder::new(db_path, Arc::clone(&self.object_store))
56-
.with_settings(settings)
5750
.build()
5851
.await
5952
.unwrap(),

0 commit comments

Comments
 (0)