trait ZNode extends AnyRef
A handle to a ZNode attached to a ZkClient
- Alphabetic
- By Inheritance
- ZNode
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
val
path: String
Absolute path of ZNode
-
abstract
val
zkClient: ZkClient
- Attributes
- protected[com.twitter.zk]
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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
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[java.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[_]
- 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( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
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]