Add GraphiteReporter.Builder.timedThresholdMicros()

This can be used typically when using enhancement to add metrics
to all spring components or all avaje-inject components to
filter out timing metrics and not report them when
method total execution time does not exceed the
threshold specified.

Author: rbygrave

metrics-graphite/src/main/java/io/avaje/metrics/graphite/DGraphiteBuilder.java

@@ -17,6 +17,7 @@ final class DGraphiteBuilder implements GraphiteReporter.Builder {
   private String prefix;
   private String hostname;
   private int port;
+  private long timedThresholdMicros;
   private SocketFactory socketFactory = SSLSocketFactory.getDefault();
 
   private final List<GraphiteSender.Reporter> reporters = new ArrayList<>();
@@ -57,7 +58,14 @@ public DGraphiteBuilder excludeDefaultRegistry() {
     this.excludeDefaultRegistry = true;
     return this;
   }
-    @Override
+
+  @Override
+  public DGraphiteBuilder timedThresholdMicros(int timedThresholdMicros) {
+    this.timedThresholdMicros = timedThresholdMicros;
+    return this;
+  }
+
+  @Override
   public DGraphiteBuilder database(Database database) {
     reporters.add(DatabaseReporter.reporter(database));
     return this;
@@ -84,11 +92,11 @@ private GraphiteSender buildSender() {
       throw new IllegalStateException("Unknown host " + address.getHostName());
     }
 
-    return new DGraphiteSender(address, socketFactory, batchSize, prefix);
+    return new DGraphiteSender(address, socketFactory, batchSize, prefix, timedThresholdMicros);
   }
 
   public GraphiteReporter build() {
-    if (!excludeDefaultRegistry){
+    if (!excludeDefaultRegistry) {
       reporters.add(new DRegistryReporter(Metrics.registry()));
     }
     return new DGraphiteReporter(buildSender(), reporters);

metrics-graphite/src/main/java/io/avaje/metrics/graphite/DGraphiteSender.java

@@ -38,14 +38,16 @@ final class DGraphiteSender implements GraphiteSender {
   private final InetSocketAddress address;
   private final SocketFactory socketFactory;
   private final String prefix;
+  private final long timedThreshold;
   private Socket socket;
   private Writer writer;
 
-  DGraphiteSender(InetSocketAddress address, SocketFactory socketFactory, int batchSize, String prefix) {
+  DGraphiteSender(InetSocketAddress address, SocketFactory socketFactory, int batchSize, String prefix, long timedThreshold) {
     this.address = address;
     this.socketFactory = socketFactory;
     this.batchSize = batchSize;
     this.prefix = prefix;
+    this.timedThreshold = timedThreshold;
   }
 
   @Override
@@ -80,11 +82,13 @@ public void send(List<Metric.Statistics> metrics) {
 
   private class MetricsVisitor implements Metric.Visitor {
 
-    final long epochSecs = System.currentTimeMillis() / 1000;
+    private final long epochSecs = System.currentTimeMillis() / 1000;
 
     @Override
     public void visit(Timer.Stats timed) {
-      sendValues(timed);
+      if (timedThreshold == 0 || timedThreshold < timed.total()) {
+        sendValues(timed);
+      }
     }
 
     @Override
@@ -162,7 +166,7 @@ public void close() throws IOException {
    * 3. Clear out the list of metrics
    */
   private void writeMetrics() throws IOException {
-    if (metrics.size() > 0) {
+    if (!metrics.isEmpty()) {
       try {
         byte[] payload = pickleMetrics(metrics);
         byte[] header = ByteBuffer.allocate(4).putInt(payload.length).array();

metrics-graphite/src/main/java/io/avaje/metrics/graphite/GraphiteReporter.java

@@ -94,6 +94,21 @@ interface Builder {
      */
     Builder excludeDefaultRegistry();
 
+    /**
+     * Set a threshold where timed metrics with total time less than the
+     * threshold are not reported.
+     * <p>
+     * This can use used to when metrics are applied fairly globally (for
+     * example on all Spring components or all avaje-inject components)
+     * and hence can include methods that are not that interesting for
+     * collecting timing on.
+     * <p>
+     * Setting this to 1000 (which is 1 millisecond) when reporting every 1 minute
+     * means that methods with total execution time less than 1ms in a one-minute period
+     * will not be reported.
+     */
+    Builder timedThresholdMicros(int timedThresholdMicros);
+
     /**
      * Include Ebean Database metrics in the reporting.
      * <p>