code example for Reporters

[hhadind]

any examples for using reporters like the ConsoleReporter or the CvsReporter ?
thanks in advance.

[scullxbones]

They're fairly straight-forward to set up. Enhancing the manual example a little bit:

object YourApplication {
  /** The application wide metrics registry. */
  val metricRegistry = { 
    val registry = new com.codahale.metrics.MetricRegistry()
    ConsoleReporter.forRegistry(registry)
      .convertRatesTo(TimeUnit.SECONDS)
      .convertDurationsTo(TimeUnit.MILLISECONDS)
      .build()
      .start(1, TimeUnit.MINUTES)
    registry
  }
}

[hhadind]

thank you @scullxbones for responding. I am still new to this package so excuse the basic question, when I integrated your code above into the example, I still do not see anything being sent to the console , here is the code :

import com.codahale.metrics.ConsoleReporter
import com.codahale.metrics.Timer

import java.util.concurrent.TimeUnit;

object YourApplication {
  /** The application wide metrics registry. */
  val metricRegistry = {
    val registry = new com.codahale.metrics.MetricRegistry()
    ConsoleReporter.forRegistry(registry)
      .convertRatesTo(TimeUnit.SECONDS)
      .convertDurationsTo(TimeUnit.MILLISECONDS)
      .build()
      .start(1, TimeUnit.MINUTES)
    registry
  }
}

trait Instrumented extends nl.grons.metrics.scala.InstrumentedBuilder {
  val metricRegistry = YourApplication.metricRegistry

}

class Example(db: List[Int]) extends Instrumented {
  private[this] val loading = metrics.timer("loading")
  def loadStuff(): Seq[Int] = loading.time {
    val k = (1 to 100)
    k.toSeq
  }
}

object metric extends Instrumented {

  def main(args: Array[String]) {

    val o = new Example(List(1)).loadStuff()

  }
}

[scullxbones]

Sure, happy to help.

Note the timing of the reporter - .start(1, TimeUnit.MINUTES). I believe this will only write to console every minute. If your example doesn't run that long, you wouldn't see anything. You could try a shorter interval and see if that improves things.

[hhadind]

uh... that was really a rocky mistake :) modified my code as such and it worked fine :

import com.codahale.metrics.ConsoleReporter
import com.codahale.metrics.Timer

import java.util.concurrent.TimeUnit;

object YourApplication {
  /** The application wide metrics registry. */
  val metricRegistry = {
    val registry = new com.codahale.metrics.MetricRegistry()
    ConsoleReporter.forRegistry(registry)
      .convertRatesTo(TimeUnit.SECONDS)
      .convertDurationsTo(TimeUnit.MILLISECONDS)
      .build()
      .start(1, TimeUnit.SECONDS) //changed the interval to seconds instead of minutes
    registry
  }
}

trait Instrumented extends nl.grons.metrics.scala.InstrumentedBuilder {

  val metricRegistry = YourApplication.metricRegistry

}

class Example(db: List[Int]) extends Instrumented {
  private[this] val loading = metrics.timer("loading")

  def loadStuff(): Seq[Int] = loading.time {
    val k = (1 to 100)
    k.toSeq
  }
}

object metric extends Instrumented {
  def wait5Seconds() {
    try {
      Thread.sleep(5 * 1000);
    } catch {
      case e: InterruptedException =>
    }

  }

  def main(args: Array[String]) {

    val o = new Example(List(1)).loadStuff()
    wait5Seconds //forced program to wait for 5 seconds 
  }
}

thanks again.

[erikvanoosten]

Hi @hhadind , can we close this issue?

[hhadind]

sure thanks again.

[atz]

Very helpful. Recommend reopening this, since no Reporter examples are currently in the Manual.

[erikvanoosten]

Hi @atz, a pull request would be amazing!