akka.cluster.zookeeper

AkkaZkClient

class AkkaZkClient extends ZkClient

ZooKeeper client. Holds the ZooKeeper connection and manages its session.

Linear Supertypes
ZkClient, Watcher, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. AkkaZkClient
  2. ZkClient
  3. Watcher
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AkkaZkClient (zkServers: String, sessionTimeout: Duration, connectionTimeout: Duration, zkSerializer: ZkSerializer)

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. def close (): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws()

  9. def connect (arg0: Long, arg1: Watcher): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws()

  10. def connection : ZkConnection

  11. def countChildren (arg0: String): Int

    Definition Classes
    ZkClient

  12. def create (arg0: String, arg1: Any, arg2: CreateMode): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  13. def createEphemeral (arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  14. def createEphemeral (arg0: String): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  15. def createEphemeralSequential (arg0: String, arg1: Any): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  16. def createPersistent (arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  17. def createPersistent (arg0: String, arg1: Boolean): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  18. def createPersistent (arg0: String): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  19. def createPersistentSequential (arg0: String, arg1: Any): String

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  20. def delete (arg0: String): Boolean

    Definition Classes
    ZkClient

  21. def deleteRecursive (arg0: String): Boolean

    Definition Classes
    ZkClient

  22. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  23. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  24. def exists (arg0: String): Boolean

    Definition Classes
    ZkClient

  25. def exists (arg0: String, arg1: Boolean): Boolean

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient

  26. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  27. def getChildren (arg0: String, arg1: Boolean): List[String]

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient

  28. def getChildren (arg0: String): List[String]

    Definition Classes
    ZkClient

  29. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any

  30. def getCreationTime (arg0: String): Long

    Definition Classes
    ZkClient

  31. def getDataListener (arg0: String): Set[IZkDataListener]

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient

  32. def getEventLock (): ZkLock

    Definition Classes
    ZkClient

  33. def getShutdownTrigger (): Boolean

    Definition Classes
    ZkClient

  34. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  35. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  36. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  37. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  38. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  39. def numberOfListeners (): Int

    Definition Classes
    ZkClient

  40. def process (arg0: WatchedEvent): Unit

    Definition Classes
    ZkClient → Watcher

  41. def readData [T] (arg0: String, arg1: Stat, arg2: Boolean): T

    Attributes
    protected[zkclient]
    Definition Classes
    ZkClient

  42. def readData [T] (arg0: String, arg1: Stat): T

    Definition Classes
    ZkClient

  43. def readData [T] (arg0: String, arg1: Boolean): T

    Definition Classes
    ZkClient

  44. def readData [T] (arg0: String): T

    Definition Classes
    ZkClient

  45. def reconnect (): Unit

  46. def retryUntilConnected [T] (arg0: Callable[T]): T

    Definition Classes
    ZkClient
    Annotations
    @throws() @throws() @throws() @throws()

  47. def setCurrentState (arg0: KeeperState): Unit

    Definition Classes
    ZkClient

  48. def setShutdownTrigger (arg0: Boolean): Unit

    Definition Classes
    ZkClient

  49. def setZkSerializer (arg0: ZkSerializer): Unit

    Definition Classes
    ZkClient

  50. def showFolders (arg0: OutputStream): Unit

    Definition Classes
    ZkClient

  51. def subscribeChildChanges (arg0: String, arg1: IZkChildListener): List[String]

    Definition Classes
    ZkClient

  52. def subscribeDataChanges (arg0: String, arg1: IZkDataListener): Unit

    Definition Classes
    ZkClient

  53. def subscribeStateChanges (arg0: IZkStateListener): Unit

    Definition Classes
    ZkClient

  54. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  55. def toString (): String

    Definition Classes
    AnyRef → Any

  56. def unsubscribeAll (): Unit

    Definition Classes
    ZkClient

  57. def unsubscribeChildChanges (arg0: String, arg1: IZkChildListener): Unit

    Definition Classes
    ZkClient

  58. def unsubscribeDataChanges (arg0: String, arg1: IZkDataListener): Unit

    Definition Classes
    ZkClient

  59. def unsubscribeStateChanges (arg0: IZkStateListener): Unit

    Definition Classes
    ZkClient

  60. def updateDataSerialized [T] (arg0: String, arg1: DataUpdater[T]): Unit

    Definition Classes
    ZkClient

  61. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  62. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  63. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  64. def waitForKeeperState (arg0: KeeperState, arg1: Long, arg2: TimeUnit): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()

  65. def waitUntilConnected (arg0: Long, arg1: TimeUnit): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()

  66. def waitUntilConnected (): Unit

    Definition Classes
    ZkClient
    Annotations
    @throws()

  67. def waitUntilExists (arg0: String, arg1: TimeUnit, arg2: Long): Boolean

    Definition Classes
    ZkClient
    Annotations
    @throws()

  68. def watchForChilds (arg0: String): List[String]

    Definition Classes
    ZkClient

  69. def watchForData (arg0: String): Unit

    Definition Classes
    ZkClient

  70. def writeData (arg0: String, arg1: Any, arg2: Int): Unit

    Definition Classes
    ZkClient

  71. def writeData (arg0: String, arg1: Any): Unit

    Definition Classes
    ZkClient

Inherited from ZkClient

Inherited from Watcher

Inherited from AnyRef

Inherited from Any