Skip to content

Commit cc55d55

Browse files
committed
Merge pull request #13 from mkeesey/readytalk-master
Fix metric names for timers, meters, and histograms. Add ".samples" to reads from count()
2 parents a122960 + f1d330d commit cc55d55

File tree

5 files changed

+9
-9
lines changed

5 files changed

+9
-9
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
allprojects {
2-
version = '4.0.0'
2+
version = '4.1.0-SNAPSHOT'
33
}
44

55
buildscript {

metrics2-statsd/src/main/java/com/readytalk/metrics/StatsDReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ protected void printRegularMetrics(long epoch) {
134134
@Override
135135
public void processMeter(MetricName name, Metered meter, Long epoch) {
136136
final String sanitizedName = sanitizeName(name);
137-
sendToStatsD(sanitizedName, formatNumber(meter.count()));
137+
sendToStatsD(sanitizedName + ".samples", formatNumber(meter.count()));
138138
sendToStatsD(sanitizedName + ".meanRate", formatNumber(meter.meanRate()));
139139
sendToStatsD(sanitizedName + ".1MinuteRate", formatNumber(meter.oneMinuteRate()));
140140
sendToStatsD(sanitizedName + ".5MinuteRate", formatNumber(meter.fiveMinuteRate()));

metrics2-statsd/src/test/java/com/readytalk/metrics/StatsDReporterTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ private void verifySend(String metricValue) {
104104
}
105105

106106
public void verifyTimer() {
107-
verifySend("1");
107+
verifySend("samples", "1");
108108
verifySend("meanRate", "2.00");
109109
verifySend("1MinuteRate", "1.00");
110110
verifySend("5MinuteRate", "5.00");
@@ -122,7 +122,7 @@ public void verifyTimer() {
122122
}
123123

124124
public void verifyMeter() {
125-
verifySend("1");
125+
verifySend("samples", "1");
126126
verifySend("meanRate", "2.00");
127127
verifySend("1MinuteRate", "1.00");
128128
verifySend("5MinuteRate", "5.00");

metrics3-statsd/src/main/java/com/readytalk/metrics/StatsDReporter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ private void reportTimer(final String name, final Timer timer) {
219219
}
220220

221221
private void reportMetered(final String name, final Metered meter) {
222-
statsD.send(prefix(name), formatNumber(meter.getCount()));
222+
statsD.send(prefix(name, "samples"), formatNumber(meter.getCount()));
223223
statsD.send(prefix(name, "m1_rate"), formatNumber(convertRate(meter.getOneMinuteRate())));
224224
statsD.send(prefix(name, "m5_rate"), formatNumber(convertRate(meter.getFiveMinuteRate())));
225225
statsD.send(prefix(name, "m15_rate"), formatNumber(convertRate(meter.getFifteenMinuteRate())));
@@ -228,7 +228,7 @@ private void reportMetered(final String name, final Metered meter) {
228228

229229
private void reportHistogram(final String name, final Histogram histogram) {
230230
final Snapshot snapshot = histogram.getSnapshot();
231-
statsD.send(prefix(name), formatNumber(histogram.getCount()));
231+
statsD.send(prefix(name, "samples"), formatNumber(histogram.getCount()));
232232
statsD.send(prefix(name, "max"), formatNumber(snapshot.getMax()));
233233
statsD.send(prefix(name, "mean"), formatNumber(snapshot.getMean()));
234234
statsD.send(prefix(name, "min"), formatNumber(snapshot.getMin()));

metrics3-statsd/src/test/java/com/readytalk/metrics/StatsDReporterTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ public void reportsHistograms() throws Exception {
165165
final InOrder inOrder = inOrder(statsD);
166166

167167
inOrder.verify(statsD).connect();
168-
verify(statsD).send("prefix.histogram", "1");
168+
verify(statsD).send("prefix.histogram.samples", "1");
169169
verify(statsD).send("prefix.histogram.max", "2");
170170
verify(statsD).send("prefix.histogram.mean", "3.00");
171171
verify(statsD).send("prefix.histogram.min", "4");
@@ -194,7 +194,7 @@ public void reportsMeters() throws Exception {
194194

195195
final InOrder inOrder = inOrder(statsD);
196196
inOrder.verify(statsD).connect();
197-
verify(statsD).send("prefix.meter", "1");
197+
verify(statsD).send("prefix.meter.samples", "1");
198198
verify(statsD).send("prefix.meter.m1_rate", "2.00");
199199
verify(statsD).send("prefix.meter.m5_rate", "3.00");
200200
verify(statsD).send("prefix.meter.m15_rate", "4.00");
@@ -242,7 +242,7 @@ public void reportsTimers() throws Exception {
242242
verify(statsD).send("prefix.timer.p98", "800.00");
243243
verify(statsD).send("prefix.timer.p99", "900.00");
244244
verify(statsD).send("prefix.timer.p999", "1000.00");
245-
verify(statsD).send("prefix.timer", "1");
245+
verify(statsD).send("prefix.timer.samples", "1");
246246
verify(statsD).send("prefix.timer.m1_rate", "3.00");
247247
verify(statsD).send("prefix.timer.m5_rate", "4.00");
248248
verify(statsD).send("prefix.timer.m15_rate", "5.00");

0 commit comments

Comments
 (0)