class
AkkaZkClient extends ZkClient
Instance Constructors
-
new
AkkaZkClient(zkServers: String, sessionTimeout: Duration, connectionTimeout: Duration, zkSerializer: ZkSerializer = ...)
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
def
close(): Unit
-
def
connect(arg0: Long, arg1: Watcher): Unit
-
def
connection: ZkConnection
-
def
countChildren(arg0: String): Int
-
def
create(arg0: String, arg1: Any, arg2: CreateMode): String
-
def
createEphemeral(arg0: String, arg1: Any): Unit
-
def
createEphemeral(arg0: String): Unit
-
def
createEphemeralSequential(arg0: String, arg1: Any): String
-
def
createPersistent(arg0: String, arg1: Any): Unit
-
def
createPersistent(arg0: String, arg1: Boolean): Unit
-
def
createPersistent(arg0: String): Unit
-
def
createPersistentSequential(arg0: String, arg1: Any): String
-
def
delete(arg0: String): Boolean
-
def
deleteRecursive(arg0: String): Boolean
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
exists(arg0: String): Boolean
-
def
exists(arg0: String, arg1: Boolean): Boolean
-
def
finalize(): Unit
-
def
getChildren(arg0: String, arg1: Boolean): List[String]
-
def
getChildren(arg0: String): List[String]
-
final
def
getClass(): java.lang.Class[_]
-
def
getCreationTime(arg0: String): Long
-
def
getDataListener(arg0: String): Set[IZkDataListener]
-
def
getEventLock(): ZkLock
-
def
getShutdownTrigger(): Boolean
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
numberOfListeners(): Int
-
def
process(arg0: WatchedEvent): Unit
-
def
readData[T](arg0: String, arg1: Stat, arg2: Boolean): T
-
def
readData[T](arg0: String, arg1: Stat): T
-
def
readData[T](arg0: String, arg1: Boolean): T
-
def
readData[T](arg0: String): T
-
def
reconnect(): Unit
-
def
retryUntilConnected[T](arg0: Callable[T]): T
-
def
setCurrentState(arg0: KeeperState): Unit
-
def
setShutdownTrigger(arg0: Boolean): Unit
-
def
setZkSerializer(arg0: ZkSerializer): Unit
-
def
showFolders(arg0: OutputStream): Unit
-
def
subscribeChildChanges(arg0: String, arg1: IZkChildListener): List[String]
-
def
subscribeDataChanges(arg0: String, arg1: IZkDataListener): Unit
-
def
subscribeStateChanges(arg0: IZkStateListener): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
unsubscribeAll(): Unit
-
def
unsubscribeChildChanges(arg0: String, arg1: IZkChildListener): Unit
-
def
unsubscribeDataChanges(arg0: String, arg1: IZkDataListener): Unit
-
def
unsubscribeStateChanges(arg0: IZkStateListener): Unit
-
def
updateDataSerialized[T](arg0: String, arg1: DataUpdater[T]): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
def
waitForKeeperState(arg0: KeeperState, arg1: Long, arg2: TimeUnit): Boolean
-
def
waitUntilConnected(arg0: Long, arg1: TimeUnit): Boolean
-
def
waitUntilConnected(): Unit
-
def
waitUntilExists(arg0: String, arg1: TimeUnit, arg2: Long): Boolean
-
def
watchForChilds(arg0: String): List[String]
-
def
watchForData(arg0: String): Unit
-
def
writeData(arg0: String, arg1: Any, arg2: Int): Unit
-
def
writeData(arg0: String, arg1: Any): Unit
Inherited from ZkClient
Inherited from Watcher
Inherited from AnyRef
Inherited from Any
ZooKeeper client. Holds the ZooKeeper connection and manages its session.
(Since version 2.0.2) ZooKeeperBasedMailbox will be removed in Akka 2.1