From 008283e63e01d67cfdaee6976474a5272a0b1e91 Mon Sep 17 00:00:00 2001
From: vlad <vlad@drivergrp.com>
Date: Wed, 12 Oct 2016 13:00:29 -0700
Subject: App /health endpoint with info related to OS, memory, file system and
 GC

---
 src/main/scala/com/drivergrp/core/app.scala | 35 ++++++++++++++++++++++++++++-
 1 file changed, 34 insertions(+), 1 deletion(-)

(limited to 'src/main/scala/com/drivergrp/core/app.scala')

diff --git a/src/main/scala/com/drivergrp/core/app.scala b/src/main/scala/com/drivergrp/core/app.scala
index a1e1082..f6100f0 100644
--- a/src/main/scala/com/drivergrp/core/app.scala
+++ b/src/main/scala/com/drivergrp/core/app.scala
@@ -11,6 +11,7 @@ import akka.http.scaladsl.server.{ExceptionHandler, Route, RouteConcatenation}
 import akka.stream.ActorMaterializer
 import com.drivergrp.core.logging.{Logger, TypesafeScalaLogger}
 import com.drivergrp.core.rest.Swagger
+import com.drivergrp.core.stats.SystemStats
 import com.drivergrp.core.time.Time
 import com.drivergrp.core.time.provider.{SystemTimeProvider, TimeProvider}
 import com.typesafe.config.Config
@@ -99,7 +100,7 @@ object app {
 
       val _ = Future {
         http.bindAndHandle(route2HandlerFlow(handleExceptions(generalExceptionHandler) {
-          logRequestResult("log")(modules.map(_.route).foldLeft(versionRt ~ swaggerRoutes)(_ ~ _))
+          logRequestResult("log")(modules.map(_.route).foldLeft(versionRt ~ healthRoute ~ swaggerRoutes)(_ ~ _))
         }), interface, port)(materializer)
       }
     }
@@ -122,6 +123,38 @@ object app {
       }
     }
 
+    protected def healthRoute: Route = {
+      import DefaultJsonProtocol._
+      import SprayJsonSupport._
+      import spray.json._
+
+      val memoryUsage = SystemStats.memoryUsage
+      val gcStats     = SystemStats.garbageCollectorStats
+
+      path("health") {
+        complete(
+            Map(
+                "availableProcessors" -> SystemStats.availableProcessors.toJson,
+                "memoryUsage" -> Map(
+                    "free"  -> memoryUsage.free.toJson,
+                    "total" -> memoryUsage.total.toJson,
+                    "max"   -> memoryUsage.max.toJson
+                ).toJson,
+                "gcStats" -> Map(
+                    "garbageCollectionTime"   -> gcStats.garbageCollectionTime.toJson,
+                    "totalGarbageCollections" -> gcStats.totalGarbageCollections.toJson
+                ).toJson,
+                "fileSystemSpace" -> SystemStats.fileSystemSpace.map { f =>
+              Map("path"        -> f.path.toJson,
+                  "freeSpace"   -> f.freeSpace.toJson,
+                  "totalSpace"  -> f.totalSpace.toJson,
+                  "usableSpace" -> f.usableSpace.toJson)
+            }.toJson,
+                "operatingSystem" -> SystemStats.operatingSystemStats.toJson
+            ))
+      }
+    }
+
     /**
       * Initializes services
       */
-- 
cgit v1.2.3