3f5fc11f31
This commit introduces 3 examples of LDPs that process monasca metrics: * `Aggregate` - compute simple stats per metric name. * `Combine` - allow mixing of different metrics by providing a simple expression parser that gets transformed into CPython bytecode. * `Derivative` - compute a metric derivative. While quite simple, those examples, will help us improve the framework by emphazing some of the problems we will face when working on more complex solution such as: * Spark's inability to share data between sliding windows. * Ordering of data. * Sampling of metrics / events. Change-Id: I259022f20e9b288aa2a08c24ad4a5f41a20e6095 |
||
---|---|---|
.. | ||
__init__.py | ||
test_base.py | ||
test_cloud.py | ||
test_iptables_ingestor.py |