| 46 | |
| 47 | template<class Quantities> |
| 48 | void QuotaMetrics::update(const string& role, const Quantities& quantities) |
| 49 | { |
| 50 | hashmap<string, PushGauge>& gauges = metrics[role]; |
| 51 | |
| 52 | hashset<string> namesToRemove = gauges.keys(); |
| 53 | |
| 54 | for (const auto& quantity : quantities) { |
| 55 | const string& name = quantity.first; |
| 56 | const double value = quantity.second.value(); |
| 57 | |
| 58 | namesToRemove.erase(name); |
| 59 | |
| 60 | if (gauges.contains(name)) { |
| 61 | gauges.at(name) = value; |
| 62 | continue; |
| 63 | } |
| 64 | |
| 65 | PushGauge newGauge( |
| 66 | "allocator/mesos/quota/roles/" + role + "/resources/" + name + suffix); |
| 67 | |
| 68 | newGauge = value; |
| 69 | process::metrics::add(newGauge); |
| 70 | gauges.put(name, newGauge); |
| 71 | } |
| 72 | |
| 73 | for (const string& name : namesToRemove) { |
| 74 | process::metrics::remove(gauges.at(name)); |
| 75 | gauges.erase(name); |
| 76 | } |
| 77 | |
| 78 | if (gauges.empty()) { |
| 79 | metrics.erase(role); |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | |
| 84 | QuotaMetrics::~QuotaMetrics() { |