Load storage metadata as global static variable (#313)

Author: trueleo

Cargo.lock

@@ -72,6 +72,7 @@ itertools = "0.10"
 xxhash-rust = { version = "0.8", features = ["xxh3"] }
 xz2 = { version = "*", features=["static"] }
 bzip2 = { version = "*", features=["static"] }
+once_cell = "1.17.1"
 
 [build-dependencies]
 static-files = "0.2"

server/Cargo.toml

@@ -22,7 +22,7 @@ use crossterm::style::Stylize;
 use crate::utils::uid::Uid;
 use crate::{option::Config, storage::StorageMetadata};
 
-pub async fn print(config: &Config, meta: StorageMetadata) {
+pub async fn print(config: &Config, meta: &StorageMetadata) {
     print_ascii_art();
     let scheme = config.parseable.get_scheme();
     status_info(config, &scheme, meta.deployment_id);
@@ -149,11 +149,11 @@ pub mod about {
         eprint!("{}", fmt_latest_version.red());
     }
 
-    pub async fn print(config: &Config, meta: StorageMetadata) {
+    pub async fn print(config: &Config, meta: &StorageMetadata) {
         // print current version
         let current = current();
         let latest_release = if config.parseable.check_update {
-            update::get_latest(&meta).await.ok()
+            update::get_latest(meta).await.ok()
         } else {
             None
         };

server/src/banner.rs

@@ -69,7 +69,8 @@ async fn main() -> anyhow::Result<()> {
     CONFIG.validate_staging()?;
     CONFIG.validate_storage(&*storage).await;
     let metadata = storage::resolve_parseable_metadata().await?;
-    banner::print(&CONFIG, metadata).await;
+    metadata.set_global();
+    banner::print(&CONFIG, storage::StorageMetadata::global()).await;
     let prometheus = metrics::build_metrics_handler();
     CONFIG.storage().register_store_metrics(&prometheus);
 

server/src/main.rs

@@ -21,13 +21,16 @@ use std::{
     path::PathBuf,
 };
 
+use once_cell::sync::OnceCell;
 use serde::{Deserialize, Serialize};
 use std::io;
 
 use crate::{option::CONFIG, utils::uid};
 
 use super::object_storage::PARSEABLE_METADATA_FILE_NAME;
 
+pub static STORAGE_METADATA: OnceCell<StorageMetadata> = OnceCell::new();
+
 #[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
 pub struct StorageMetadata {
     pub version: String,
@@ -59,6 +62,16 @@ impl StorageMetadata {
             stream: Vec::new(),
         }
     }
+
+    pub fn global() -> &'static Self {
+        STORAGE_METADATA
+            .get()
+            .expect("gloabal static is initialized")
+    }
+
+    pub fn set_global(self) {
+        STORAGE_METADATA.set(self).expect("only set once")
+    }
 }
 
 pub fn check_metadata_conflict(