AggregatingOutput adds aggregating functionality to an Output. May be used if the Output only accepts a fixed set of aggregations over a time period. These functions may be called concurrently to the Write function.
| 18 | // if the Output only accepts a fixed set of aggregations over a time period. |
| 19 | // These functions may be called concurrently to the Write function. |
| 20 | type AggregatingOutput interface { |
| 21 | Output |
| 22 | |
| 23 | // Add the metric to the aggregator |
| 24 | Add(in Metric) |
| 25 | // Push returns the aggregated metrics and is called every flush interval. |
| 26 | Push() []Metric |
| 27 | // Reset signals that the aggregator period is completed. |
| 28 | Reset() |
| 29 | } |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…