fix: modify querier_{endpoint, auth_token} to Option

Author: Anirudhxx

server/src/handlers/http/cluster/mod.rs

@@ -849,8 +849,8 @@ pub async fn forward_create_stream_request(stream_name: &str) -> Result<(), Stre
     let staging_metadata = get_staging_metadata().unwrap().ok_or_else(|| {
         StreamError::Anyhow(anyhow::anyhow!("Failed to retrieve staging metadata"))
     })?;
-    let querier_endpoint = to_url_string(staging_metadata.querier_endpoint);
-    let token = staging_metadata.querier_auth_token;
+    let querier_endpoint = to_url_string(staging_metadata.querier_endpoint.unwrap());
+    let token = staging_metadata.querier_auth_token.unwrap();
 
     if !check_liveness(&querier_endpoint).await {
         log::warn!("Querier {} is not live", querier_endpoint);

server/src/storage/store_metadata.rs

@@ -64,23 +64,27 @@ pub struct StorageMetadata {
     pub roles: HashMap<String, Vec<DefaultPrivilege>>,
     #[serde(default)]
     pub default_role: Option<String>,
-    pub querier_endpoint: String,
-    pub querier_auth_token: String,
+    pub querier_endpoint: Option<String>,
+    pub querier_auth_token: Option<String>,
 }
 
 impl StorageMetadata {
     pub fn new() -> Self {
-        let querier_auth_token = format!(
-            "Basic {}",
-            base64::prelude::BASE64_STANDARD.encode(format!(
-                "{}:{}",
-                CONFIG.parseable.username, CONFIG.parseable.password
-            ))
-        );
-
         let (querier_endpoint, querier_auth_token) = match CONFIG.parseable.mode {
-            Mode::All | Mode::Query => (CONFIG.parseable.address.clone(), querier_auth_token),
-            Mode::Ingest => (String::default(), String::default()),
+            Mode::All | Mode::Query => {
+                let querier_auth_token = format!(
+                    "Basic {}",
+                    base64::prelude::BASE64_STANDARD.encode(format!(
+                        "{}:{}",
+                        CONFIG.parseable.username, CONFIG.parseable.password
+                    ))
+                );
+                (
+                    Some(CONFIG.parseable.address.clone()),
+                    Some(querier_auth_token),
+                )
+            }
+            Mode::Ingest => (None, None),
         };
 
         Self {