refactor(pipeline)!: change dispatch table name format (#6901)

* chore(breaking): change dispatch table name format

* chore: fix test
This commit is contained in:
localhost
2025-09-03 21:47:40 +08:00
committed by GitHub
parent dbb76483e8
commit 756856799f
2 changed files with 4 additions and 4 deletions

View File

@@ -218,7 +218,7 @@ impl From<&Rule> for DispatchedTo {
impl DispatchedTo {
/// Generate destination table name from input
pub fn dispatched_to_table_name(&self, original: &str) -> String {
format!("{}_{}", &original, self.table_suffix)
[original, &self.table_suffix].concat()
}
}

View File

@@ -2517,12 +2517,12 @@ dispatcher:
field: type
rules:
- value: http
table_suffix: http
table_suffix: _http
pipeline: http
- value: db
table_suffix: db
table_suffix: _db
- value: not_found
table_suffix: not_found
table_suffix: _not_found
pipeline: not_found
transform: