Simple, yet powerful fs2 bindings for Apache Zookeeper.
Library reuses Zookeeper client, and wraps fs2 around it allowing some very simple distributed primitives.
Add this to your sbt build file :
libraryDependencies += "com.spinoco" %% "fs2-zk" % "0.4.0"
Library does not have other dependencies than fs2 and zookeeper client itself:
| version | scala | fs2 | zookeeper |
|---|---|---|---|
| 0.4.0 | 2.11, 2.12 | 1.0.0 | 3.4.10 |
| 0.2.0 | 2.11, 2.12 | 0.10.0 | 3.4.10 |
| 0.1.6 | 2.11, 2.12 | 0.9.7 | 3.4.10 |
import spinoco.fs2.zk._
// monitor all children of given node 'node1'
// by discrete stream of changes
client("yourZkConnectString") flatMap { zkc =>
clientTo(zks) flatMap { zkc => zkc.childrenOf(node1) }
}
More examples you may found in Tests here