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
|
// Copyright 2020 Oath Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package ai.vespa.metricsproxy.metric;
import ai.vespa.metricsproxy.metric.model.ConsumerId;
import ai.vespa.metricsproxy.metric.model.DimensionId;
import ai.vespa.metricsproxy.metric.model.MetricId;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;
/**
* @author Jo Kristian Bergum
*/
public class Metric {
private final long time;
private final Number value;
private final String description;
private MetricId name;
private Map<DimensionId, String> dimensions;
private Set<ConsumerId> consumers;
/**
* Creates a new metric instance
*
* @param name The metric name. E.g 'documents'
* @param value The numeric value
* @param time The timestamp of this metric in seconds
*/
public Metric(MetricId name, Number value, long time, Map<DimensionId, String> dimensions, String description) {
this.time = time;
this.value = value;
this.name = name;
this.dimensions = dimensions;
this.description = description;
}
public Metric(MetricId name, Number value, long timestamp) {
this(name, value, timestamp, Collections.emptyMap(), "");
}
public Metric(MetricId name, Number value) {
this(name, value, System.currentTimeMillis() / 1000);
}
public void setDimensions(Map<DimensionId, String> dimensions) {
this.dimensions = dimensions;
}
/**
* @return A map of the dimensions registered for this metric
*/
public Map<DimensionId, String> getDimensions() { return dimensions; }
public void setConsumers(Set<ConsumerId> consumers) { this.consumers = consumers; }
/**
* @return The consumers this metric should be routed to.
*/
public Set<ConsumerId> getConsumers() { return consumers; }
/**
* @return The number that this metric name represent
*/
public Number getValue() {
return value;
}
/**
* Set the name of this metric
*
* @param name The name to use for this metric
*/
public void setName(MetricId name) {
this.name = name;
}
/**
* @return The name of the metric
*/
public MetricId getName() {
return name;
}
/**
* @return The UTC timestamp for when this metric was collected
*/
public long getTimeStamp() {
return this.time;
}
@Override
public String toString() {
return "Metric{" +
"time=" + time +
", name=" + name.id +
", value='" + value + '\'' +
", dimensions=" + dimensions +
'}';
}
@Override
public Metric clone() {
return new Metric(name, value, time, new LinkedHashMap<>(dimensions), getDescription());
}
/**
* @return the description of this metric
*/
public String getDescription() {
return this.description;
}
/** Return an adjusted (rounded up) time if necessary */
public static long adjustTime(long timestamp, long now) {
if ((now == (timestamp+1)) && ((now % 60) == 0)) {
return now;
}
return timestamp;
}
}
|
