diff options
author | vlad <vlad@drivergrp.com> | 2016-10-12 13:00:29 -0700 |
---|---|---|
committer | vlad <vlad@drivergrp.com> | 2016-10-12 13:00:29 -0700 |
commit | 008283e63e01d67cfdaee6976474a5272a0b1e91 (patch) | |
tree | 254b00ef485573cacb4e9ee7761cf53205c0021f /src/main/scala/com/drivergrp/core/app.scala | |
parent | 461d08d2caefac4798eb5ac3fa3c0c421603de60 (diff) | |
download | driver-core-008283e63e01d67cfdaee6976474a5272a0b1e91.tar.gz driver-core-008283e63e01d67cfdaee6976474a5272a0b1e91.tar.bz2 driver-core-008283e63e01d67cfdaee6976474a5272a0b1e91.zip |
App /health endpoint with info related to OS, memory, file system and GCv0.9.2
Diffstat (limited to 'src/main/scala/com/drivergrp/core/app.scala')
-rw-r--r-- | src/main/scala/com/drivergrp/core/app.scala | 35 |
1 files changed, 34 insertions, 1 deletions
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 */ |