trait ZNode extends AnyRef
A handle to a ZNode attached to a ZkClient
- Alphabetic
- By Inheritance
- ZNode
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply(stat: Stat, bytes: Array[Byte]): Data
Build a ZNode with its metadata and data.
- def apply(stat: Stat, children: Seq[String]): Children
Build a ZNode with its metadata and children.
- def apply(stat: Stat): Exists
Build a ZNode with its metadata.
- def apply(child: String): ZNode
Get a child node.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def childPath(child: String): String
The absolute path of a child
- def client: ZkClient
Return the ZkClient associated with this node.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def create(data: Array[Byte] = Array.empty[Byte], acls: Seq[ACL] = zkClient.acl, mode: CreateMode = zkClient.mode, child: Option[String] = None): Future[ZNode]
Create this ZNode; or if a child name is specified create that child.
- def delete(version: Int = 0): Future[ZNode]
Returns a Future that is satisfied with this ZNode
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(other: Any): Boolean
ZNodes are equal if they share a path.
ZNodes are equal if they share a path.
- Definition Classes
- ZNode → AnyRef → Any
- val exists: ZOp[Exists]
Provides access to this node's metadata.
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- val getChildren: ZOp[Children]
Provides access to this node's children.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val getData: ZOp[Data]
Provides access to this node's data.
- def hashCode(): Int
- Definition Classes
- ZNode → AnyRef → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- lazy val log: Logger
- Attributes
- protected[this]
- def monitorTree(): Offer[TreeUpdate]
Continuously watch all nodes in this subtree for child updates.
Continuously watch all nodes in this subtree for child updates.
A ZNode.TreeUpdate is offered for each node in the tree.
If this node is deleted and it had children, an offer is sent indicating that this node no longer has children. A watch is maintained on deleted nodes so that if the parent node is not monitored, the monitor continues to work when the node is restored.
If an authorization failure or session expiration is encountered, the monitor will be lost silently. To detect these situations, receive events from ZkClient.monitorSession().
- lazy val name: String
The 'basename' of the ZNode path.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- lazy val parent: ZNode
The parent node.
The parent node. The root node is its own parent.
- lazy val parentPath: String
- def setData(data: Array[Byte], version: Int): Future[Data]
Returns a Future that is satisfied with this ZNode with its metadata and data
- def sync(): Future[ZNode]
Returns a Future that is satisfied with a reference to this ZNode
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ZNode → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withZkClient(zk: ZkClient): ZNode
Create a copy of this ZNode with an alternate ZkClient.
- object MonitorableEvent
AuthFailed and Expired are unmonitorable.
AuthFailed and Expired are unmonitorable. Everything else can be resumed.
- Attributes
- protected[this]