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
-
-
-
-
zookeeper
-
cluster
-
spi
-
vertx