diff --git a/server/src/handlers/http/cluster/mod.rs b/server/src/handlers/http/cluster/mod.rs index 4afce9b64..b854ebcd0 100644 --- a/server/src/handlers/http/cluster/mod.rs +++ b/server/src/handlers/http/cluster/mod.rs @@ -50,7 +50,7 @@ use std::time::Duration; use super::modal::IngestorMetadata; use clokwerk::{AsyncScheduler, Interval}; -pub const INTERNAL_STREAM_NAME: &str = "meta"; +pub const INTERNAL_STREAM_NAME: &str = "pmeta"; const CLUSTER_METRICS_INTERVAL_SECONDS: Interval = clokwerk::Interval::Minutes(1); diff --git a/server/src/validator.rs b/server/src/validator.rs index 9a6d15b49..15bf60c02 100644 --- a/server/src/validator.rs +++ b/server/src/validator.rs @@ -16,15 +16,25 @@ * */ +use self::error::{AlertValidationError, StreamNameValidationError, UsernameValidationError}; use crate::alerts::rule::base::{NumericRule, StringRule}; use crate::alerts::rule::{ColumnRule, ConsecutiveNumericRule, ConsecutiveStringRule}; use crate::alerts::{Alerts, Rule}; - -use self::error::{AlertValidationError, StreamNameValidationError, UsernameValidationError}; +use crate::handlers::http::cluster::INTERNAL_STREAM_NAME; // Add more sql keywords here in lower case const DENIED_NAMES: &[&str] = &[ - "select", "from", "where", "group", "by", "order", "limit", "offset", "join", "and", "meta", + "select", + "from", + "where", + "group", + "by", + "order", + "limit", + "offset", + "join", + "and", + INTERNAL_STREAM_NAME, ]; pub fn alert(alerts: &Alerts) -> Result<(), AlertValidationError> {