Apache Zookeeper bindings for fs2
Simple, yet powerful fs2 bindings for Apache Zookeeper.
Overview
Library reuses Zookeeper client, and wraps fs2 around it allowing some very simple distributed primitives.
SBT
Add this to your sbt build file :
libraryDependencies += "com.spinoco" %% "fs2-zk" % "0.4.0"
Dependencies
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 |
Simple usage
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