1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.admin.monitoring;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import static java.util.Collections.unmodifiableMap;
/**
* Models a metric set containing a set of metrics and child metric sets.
* This should be immutable.
*
* @author gjoranv
*/
public class MetricSet {
private final String id;
private final Map<String, Metric> metrics;
private final Set<MetricSet> children;
public MetricSet(String id, Collection<Metric> metrics) {
this(id, metrics, Collections.emptySet());
}
public MetricSet(String id, Collection<Metric> metrics, Collection<MetricSet> children) {
this.id = Objects.requireNonNull(id, "Id cannot be null or empty.");
this.metrics = toMapByName(metrics);
this.children = new LinkedHashSet<>(children);
}
public static MetricSet empty() {
return new MetricSet("empty", Set.of());
}
public final String getId() { return id; }
/**
* Returns all metrics in this set, including all metrics in any contained metric sets.
*
* Joins this set's metrics with its child sets into a named flat map of metrics.
* In the case of duplicate metrics, the metrics directly defined in this set
* takes precedence with respect to output name, description and dimension value
* (even if they are empty), while new dimensions from the children will be added.
*
* @return all the metrics contained in this set
*/
public final Map<String, Metric> getMetrics() {
return unmodifiableMap(flatten(metrics, children));
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof MetricSet)) return false;
MetricSet that = (MetricSet) o;
return Objects.equals(id, that.id);
}
@Override
public int hashCode() {
return Objects.hashCode(id);
}
private Map<String, Metric> flatten(Map<String, Metric> metrics, Set<MetricSet> children) {
Map<String, Metric> joinedMetrics = new LinkedHashMap<>(metrics);
for (MetricSet child : children) {
child.getMetrics().forEach(
(name, metric) -> {
if (joinedMetrics.containsKey(name))
joinedMetrics.put(name, joinedMetrics.get(name).addDimensionsFrom(metric));
else
joinedMetrics.put(name, metric);
});
}
return joinedMetrics;
}
private Map<String, Metric> toMapByName(Collection<Metric> metrics) {
Map<String, Metric> metricMap = new LinkedHashMap<>();
metrics.forEach(metric -> metricMap.put(metric.name, metric));
return metricMap;
}
}
|
