Repository for Metric Runner development.
- Python 46.2%
- Java 27.4%
- Perl 23.1%
- Dockerfile 3.3%
| client | ||
| dockercompose | ||
| jobs | ||
| threatmodel | ||
| README.md | ||
Metric Runner service
Metric Runner is responsible to setting up flink pipelines that run in Flink behind Kafka and a Flask frontend. The frontend uses Cerberus to validate incoming data and pipelines can be set to send alerts on events sent from the pipeline to TSDB with value thresholds.
Important Information
- Mrdirector is a container responsible to reading the desired state of pipelines from the api and creating/deleting Flink jobs and Kafka topics in response to match.
- Mremail is a container responsible for sending out email alerts if a pipeline has email alerting enabled.
- Mrfrontapi is a container responsible for receiving incoming events, validating them with Cerberus, and writing them to the appropriate Kafka topic.
- Mrmanagementapi is a container responsible for creating, updating, deleting, querying Metric Runner pipelines.