Skip to content

Commit 08066aa

Browse files
renamed internal stream name to pmeta
1 parent 0b8c74e commit 08066aa

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

server/src/handlers/http/cluster/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ use std::time::Duration;
5050

5151
use super::modal::IngestorMetadata;
5252
use clokwerk::{AsyncScheduler, Interval};
53-
pub const INTERNAL_STREAM_NAME: &str = "meta";
53+
pub const INTERNAL_STREAM_NAME: &str = "pmeta";
5454

5555
const CLUSTER_METRICS_INTERVAL_SECONDS: Interval = clokwerk::Interval::Minutes(1);
5656

server/src/validator.rs

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,15 +16,25 @@
1616
*
1717
*/
1818

19+
use self::error::{AlertValidationError, StreamNameValidationError, UsernameValidationError};
1920
use crate::alerts::rule::base::{NumericRule, StringRule};
2021
use crate::alerts::rule::{ColumnRule, ConsecutiveNumericRule, ConsecutiveStringRule};
2122
use crate::alerts::{Alerts, Rule};
22-
23-
use self::error::{AlertValidationError, StreamNameValidationError, UsernameValidationError};
23+
use crate::handlers::http::cluster::INTERNAL_STREAM_NAME;
2424

2525
// Add more sql keywords here in lower case
2626
const DENIED_NAMES: &[&str] = &[
27-
"select", "from", "where", "group", "by", "order", "limit", "offset", "join", "and", "meta",
27+
"select",
28+
"from",
29+
"where",
30+
"group",
31+
"by",
32+
"order",
33+
"limit",
34+
"offset",
35+
"join",
36+
"and",
37+
INTERNAL_STREAM_NAME,
2838
];
2939

3040
pub fn alert(alerts: &Alerts) -> Result<(), AlertValidationError> {

0 commit comments

Comments
 (0)