move pstats name to utils

Author: nikhilsinhaparseable

src/parseable/streams.rs

@@ -46,6 +46,7 @@ use serde::Serialize;
 use tokio::task::JoinSet;
 use tracing::{error, info, trace, warn};
 
+use crate::utils::DATASET_STATS_STREAM_NAME;
 use crate::{
     cli::Options,
     event::{
@@ -71,7 +72,7 @@ use super::{
     },
     LogStream, ARROW_FILE_EXTENSION,
 };
-const DATASET_STATS_STREAM_NAME: &str = "pstats";
+
 const MAX_CONCURRENT_FIELD_STATS: usize = 10;
 
 #[derive(Serialize, Debug)]

src/utils/mod.rs

@@ -37,6 +37,8 @@ use datafusion::common::tree_node::TreeNode;
 use regex::Regex;
 use sha2::{Digest, Sha256};
 
+pub const DATASET_STATS_STREAM_NAME: &str = "pstats";
+
 pub fn get_node_id() -> String {
     let now = Utc::now().to_rfc3339();
     let id = get_hash(&now).to_string().split_at(15).0.to_string();