split overview models into own files (bd6650f4) · Commits · nimrod / cerebro

app/models/overview/ClosedIndices.scala

0 → 100644

+18 −0

Original line number	Diff line number	Diff line
		package models.overview

		import play.api.libs.json._

		object ClosedIndices {

		def apply(clusterState: JsValue) = {
		val blocks = (clusterState \ "blocks" \ "indices").asOpt[JsObject].getOrElse(Json.obj())
		blocks.keys.collect {
		case index if (blocks \ index \ "4").asOpt[JsObject].isDefined =>
		Json.obj(
		"name" -> JsString(index),
		"closed" -> JsBoolean(true),
		"special" -> JsBoolean(index.startsWith("."))
		)
		}
		}
		}

app/models/overview/ClusterOverview.scala

+0 −110

Original line number	Diff line number	Diff line
		@@ -37,113 +37,3 @@ object ClusterOverview {
		))
		}
		}

		object Nodes {

		def apply(clusterState: JsValue, nodesStats: JsValue, nodes: JsValue): Seq[JsValue] = {
		val currentMaster = (clusterState \ "master_node").as[String]
		(nodes \ "nodes").as[JsObject].value.map { case (nodeId, info) =>

		val nodeRoles = NodeRoles(info)
		val stats = (nodesStats \ "nodes" \ nodeId).as[JsObject]
		val totalInBytes = (stats \ "fs" \ "total" \ "total_in_bytes").asOpt[Long].getOrElse(0l)
		val diskFreeInBytes = (stats \ "fs" \ "total" \ "free_in_bytes").asOpt[Long].getOrElse(0l)
		Json.obj(
		"id" -> JsString(nodeId),
		"current_master" -> JsBoolean(nodeId.equals(currentMaster)),
		"name" -> (info \ "name").as[JsString],
		"host" -> (info \ "host").as[JsString],
		"ip" -> (info \ "ip").as[JsString],
		"es_version" -> (info \ "version").as[JsString],
		"jvm_version" -> (info \ "jvm" \ "version").as[JsString],
		"load_average" -> loadAverage(stats),
		"available_processors" -> (info \ "os" \ "available_processors").as[JsNumber],
		"cpu_percent" -> cpuPercent(stats),
		"master" -> JsBoolean(nodeRoles.master),
		"data" -> JsBoolean(nodeRoles.data),
		"client" -> JsBoolean(nodeRoles.client),
		"ingest" -> JsBoolean(nodeRoles.ingest),
		"heap" -> Json.obj(
		"used" -> (stats \ "jvm" \ "mem" \ "heap_used_in_bytes").as[JsNumber],
		"committed" -> (stats \ "jvm" \ "mem" \ "heap_committed_in_bytes").as[JsNumber],
		"used_percent" -> (stats \ "jvm" \ "mem" \ "heap_used_percent").as[JsNumber],
		"max" -> (stats \ "jvm" \ "mem" \ "heap_max_in_bytes").as[JsNumber]
		),
		"disk" -> Json.obj(
		"total_in_bytes" -> JsNumber(totalInBytes),
		"disk_free_in_bytes" -> JsNumber(diskFreeInBytes),
		"used_percent" -> JsNumber(100 - (100 * (diskFreeInBytes.toFloat / totalInBytes.toFloat)).toInt)
		)
		)
		}.toSeq
		}

		def loadAverage(nodeStats: JsValue): JsNumber = {
		val load = (nodeStats \ "os" \ "cpu" \ "load_average" \ "1m").asOpt[Float].getOrElse( // 5.X
		(nodeStats \ "os" \ "load_average").asOpt[Float].getOrElse(0f) // FIXME: 2.X
		)
		JsNumber(BigDecimal(load.toDouble))
		}

		def cpuPercent(nodeStats: JsValue): JsNumber = {
		val cpu = (nodeStats \ "os" \ "cpu" \ "percent").asOpt[Int].getOrElse( // 5.X
		(nodeStats \ "os" \ "cpu_percent").asOpt[Int].getOrElse(0) // FIXME 2.X
		)
		JsNumber(BigDecimal(cpu))
		}

		}

		object Indices {

		def apply(clusterState: JsValue, indicesStats: JsValue, aliases: JsValue) = {
		val routingTable = (clusterState \ "routing_table" \ "indices").as[JsObject]
		val openIndices = routingTable.value.map { case (index, shards) =>
		val stats = (indicesStats \ "indices" \ index).asOpt[JsObject].getOrElse(Json.obj())
		val indexShards = (shards \ "shards").as[JsObject].values.flatMap { case shards =>
		shards.as[JsArray].value.map { instance =>
		(instance \ "node").asOpt[String].getOrElse("unassigned") -> instance
		}
		}.groupBy(_._1).mapValues { shards => JsArray(shards.map(_._2).toSeq) }.toSeq

		val numShards = (shards \ "shards").as[JsObject].keys.size
		val numReplicas = (shards \ "shards" \ "0").as[JsArray].value.size - 1

		val unhealthy = indexShards.find(_._1.equals("unassigned")).isDefined
		val special = index.startsWith(".")

		JsObject(Seq(
		"name" -> JsString(index),
		"closed" -> JsBoolean(false),
		"special" -> JsBoolean(special),
		"unhealthy" -> JsBoolean(unhealthy),
		"doc_count" -> (stats \ "primaries" \ "docs" \ "count").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"deleted_docs" -> (stats \ "primaries" \ "docs" \ "deleted").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"size_in_bytes" -> (stats \ "primaries" \ "store" \ "size_in_bytes").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"total_size_in_bytes" -> (stats \ "total" \ "store" \ "size_in_bytes").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"aliases" -> JsArray((aliases \ index \ "aliases").asOpt[JsObject].getOrElse(Json.obj()).keys.map(JsString(_)).toSeq), // 1.4 < does not return aliases obj
		"num_shards" -> JsNumber(numShards),
		"num_replicas" -> JsNumber(numReplicas),
		"shards" -> JsObject(indexShards)
		))
		}.toSeq

		openIndices ++ ClosedIndices(clusterState)
		}

		}

		object ClosedIndices {

		def apply(clusterState: JsValue) = {
		val blocks = (clusterState \ "blocks" \ "indices").asOpt[JsObject].getOrElse(Json.obj())
		blocks.keys.collect {
		case index if (blocks \ index \ "4").asOpt[JsObject].isDefined =>
		Json.obj(
		"name" -> JsString(index),
		"closed" -> JsBoolean(true),
		"special" -> JsBoolean(index.startsWith("."))
		)
		}
		}
		}

app/models/overview/Indices.scala

0 → 100644

+42 −0

Original line number	Diff line number	Diff line
		package models.overview

		import play.api.libs.json._

		object Indices {

		def apply(clusterState: JsValue, indicesStats: JsValue, aliases: JsValue) = {
		val routingTable = (clusterState \ "routing_table" \ "indices").as[JsObject]
		val openIndices = routingTable.value.map { case (index, shards) =>
		val stats = (indicesStats \ "indices" \ index).asOpt[JsObject].getOrElse(Json.obj())
		val indexShards = (shards \ "shards").as[JsObject].values.flatMap { case shards =>
		shards.as[JsArray].value.map { instance =>
		(instance \ "node").asOpt[String].getOrElse("unassigned") -> instance
		}
		}.groupBy(_._1).mapValues { shards => JsArray(shards.map(_._2).toSeq) }.toSeq

		val numShards = (shards \ "shards").as[JsObject].keys.size
		val numReplicas = (shards \ "shards" \ "0").as[JsArray].value.size - 1

		val unhealthy = indexShards.find(_._1.equals("unassigned")).isDefined
		val special = index.startsWith(".")

		JsObject(Seq(
		"name" -> JsString(index),
		"closed" -> JsBoolean(false),
		"special" -> JsBoolean(special),
		"unhealthy" -> JsBoolean(unhealthy),
		"doc_count" -> (stats \ "primaries" \ "docs" \ "count").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"deleted_docs" -> (stats \ "primaries" \ "docs" \ "deleted").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"size_in_bytes" -> (stats \ "primaries" \ "store" \ "size_in_bytes").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"total_size_in_bytes" -> (stats \ "total" \ "store" \ "size_in_bytes").asOpt[JsNumber].getOrElse(JsNumber(0)),
		"aliases" -> JsArray((aliases \ index \ "aliases").asOpt[JsObject].getOrElse(Json.obj()).keys.map(JsString(_)).toSeq), // 1.4 < does not return aliases obj
		"num_shards" -> JsNumber(numShards),
		"num_replicas" -> JsNumber(numReplicas),
		"shards" -> JsObject(indexShards)
		))
		}.toSeq

		openIndices ++ ClosedIndices(clusterState)
		}

		}

app/models/overview/Nodes.scala

0 → 100644

+59 −0

Original line number	Diff line number	Diff line
		package models.overview

		import play.api.libs.json._

		object Nodes {

		def apply(clusterState: JsValue, nodesStats: JsValue, nodes: JsValue): Seq[JsValue] = {
		val currentMaster = (clusterState \ "master_node").as[String]
		(nodes \ "nodes").as[JsObject].value.map { case (nodeId, info) =>

		val nodeRoles = NodeRoles(info)
		val stats = (nodesStats \ "nodes" \ nodeId).as[JsObject]
		val totalInBytes = (stats \ "fs" \ "total" \ "total_in_bytes").asOpt[Long].getOrElse(0l)
		val diskFreeInBytes = (stats \ "fs" \ "total" \ "free_in_bytes").asOpt[Long].getOrElse(0l)
		Json.obj(
		"id" -> JsString(nodeId),
		"current_master" -> JsBoolean(nodeId.equals(currentMaster)),
		"name" -> (info \ "name").as[JsString],
		"host" -> (info \ "host").as[JsString],
		"ip" -> (info \ "ip").as[JsString],
		"es_version" -> (info \ "version").as[JsString],
		"jvm_version" -> (info \ "jvm" \ "version").as[JsString],
		"load_average" -> loadAverage(stats),
		"available_processors" -> (info \ "os" \ "available_processors").as[JsNumber],
		"cpu_percent" -> cpuPercent(stats),
		"master" -> JsBoolean(nodeRoles.master),
		"data" -> JsBoolean(nodeRoles.data),
		"client" -> JsBoolean(nodeRoles.client),
		"ingest" -> JsBoolean(nodeRoles.ingest),
		"heap" -> Json.obj(
		"used" -> (stats \ "jvm" \ "mem" \ "heap_used_in_bytes").as[JsNumber],
		"committed" -> (stats \ "jvm" \ "mem" \ "heap_committed_in_bytes").as[JsNumber],
		"used_percent" -> (stats \ "jvm" \ "mem" \ "heap_used_percent").as[JsNumber],
		"max" -> (stats \ "jvm" \ "mem" \ "heap_max_in_bytes").as[JsNumber]
		),
		"disk" -> Json.obj(
		"total_in_bytes" -> JsNumber(totalInBytes),
		"disk_free_in_bytes" -> JsNumber(diskFreeInBytes),
		"used_percent" -> JsNumber(100 - (100 * (diskFreeInBytes.toFloat / totalInBytes.toFloat)).toInt)
		)
		)
		}.toSeq
		}

		def loadAverage(nodeStats: JsValue): JsNumber = {
		val load = (nodeStats \ "os" \ "cpu" \ "load_average" \ "1m").asOpt[Float].getOrElse( // 5.X
		(nodeStats \ "os" \ "load_average").asOpt[Float].getOrElse(0f) // FIXME: 2.X
		)
		JsNumber(BigDecimal(load.toDouble))
		}

		def cpuPercent(nodeStats: JsValue): JsNumber = {
		val cpu = (nodeStats \ "os" \ "cpu" \ "percent").asOpt[Int].getOrElse( // 5.X
		(nodeStats \ "os" \ "cpu_percent").asOpt[Int].getOrElse(0) // FIXME 2.X
		)
		JsNumber(BigDecimal(cpu))
		}

		}