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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.metrics.simple;
import java.util.logging.Logger;
import org.HdrHistogram.DoubleHistogram;
import com.yahoo.log.LogLevel;
/**
* A gauge or a counter or... who knows? The class for storing a metric when the
* metric has not been declared.
*
* @author Steinar Knutsen
*/
public class UntypedMetric {
private static final Logger log = Logger.getLogger(UntypedMetric.class.getName());
private long count = 0L;
private double current = 0.0d;
private double max;
private double min;
private double sum;
private AssumedType outputFormat = AssumedType.NONE;
private final DoubleHistogram histogram;
private final MetricSettings metricSettings;
public enum AssumedType { NONE, GAUGE, COUNTER };
UntypedMetric(MetricSettings metricSettings) {
this.metricSettings = metricSettings;
if (metricSettings == null || !metricSettings.isHistogram()) {
histogram = null;
} else {
histogram = new DoubleHistogram(metricSettings.getSignificantdigits());
}
}
void add(Number x) {
outputFormat = AssumedType.COUNTER;
count += x.longValue();
}
void put(Number x) {
outputFormat = AssumedType.GAUGE;
current = x.doubleValue();
if (histogram != null) {
histogram.recordValue(current);
}
if (count > 0) {
max = Math.max(current, max);
min = Math.min(current, min);
sum += current;
} else {
max = current;
min = current;
sum = current;
}
++count;
}
UntypedMetric pruneData() {
UntypedMetric pruned = new UntypedMetric(null);
pruned.outputFormat = this.outputFormat;
pruned.current = this.current;
return pruned;
}
void merge(UntypedMetric other, boolean otherIsNewer) throws IllegalArgumentException {
if (outputFormat == AssumedType.NONE) {
outputFormat = other.outputFormat;
}
if (outputFormat != other.outputFormat) {
throw new IllegalArgumentException("Mismatching output formats: " + outputFormat + " and " + other.outputFormat + ".");
}
count += other.count;
if (otherIsNewer) {
current = other.current;
}
max = Math.max(other.max, max);
min = Math.min(other.min, min);
sum += other.sum;
if (histogram != null) {
// some config scenarios may lead to differing histogram settings,
// so doing this defensively
if (other.histogram != null) {
try {
histogram.add(other.histogram);
} catch (ArrayIndexOutOfBoundsException e) {
log.log(LogLevel.WARNING, "Had trouble merging histograms: " + e.getMessage());
}
}
}
}
public boolean isCounter() { return outputFormat == AssumedType.COUNTER; }
public long getCount() { return count; }
public double getLast() { return current; }
public double getMax() { return max; }
public double getMin() { return min; }
public double getSum() { return sum; }
MetricSettings getMetricDefinition() {
return metricSettings;
}
public DoubleHistogram getHistogram() {
return histogram;
}
@Override
public String toString() {
StringBuilder buf = new StringBuilder();
buf.append(this.getClass().getName()).append(": ");
buf.append("outputFormat=").append(outputFormat).append(", ");
if (count > 0 && outputFormat == AssumedType.GAUGE) {
buf.append("max=").append(max).append(", ");
buf.append("min=").append(min).append(", ");
buf.append("sum=").append(sum).append(", ");
}
if (histogram != null) {
buf.append("histogram=").append(histogram).append(", ");
}
if (metricSettings != null) {
buf.append("metricSettings=").append(metricSettings).append(", ");
}
buf.append("current=").append(current).append(", ");
buf.append("count=").append(count);
return buf.toString();
}
}
|
