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
135
136
137
138
139
140
141
|
// Copyright Yahoo. 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.Objects;
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());
}
@Override
public boolean equals(Object obj) {
if ( ! (obj instanceof Metric) ) return false;
Metric rhs = (Metric) obj;
return name.equals(rhs.name)
&& description.equals(rhs.description)
&& value.equals(rhs.value)
&& (time == rhs.time)
&& Objects.equals(dimensions, rhs.dimensions)
&& Objects.equals(consumers, rhs.consumers);
}
@Override
public int hashCode() {
return Objects.hash(name, description, value, dimensions, consumers, time);
}
/**
* @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;
}
}
|
