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