refactor: move kinesis to src

Author: Devdutt Shenoi

src/handlers/http/mod.rs

@@ -34,7 +34,6 @@ pub mod cluster;
 pub mod correlation;
 pub mod health_check;
 pub mod ingest;
-mod kinesis;
 pub mod llm;
 pub mod logstream;
 pub mod middleware;

src/handlers/http/modal/utils/ingest_utils.rs

@@ -31,13 +31,8 @@ use crate::{
         format::{json, EventFormat, LogSource},
         FORMAT_KEY, SOURCE_IP_KEY, USER_AGENT_KEY,
     },
-    handlers::{
-        http::{
-            ingest::PostError,
-            kinesis::{flatten_kinesis_logs, Message},
-        },
-        LOG_SOURCE_KEY, STREAM_NAME_HEADER_KEY,
-    },
+    handlers::{http::ingest::PostError, LOG_SOURCE_KEY, STREAM_NAME_HEADER_KEY},
+    kinesis::{flatten_kinesis_logs, Message},
     otel::{logs::flatten_otel_logs, metrics::flatten_otel_metrics, traces::flatten_otel_traces},
     parseable::PARSEABLE,
     storage::StreamType,
@@ -143,6 +138,7 @@ async fn push_logs(
             )?
             .process()?;
     }
+
     Ok(())
 }
 

src/handlers/http/kinesis.rs renamed to src/kinesis.rs

@@ -30,6 +30,7 @@ pub mod enterprise;
 pub mod event;
 pub mod handlers;
 pub mod hottier;
+mod kinesis;
 mod livetail;
 mod metadata;
 pub mod metrics;