Commit acfaf51f authored Mar 08, 2017 by Leonardo Menezes

created catMaster api call

parent da94648a

app/elastic/ElasticClient.scala

+3 −0

Original line number	Diff line number	Diff line
		@@ -110,6 +110,9 @@ trait ElasticClient {
		// Cat requests
		def catRequest(api: String, target: ElasticServer): Future[ElasticResponse]

		// Cat master
		def catMaster(target: ElasticServer): Future[ElasticResponse]

		def executeRequest(method: String, path: String, data: Option[JsValue], target: ElasticServer): Future[ElasticResponse]

		}

app/elastic/HTTPElasticClient.scala

+5 −0

Original line number	Diff line number	Diff line
		@@ -8,6 +8,7 @@ import play.api.libs.json._
		import play.api.libs.ws.{WSAuthScheme, WSClient}

		import scala.concurrent.ExecutionContext.Implicits.global
		import scala.concurrent.Future

		@Singleton
		class HTTPElasticClient @Inject()(client: WSClient) extends ElasticClient {
		@@ -301,4 +302,8 @@ class HTTPElasticClient @Inject()(client: WSClient) extends ElasticClient {
		}
		}

		override def catMaster(target: ElasticServer): Future[ElasticResponse] = {
		val path = "/_cat/master"
		execute(s"${target.host}$path?format=json", "GET", None, target.authentication)
		}
		}