Skip to content

Commit ec49597

Browse files
caikpigossoclaude
andcommitted
debug: log cluster servers count and DNS wait with warn level
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent e341fbd commit ec49597

2 files changed

Lines changed: 35 additions & 12 deletions

File tree

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/server/mod.rs

Lines changed: 34 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -902,14 +902,37 @@ impl VectorizerServer {
902902
// Bootstrap Raft cluster with all configured members.
903903
// Build the member map from the cluster.servers config so
904904
// all nodes participate in the initial election.
905-
let cluster_servers = std::fs::read_to_string(&config_path)
906-
.ok()
907-
.and_then(|content| {
908-
serde_yaml::from_str::<crate::config::VectorizerConfig>(&content)
909-
.ok()
910-
.map(|c| c.cluster.servers)
911-
})
912-
.unwrap_or_default();
905+
let cluster_servers = match std::fs::read_to_string(&config_path) {
906+
Ok(content) => {
907+
match serde_yaml::from_str::<crate::config::VectorizerConfig>(
908+
&content,
909+
) {
910+
Ok(c) => {
911+
warn!(
912+
"Cluster servers from config: {} servers",
913+
c.cluster.servers.len()
914+
);
915+
c.cluster.servers
916+
}
917+
Err(e) => {
918+
error!(
919+
"❌ Failed to parse config for cluster servers: {}",
920+
e
921+
);
922+
vec![]
923+
}
924+
}
925+
}
926+
Err(e) => {
927+
error!("❌ Failed to read config: {}", e);
928+
vec![]
929+
}
930+
};
931+
932+
warn!(
933+
"Cluster servers count: {} (need >1 for multi-node)",
934+
cluster_servers.len()
935+
);
913936

914937
if cluster_servers.len() > 1 {
915938
// Wait for at least 1 peer to be resolvable via DNS
@@ -924,7 +947,7 @@ impl VectorizerServer {
924947
})
925948
.unwrap_or_default();
926949

927-
info!("⏳ Waiting for peer DNS resolution before Raft bootstrap...");
950+
warn!("⏳ Waiting for peer DNS resolution before Raft bootstrap...");
928951
for attempt in 1..=30 {
929952
let mut resolved = 0;
930953
for server in &cluster_servers {
@@ -937,14 +960,14 @@ impl VectorizerServer {
937960
}
938961
}
939962
if resolved > 0 {
940-
info!(
963+
warn!(
941964
"✅ {} peer(s) resolvable via DNS (attempt {})",
942965
resolved, attempt
943966
);
944967
break;
945968
}
946969
if attempt % 5 == 0 {
947-
info!(
970+
warn!(
948971
"⏳ Still waiting for peer DNS... (attempt {}/30)",
949972
attempt
950973
);

0 commit comments

Comments
 (0)