rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-07-04 21:10:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(cli): reuse e2e connection helper in minio test

Browse Source 
Signed-off-by: jeremyhi <fengjiachun@gmail.com>
This commit is contained in:
jeremyhi
2026-06-16 23:40:30 +08:00
parent 3aabeef192
commit ecf4136855
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/cli/src/data/export_v2/tests.rs
View File

@@ -574,9 +574,7 @@ async fn export_import_v2_minio_roundtrip_e2e() -> Result<()> {
return Ok(());
}
let addr = env::var("GREPTIME_ADDR").unwrap_or_else(|_| "127.0.0.1:4000".to_string());
let catalog = env::var("GREPTIME_CATALOG").unwrap_or_else(|_| "greptime".to_string());
let auth_basic = env::var("GREPTIME_AUTH_BASIC").ok();
let conn = TestConnection::from_env();
let bucket = env::var("GT_MINIO_BUCKET").expect("checked above");
let access_key_id = env::var("GT_MINIO_ACCESS_KEY_ID").expect("checked above");
let secret_access_key = env::var("GT_MINIO_ACCESS_KEY").expect("checked above");
@@ -603,15 +601,15 @@ async fn export_import_v2_minio_roundtrip_e2e() -> Result<()> {
]);
};
let append_auth_args = |args: &mut Vec<String>| {
if let Some(auth) = &auth_basic {
if let Some(auth) = &conn.auth_basic {
args.extend(["--auth-basic".to_string(), auth.clone()]);
}
};
let database_client = DatabaseClient::new(
addr.clone(),
catalog.clone(),
auth_basic.clone(),
conn.addr.clone(),
conn.catalog.clone(),
conn.auth_basic.clone(),
Duration::from_secs(60),
None,
false,
@@ -648,11 +646,11 @@ async fn export_import_v2_minio_roundtrip_e2e() -> Result<()> {
let mut export_args = vec![
"export-v2-create".to_string(),
"--addr".to_string(),
addr.clone(),
conn.addr.clone(),
"--to".to_string(),
snapshot_uri.clone(),
"--catalog".to_string(),
catalog.clone(),
conn.catalog.clone(),
"--schemas".to_string(),
schema.to_string(),
"--start-time".to_string(),
@@ -702,11 +700,11 @@ async fn export_import_v2_minio_roundtrip_e2e() -> Result<()> {
let mut import_args = vec![
"import-v2".to_string(),
"--addr".to_string(),
addr.clone(),
conn.addr.clone(),
"--from".to_string(),
snapshot_uri.clone(),
"--catalog".to_string(),
catalog.clone(),
conn.catalog.clone(),
"--schemas".to_string(),
schema.to_string(),
"--task-parallelism".to_string(),