Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.google.code.findbugs/jsr305/3.0.2
- com.google.errorprone/error_prone_annotations/2.2.0
- com.google.guava/failureaccess/1.0.1
- com.google.guava/guava/27.0.1-jre
- com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava
- com.google.j2objc/j2objc-annotations/1.1
- commons-logging/commons-logging/1.2
- io.netty/netty-buffer/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.45.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.1.RELEASE
- java/11
- javax.activation/activation/1.1
- javax.mail/mail/1.4.3
- jdk/srczip/999
- jdk.tools/jdk.tools/1.8
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- org.apache.curator/curator-client/4.3.0
- org.apache.curator/curator-framework/4.3.0
- org.apache.curator/curator-recipes/4.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.yetus/audience-annotations/0.5.0
- org.apache.zookeeper/zookeeper/3.5.7
- org.apache.zookeeper/zookeeper-jute/3.5.7
- org.checkerframework/checker-qual/2.5.2
- org.codehaus.mojo/animal-sniffer-annotations/1.17
- org.slf4j/slf4j-api/1.7.25
- org.slf4j/slf4j-log4j12/1.7.25
Declarations
- example
-
io
-
vertx
-
spi
-
cluster
-
zookeeper
-
ZookeeperClusterManager
- clusterNodes: PathChildrenCache
- active: boolean
- joined: boolean
- nodeId: String
- curator: CuratorFramework
- customCuratorCluster: boolean
- retryPolicy: RetryPolicy
- subsMapHelper: SubsMapHelper
- locks: Map<String, ZKLock>
- DEFAULT_CONFIG_FILE: String
- CONFIG_FILE: String
- ZK_SYS_CONFIG_KEY: String
- ZK_PATH_LOCKS: String
- ZK_PATH_CLUSTER_NODE: String
- ZK_PATH_CLUSTER_NODE_WITHOUT_SLASH: String
- lockReleaseExec: ExecutorService
- resolveNodeId: Function<String, String>
- ZookeeperClusterManager(): void
- ZookeeperClusterManager(CuratorFramework): void
- ZookeeperClusterManager(String): void
- ZookeeperClusterManager(CuratorFramework, String): void
- loadProperties(String): void
- getConfigStream(String): InputStream
- getCuratorFramework(): CuratorFramework
- getSyncMap(String): Map<Object, Object>
- getNodeId(): String
- getNodes(): List<String>
- createThisNode(): void
- isActive(): boolean
- childEvent(CuratorFramework, PathChildrenCacheEvent): void
-
impl
- SubsMapHelper
- ZKAsyncMap
- ZKCounter
- ZKLock
-
ZKMap
- curator: CuratorFramework
- mapPath: String
- ZK_PATH_ASYNC_MAP: String
- ZK_PATH_SYNC_MAP: String
- pathChecker: Predicate<String>
- retryPolicy: RetryPolicy
- keyPath(Object): String
- asByte(Object): byte[]
- asObject(byte[]): Object
- getData(Stat, String): Object
- compareAndSet(long, int, Stat, String, Object, Object): boolean
-
ZKSyncMap
- ZKSyncMap(CuratorFramework, String): void
- size(): int
- isEmpty(): boolean
- containsKey(Object): boolean
- containsValue(Object): boolean
- get(Object): Object
- put(Object, Object): Object
- remove(Object): Object
- putAll(Map<Object, Object>): void
- clear(): void
- keySet(): Set<Object>
- values(): Collection<Object>
- syncKeyPath(String): void
- entrySet(): Set<Entry<Object, Object>>
- KeyValue
-
ZookeeperClusterManager
-
zookeeper
-
cluster
-
spi
-
vertx