ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-04-06 13:35:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into develop

Browse Source
This commit is contained in:
Thomas Gruber 2024-12-19 22:58:27 +01:00 committed by GitHub
commit 063a3751f2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/messageProcessor/README.md
View File

@ -22,6 +22,7 @@ New operations can be added to the message processor at runtime. Of course, they
or some fields in a configuration file for the processing. or some fields in a configuration file for the processing.
The message processor uses the following configuration The message processor uses the following configuration
```json ```json
{ {
"drop_messages": [ "drop_messages": [
@ -226,6 +227,7 @@ type MessageProcessor interface {
} }
``` ```
### Syntax for evaluatable terms ### Syntax for evaluatable terms
The message processor uses `gval` for evaluating the terms. It provides a basic set of operators like string comparison and arithmetic operations. The message processor uses `gval` for evaluating the terms. It provides a basic set of operators like string comparison and arithmetic operations.
@ -254,9 +256,11 @@ Often the operations are written in JSON files for loading them at startup. In J
- use `''` instead of `""` for strings - use `''` instead of `""` for strings
- for the regexes, use `%` instead of `\` - for the regexes, use `%` instead of `\`
For operations that should be applied on all messages, use the condition `true`. For operations that should be applied on all messages, use the condition `true`.
### Overhead ### Overhead
The operations taking conditions are pre-processed, which is commonly the time consuming part but, of course, with each added operation, the time to process a message The operations taking conditions are pre-processed, which is commonly the time consuming part but, of course, with each added operation, the time to process a message
increases. Moreover, the processing creates a copy of the message. increases. Moreover, the processing creates a copy of the message.

1
pkg/messageProcessor/messageProcessor.go
View File

@ -9,6 +9,7 @@ import (
lp "github.com/ClusterCockpit/cc-energy-manager/pkg/cc-message" lp "github.com/ClusterCockpit/cc-energy-manager/pkg/cc-message"
cclog "github.com/ClusterCockpit/cc-metric-collector/pkg/ccLogger" cclog "github.com/ClusterCockpit/cc-metric-collector/pkg/ccLogger"
lplegacy "github.com/ClusterCockpit/cc-metric-collector/pkg/ccMetric" lplegacy "github.com/ClusterCockpit/cc-metric-collector/pkg/ccMetric"
"github.com/expr-lang/expr" "github.com/expr-lang/expr"
"github.com/expr-lang/expr/vm" "github.com/expr-lang/expr/vm"
) )