blob: 5b3bb87fd19a835462e2469a5873d483f3a19d84 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
from __future__ import absolute_import
from kafka.metrics.measurable_stat import AbstractMeasurableStat
class Total(AbstractMeasurableStat):
"""An un-windowed cumulative total maintained over all time."""
def __init__(self, value=0.0):
self._total = value
def record(self, config, value, now):
self._total += value
def measure(self, config, now):
return float(self._total)
|
