vertx / io.vertx.spi.cluster.zookeeper / ZookeeperClusterManager

# ZookeeperClusterManager

`open class ZookeeperClusterManager : ClusterManager, PathChildrenCacheListener`

A cluster manager that uses Zookeeper

Author
Stream.Liu

### Constructors

<init> | `ZookeeperClusterManager()` `ZookeeperClusterManager(curator: CuratorFramework)` `ZookeeperClusterManager(resourceLocation: String)` `ZookeeperClusterManager(curator: CuratorFramework, nodeID: String)` `ZookeeperClusterManager(config: JsonObject)`

### Functions

childEvent | `open fun childEvent(client: CuratorFramework, event: PathChildrenCacheEvent): Unit`
getAsyncMap | `open fun <K : Any, V : Any> getAsyncMap(name: String, handler: Handler<AsyncResult<AsyncMap<K, V>>>): Unit`
getAsyncMultiMap | `open fun <K : Any, V : Any> getAsyncMultiMap(name: String, handler: Handler<AsyncResult<AsyncMultiMap<K, V>>>): Unit` Every eventbus handler has an ID. SubsMap (subscriber map) is a MultiMap which maps handler-IDs with server-IDs and thus allows the eventbus to determine where to send messages.
getConfig | `open fun getConfig(): JsonObject`
getCounter | `open fun getCounter(name: String, resultHandler: Handler<AsyncResult<Counter>>): Unit`
getCuratorFramework | `open fun getCuratorFramework(): CuratorFramework`
getLockWithTimeout | `open fun getLockWithTimeout(name: String, timeout: Long, resultHandler: Handler<AsyncResult<Lock>>): Unit`
getNodeID | `open fun getNodeID(): String`
getNodes | `open fun getNodes(): MutableList<String>`
getSyncMap | `open fun <K : Any, V : Any> getSyncMap(name: String): MutableMap<K, V>`
isActive | `open fun isActive(): Boolean`
join | `open fun join(resultHandler: Handler<AsyncResult<Void>>): Unit`
leave | `open fun leave(resultHandler: Handler<AsyncResult<Void>>): Unit`
nodeListener | `open fun nodeListener(listener: NodeListener): Unit`
setConfig | `open fun setConfig(conf: JsonObject): Unit`
setVertx | `open fun setVertx(vertx: Vertx): Unit`