open class ZookeeperClusterManager : ClusterManager, PathChildrenCacheListener
A cluster manager that uses Zookeeper
Author
Stream.Liu
ZookeeperClusterManager()ZookeeperClusterManager(curator: CuratorFramework)ZookeeperClusterManager(resourceLocation: String)ZookeeperClusterManager(curator: CuratorFramework, nodeID: String)ZookeeperClusterManager(config: JsonObject) |
open fun childEvent(client: CuratorFramework, event: PathChildrenCacheEvent): Unit |
|
open fun <K : Any, V : Any> getAsyncMap(: String, : Handler<AsyncResult<AsyncMap<K, V>>>): Unit |
|
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. |
|
open fun getConfig(): JsonObject |
|
open fun getCounter(: String, : Handler<AsyncResult<Counter>>): Unit |
|
open fun getCuratorFramework(): CuratorFramework |
|
open fun getLockWithTimeout(: String, : Long, : Handler<AsyncResult<Lock>>): Unit |
|
open fun getNodeID(): String |
|
open fun getNodes(): MutableList<String> |
|
open fun <K : Any, V : Any> getSyncMap(name: String): MutableMap<K, V> |
|
open fun isActive(): Boolean |
|
open fun join(resultHandler: Handler<AsyncResult<Void>>): Unit |
|
open fun leave(resultHandler: Handler<AsyncResult<Void>>): Unit |
|
open fun nodeListener(listener: NodeListener): Unit |
|
open fun setConfig(conf: JsonObject): Unit |
|
open fun setVertx(vertx: Vertx): Unit |