feat: add time partition related changes (#1405)

create stream with custom time partition use header -
X-P-Time-Partition: <field-name> - this has to be a timestamp field
X-P-Time-Partition-Limit: max historical range default to 30d

server validates if all events in the batch has this time partition field
if false, it rejects the whole batch

Author: nikhilsinhaparseable

Cargo.lock

@@ -123,6 +123,7 @@ clokwerk = "0.4"
 derive_more = { version = "1", features = ["full"] }
 itertools = "0.14"
 once_cell = "1.20"
+rayon = "1.8"
 rand = "0.8.5"
 regex = "1.7.3"
 reqwest = { version = "0.11.27", default-features = false, features = [

Cargo.toml

@@ -107,7 +107,7 @@ async fn execute_local_query(
         filter_tag: None,
     };
 
-    let (records, _) = execute(query, &tables[0], false)
+    let (records, _) = execute(query, false)
         .await
         .map_err(|err| AlertError::CustomError(format!("Failed to execute query: {err}")))?;