libraryDependencies += "com.github.mingchuno" %% "etcd4s-core" % "0.4.0"

libraryDependencies += "com.github.mingchuno" %% "etcd4s-akka-stream" % "0.4.0"

import org.etcd4s.{Etcd4sClientConfig, Etcd4sClient}
import org.etcd4s.implicits._
import org.etcd4s.formats._
import org.etcd4s.pb.etcdserverpb._

import scala.concurrent.ExecutionContext.Implicits.global

// create the client
val config = Etcd4sClientConfig(
  address = "127.0.0.1",
  port = 2379
)
val client = Etcd4sClient.newClient(config)

// set a key
client.setKey("foo", "bar") // return a Future

// get a key
client.getKey("foo").foreach { result =>
  assert(result == Some("bar"))
}

// delete a key
client.deleteKey("foo").foreach { result =>
  assert(result == 1)
}

// set more key
client.setKey("foo/bar", "Hello")
client.setKey("foo/baz", "World")

// get keys with range
client.getRange("foo/").foreach { result =>
  assert(result.count == 2)
}

// remember to shutdown the client
client.shutdown()

client.kvApi.range(...)
client.kvApi.put(...)
client.leaseApi.leaseGrant(...)
client.electionApi.leader(...)

import org.etcd4s.akkasupport._
import org.etcd4s.implicits._
import org.etcd4s.pb.etcdserverpb._
import akka.NotUsed

// assume you have the implicit value and client needed in the scope
val flow: Flow[WatchRequest, WatchResponse, NotUsed] = client.watchApi.watchFlow
val request: WatchRequest = WatchRequest().withCreateRequest(WatchCreateRequest().withKey("foo"))
Source.single(request)
  .via(flow)
  .runForeach { resp =>
    println(resp)
  }