package  org.scalastuff.esclient
import org.elasticsearch.client.Client

implicit class ESClient(client : Client) extends AnyVal {
  def execute[Request, Response](request: Request): Future[Response]
}

 libraryDependencies += "org.scalastuff" %% "esclient" % "0.90.2"

import scala.concurrent.Await
import scala.concurrent.Future
import scala.concurrent.duration.DurationInt

import org.elasticsearch.action.index.IndexRequest
import org.elasticsearch.action.index.IndexResponse
import org.elasticsearch.client.Client
import org.elasticsearch.node.NodeBuilder.nodeBuilder
import org.scalastuff.esclient._

object TestES extends App {

  val client : Client = 
    nodeBuilder.node.client
  
  val response : Future[IndexResponse] = 
    client.execute(new IndexRequest) 
  
  println("Document id: " + Await.result(response, 5 seconds).id)

  // --- or if you like ---
  val preparedResponse = client.prepareIndex.execute.future

  println("Document id: " + Await.result(preparedResponse, 5 seconds).id)
}