Skip to content

Commit 4fa73a5

Browse files
committed
add migrate_bottomless flag to sqld
1 parent 7e0f3d7 commit 4fa73a5

2 files changed

Lines changed: 11 additions & 0 deletions

File tree

libsql-server/src/lib.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,7 @@ pub struct Server<C = HttpConnector, A = AddrIncoming, D = HttpsConnector<HttpCo
170170
pub use_custom_wal: Option<CustomWAL>,
171171
pub storage_server_address: String,
172172
pub connector: Option<D>,
173+
pub migrate_bottomless: bool,
173174
}
174175

175176
impl<C, A, D> Default for Server<C, A, D> {
@@ -194,6 +195,7 @@ impl<C, A, D> Default for Server<C, A, D> {
194195
use_custom_wal: None,
195196
storage_server_address: Default::default(),
196197
connector: None,
198+
migrate_bottomless: false,
197199
}
198200
}
199201
}

libsql-server/src/main.rs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -264,6 +264,14 @@ struct Cli {
264264
default_value = "http://0.0.0.0:5002"
265265
)]
266266
storage_server_address: String,
267+
268+
/// Enable bottomless to libsql_wal migration. Bottomless replication must be enabled.
269+
#[clap(
270+
long,
271+
env = "LIBSQL_MIGRATE_BOTTOMLESS",
272+
requires = "enable_bottomless_replication"
273+
)]
274+
migrate_bottomless: bool,
267275
}
268276

269277
#[derive(clap::Subcommand, Debug)]
@@ -662,6 +670,7 @@ async fn build_server(config: &Cli) -> anyhow::Result<Server> {
662670
use_custom_wal: config.use_custom_wal,
663671
storage_server_address: config.storage_server_address.clone(),
664672
connector: Some(https),
673+
migrate_bottomless: config.migrate_bottomless
665674
})
666675
}
667676

0 commit comments

Comments
 (0)