enhancement: hot tier enabled for standalone mode

Author: nikhilsinhaparseable

server/src/handlers/http/logstream.rs

@@ -953,12 +953,6 @@ pub async fn put_stream_hot_tier(
     req: HttpRequest,
     body: web::Json<serde_json::Value>,
 ) -> Result<impl Responder, StreamError> {
-    if CONFIG.parseable.mode != Mode::Query {
-        return Err(StreamError::Custom {
-            msg: "Hot tier can only be enabled in query mode".to_string(),
-            status: StatusCode::BAD_REQUEST,
-        });
-    }
     let stream_name: String = req.match_info().get("logstream").unwrap().parse().unwrap();
     if !metadata::STREAM_INFO.stream_exists(&stream_name) {
         return Err(StreamError::StreamNotFound(stream_name));
@@ -1008,13 +1002,6 @@ pub async fn put_stream_hot_tier(
 }
 
 pub async fn get_stream_hot_tier(req: HttpRequest) -> Result<impl Responder, StreamError> {
-    if CONFIG.parseable.mode != Mode::Query {
-        return Err(StreamError::Custom {
-            msg: "Hot tier can only be enabled in query mode".to_string(),
-            status: StatusCode::BAD_REQUEST,
-        });
-    }
-
     let stream_name: String = req.match_info().get("logstream").unwrap().parse().unwrap();
 
     if !metadata::STREAM_INFO.stream_exists(&stream_name) {
@@ -1040,13 +1027,6 @@ pub async fn get_stream_hot_tier(req: HttpRequest) -> Result<impl Responder, Str
 }
 
 pub async fn delete_stream_hot_tier(req: HttpRequest) -> Result<impl Responder, StreamError> {
-    if CONFIG.parseable.mode != Mode::Query {
-        return Err(StreamError::Custom {
-            msg: "Hot tier can only be enabled in query mode".to_string(),
-            status: StatusCode::BAD_REQUEST,
-        });
-    }
-
     let stream_name: String = req.match_info().get("logstream").unwrap().parse().unwrap();
 
     if !metadata::STREAM_INFO.stream_exists(&stream_name) {

server/src/handlers/http/modal/server.rs

@@ -29,6 +29,7 @@ use crate::handlers::http::users::dashboards;
 use crate::handlers::http::users::filters;
 use crate::handlers::http::API_BASE_PATH;
 use crate::handlers::http::API_VERSION;
+use crate::hottier::HotTierManager;
 use crate::localcache::LocalCacheManager;
 use crate::metrics;
 use crate::migration;
@@ -573,6 +574,10 @@ impl Server {
 
         storage::retention::load_retention_from_global();
 
+        if let Some(hot_tier_manager) = HotTierManager::global() {
+            hot_tier_manager.download_from_s3()?;
+        };
+
         let (localsync_handler, mut localsync_outbox, localsync_inbox) =
             sync::run_local_sync().await;
         let (mut remote_sync_handler, mut remote_sync_outbox, mut remote_sync_inbox) =

server/src/hottier.rs

@@ -73,10 +73,12 @@ impl HotTierManager {
     pub fn global() -> Option<&'static HotTierManager> {
         static INSTANCE: OnceCell<HotTierManager> = OnceCell::new();
 
-        let hot_tier_path = CONFIG.parseable.hot_tier_storage_path.as_ref()?;
-
+        let hot_tier_path = &CONFIG.parseable.hot_tier_storage_path;
+        if hot_tier_path.is_none() {
+            return None;
+        }
         Some(INSTANCE.get_or_init(|| {
-            let hot_tier_path = hot_tier_path.clone();
+            let hot_tier_path = hot_tier_path.as_ref().unwrap().clone();
             std::fs::create_dir_all(&hot_tier_path).unwrap();
             HotTierManager {
                 filesystem: LocalFileSystem::new(),