Skip to content

Commit 2109bcc

Browse files
add scheme to cluster info
1 parent 77dc86f commit 2109bcc

File tree

1 file changed

+10
-3
lines changed
  • src/handlers/http/cluster

1 file changed

+10
-3
lines changed

src/handlers/http/cluster/mod.rs

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,9 @@ use serde_json::error::Error as SerdeError;
3737
use serde_json::{to_vec, Value as JsonValue};
3838
use tracing::{error, info, warn};
3939
use url::Url;
40-
use utils::{check_liveness, to_url_string, IngestionStats, QueriedStats, StorageStats};
40+
use utils::{
41+
check_liveness, to_url_string, ClusterInfo, IngestionStats, QueriedStats, StorageStats,
42+
};
4143

4244
use crate::handlers::http::ingest::ingest_internal_stream;
4345
use crate::metrics::prom_utils::Metrics;
@@ -540,8 +542,13 @@ pub async fn send_retention_cleanup_request(
540542
}
541543

542544
pub async fn get_cluster_info() -> Result<impl Responder, StreamError> {
543-
let self_info = utils::ClusterInfo::new(
544-
&PARSEABLE.options.address,
545+
let self_info = ClusterInfo::new(
546+
format!(
547+
"{}://{}",
548+
PARSEABLE.options.get_scheme(),
549+
PARSEABLE.options.address
550+
)
551+
.as_str(),
545552
true,
546553
PARSEABLE
547554
.options

0 commit comments

Comments
 (0)