johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-12 06:24:10 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

console: use DstCommunities

Browse Source
This commit is contained in:
Vincent Bernat
2022-09-26 22:59:11 +02:00
parent e2672503b8
commit 9b821419c3
10 changed files with 100 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
console/query.go
View File

@@ -37,11 +37,12 @@ func (qc *queryColumn) UnmarshalText(input []byte) error {
// queryColumnsRequiringMainTable lists query columns only present in
// the main table. Also check filter/parser.peg.
var queryColumnsRequiringMainTable = map[queryColumn]struct{}{
queryColumnSrcAddr: {},
queryColumnDstAddr: {},
queryColumnSrcPort: {},
queryColumnDstPort: {},
queryColumnDstASPath: {},
queryColumnSrcAddr: {},
queryColumnDstAddr: {},
queryColumnSrcPort: {},
queryColumnDstPort: {},
queryColumnDstASPath: {},
queryColumnDstCommunities: {},
}
func requireMainTable(qcs []queryColumn, qf queryFilter) bool {
@@ -109,6 +110,8 @@ func (qc queryColumn) toSQLSelect() string {
strValue = fmt.Sprintf("toString(%s)", qc)
case queryColumnDstASPath:
strValue = `arrayStringConcat(DstASPath, ' ')`
case queryColumnDstCommunities:
strValue = `arrayStringConcat(arrayMap(c -> concat(toString(bitShiftRight(c, 16)), ':', toString(bitAnd(c, 0xffff))), DstCommunities), ' ')`
default:
strValue = qc.String()
}