Add Secondary Reporters (#88)

Add Secondary Reporters
davenverse · Dec 4, 2019 · 0001e33 · 0001e33
2 parents 014d4a2 + a63c30a
commit 0001e33
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/src/main/scala/io/chrisdavenport/epimetheus/http4s/EpimetheusOps.scala b/core/src/main/scala/io/chrisdavenport/epimetheus/http4s/EpimetheusOps.scala
@@ -69,7 +69,7 @@ object EpimetheusOps {
   ): F[MetricsOps[F]] = 
     register(cr, Name("org_http4s_server"), buckets, reportMethod, reportStatus)
 
-  def  client[F[_]: Sync](
+  def client[F[_]: Sync](
     cr: CollectorRegistry[F],
     buckets: List[Double] = Histogram.defaults,
     reportMethod: Method => String = EpimetheusOps.defaultReportMethod,
@@ -123,7 +123,6 @@ object EpimetheusOps {
         .observe(nanosToSeconds(elapsed))
   }
 
-
   // Elapsed is in Nanos, but buckets are in Seconds
   private def nanosToSeconds(l: Long): Double = 
     l / nanoseconds_per_second
@@ -198,6 +197,7 @@ object EpimetheusOps {
       case _ => "5xx"
     }
 
+  def secondaryReportStatus(status: Status): String = status.code.show
 
   def defaultReportMethod(m: Method): String = m match {
     case Method.GET => "get"
@@ -212,6 +212,8 @@ object EpimetheusOps {
     case _ => "other"
   }
 
+  def secondaryReportMethod(m: Method): String = m.name.toLowerCase()
+
   private def reportTermination(t: TerminationType): String = t match {
     case Abnormal => "abnormal"
     case Error => "error"