trait NullZooKeeperWriter extends ZooKeeperWriter with NullZooKeeperClient
- Alphabetic
- By Inheritance
- NullZooKeeperWriter
- NullZooKeeperClient
- ZooKeeperWriter
- ZooKeeperClient
- Closable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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 addAuthInfo(scheme: String, auth: Buf): Future[Unit]
Add the specified scheme: auth information to this connection.
Add the specified scheme: auth information to this connection.
- scheme
the authentication scheme to use.
- auth
the authentication credentials.
- returns
a Future[Unit]
- Definition Classes
- NullZooKeeperClient → ZooKeeperClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close(deadline: Time): Future[Unit]
- Definition Classes
- NullZooKeeperClient → Closable
- def close(after: Duration): Future[Unit]
- Definition Classes
- Closable
- final def close(): Future[Unit]
- Definition Classes
- Closable
- def create(path: String, data: Option[Buf], acl: Seq[ACL], createMode: CreateMode): Future[String]
Create a node of a given type with the given path.
Create a node of a given type with the given path. The node data will be the given data, and node acl will be the given acl.
- path
the path for the node.
- data
the initial data for the node.
- acl
a sequence of ACLs for the node.
- createMode
specifies what type of node to create.
- returns
a Future[String] containing the actual path of the created node.
- Definition Classes
- NullZooKeeperWriter → ZooKeeperWriter
- def delete(path: String, version: Option[Int]): Future[Unit]
Delete the node with the given path.
Delete the node with the given path. The call will succeed if such a node exists, and the given version matches the node's version (if the given version is None, it matches any node's versions).
This operation, if successful, will trigger all the watches on the node of the given path left by existsWatch API calls, and the watches on the parent node left by getChildrenWatch API calls.
- path
the path of the node to be deleted.
- version
the expected node version.
- returns
a Future[Unit]
- Definition Classes
- NullZooKeeperWriter → ZooKeeperWriter
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getEphemerals(): Future[Seq[String]]
Get the existing ephemeral nodes created with the current session ID.
Get the existing ephemeral nodes created with the current session ID.
NOTE: This method is not universally implemented. The Future will fail with KeeperException.Unimplemented if this is the case.
- returns
a Future[Seq[String]] of ephemeral node paths.
- Definition Classes
- NullZooKeeperClient → ZooKeeperClient
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- def sessionId: Long
The session id for this ZooKeeper client instance.
The session id for this ZooKeeper client instance. The value returned is not valid until the client connects to a server and may change after a re-connect.
- returns
current session id
- Definition Classes
- NullZooKeeperClient → ZooKeeperClient
- def sessionPasswd: Buf
The session password for this ZooKeeper client instance.
The session password for this ZooKeeper client instance. The value returned is not valid until the client connects to a server and may change after a re-connect.
- returns
current session password
- Definition Classes
- NullZooKeeperClient → ZooKeeperClient
- def sessionTimeout: Duration
The negotiated session timeout for this ZooKeeper client instance.
The negotiated session timeout for this ZooKeeper client instance. The value returned is not valid until the client connects to a server and may change after a re-connect.
- returns
current session timeout
- Definition Classes
- NullZooKeeperClient → ZooKeeperClient
- def setACL(path: String, acl: Seq[ACL], version: Option[Int]): Future[Stat]
Set the ACL for the node of the given path if such a node exists and the given version matches the version of the node (if the given version is None, it matches any node's versions)
Set the ACL for the node of the given path if such a node exists and the given version matches the version of the node (if the given version is None, it matches any node's versions)
- path
the path of the node to write.
- acl
a list of Data.ACL to apply to the node.
- version
the expected matching version.
- returns
a Future[Data.Stat]
- Definition Classes
- NullZooKeeperWriter → ZooKeeperWriter
- def setData(path: String, data: Option[Buf], version: Option[Int]): Future[Stat]
Set the data for the node of the given path if such a node exists and the given version matches the version of the node (if the given version is None, it matches any node's versions).
Set the data for the node of the given path if such a node exists and the given version matches the version of the node (if the given version is None, it matches any node's versions).
This operation, if successful, will trigger all the watches on the node of the given path left by getDataWatch calls.
- path
the path of the node to write.
- data
the data to set.
- version
the expected matching version.
- returns
a Future[Data.Stat]
- Definition Classes
- NullZooKeeperWriter → ZooKeeperWriter
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- 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()