Uses of Interface
org.apache.curator.x.async.AsyncStage
Package
Description
-
Uses of AsyncStage in org.apache.curator.x.async
Modifier and TypeMethodDescriptionstatic <T> CompletionStage
<AsyncResult<T>> AsyncResult.of
(AsyncStage<T> stage) Return a new stage that wraps an async stage into a result-style completion stage. -
Uses of AsyncStage in org.apache.curator.x.async.api
Modifier and TypeMethodDescriptionAsyncMultiTransaction.forOperations
(List<CuratorOp> operations) Invoke ZooKeeper to commit the given operations as a single transaction.Modifier and TypeMethodDescriptionAsyncPathAndBytesable
<AsyncStage<org.apache.zookeeper.data.Stat>> AsyncSetDataBuilder.compressed()
Cause the data to be compressed using the configured compression providerAsyncPathAndBytesable
<AsyncStage<org.apache.zookeeper.data.Stat>> AsyncSetDataBuilder.compressedWithVersion
(int version) Cause the data to be compressed using the configured compression provider.AsyncPathable
<AsyncStage<byte[]>> AsyncGetDataBuilder.decompressed()
Cause the data to be de-compressed using the configured compression providerAsyncPathable
<AsyncStage<byte[]>> AsyncGetDataBuilder.decompressedStoringStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat object and have the data be de-compressedAsyncRemoveWatchesBuilder.removing
(CuratorWatcher watcher) AsyncRemoveWatchesBuilder.removing
(CuratorWatcher watcher, Set<RemoveWatcherOption> options) AsyncRemoveWatchesBuilder.removing
(CuratorWatcher watcher, org.apache.zookeeper.Watcher.WatcherType watcherType) Remove a watcher of a given typeAsyncRemoveWatchesBuilder.removing
(CuratorWatcher watcher, org.apache.zookeeper.Watcher.WatcherType watcherType, Set<RemoveWatcherOption> options) Remove a watcher of a given typeAsyncRemoveWatchesBuilder.removing
(org.apache.zookeeper.Watcher watcher) AsyncRemoveWatchesBuilder.removing
(org.apache.zookeeper.Watcher watcher, Set<RemoveWatcherOption> options) AsyncRemoveWatchesBuilder.removing
(org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.Watcher.WatcherType watcherType) Remove a watcher of a given typeAsyncRemoveWatchesBuilder.removing
(org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.Watcher.WatcherType watcherType, Set<RemoveWatcherOption> options) Remove a watcher of a given typeAsyncRemoveWatchesBuilder.removingAll()
Remove all watchersAsyncRemoveWatchesBuilder.removingAll
(Set<RemoveWatcherOption> options) Remove all watchersAsyncRemoveWatchesBuilder.removingAll
(org.apache.zookeeper.Watcher.WatcherType watcherType) Remove all watchers of a given typeAsyncRemoveWatchesBuilder.removingAll
(org.apache.zookeeper.Watcher.WatcherType watcherType, Set<RemoveWatcherOption> options) Remove all watchers of a given typeAsyncCreateBuilder.storingStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat objectAsyncPathable
<AsyncStage<List<org.apache.zookeeper.data.ACL>>> AsyncGetACLBuilder.storingStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat objectAsyncGetChildrenBuilder.storingStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat objectAsyncEnsemblable
<AsyncStage<byte[]>> AsyncGetConfigBuilder.storingStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat objectAsyncPathable
<AsyncStage<byte[]>> AsyncGetDataBuilder.storingStatIn
(org.apache.zookeeper.data.Stat stat) Have the operation fill the provided stat objectSet an ACL list (default isZooDefs.Ids.OPEN_ACL_UNSAFE
)AsyncPathable
<AsyncStage<org.apache.zookeeper.data.Stat>> Set the given ACLsAsyncPathable
<AsyncStage<org.apache.zookeeper.data.Stat>> Set the given ACLs only if the "a" version matches.AsyncReconfigBuilder.withJoiningAndLeaving
(List<String> joining, List<String> leaving) Adds servers to join the ensemble and/or servers to leave the ensemble.AsyncReconfigBuilder.withJoiningAndLeaving
(List<String> joining, List<String> leaving, long fromConfig) Specify joiners, leaves and config version.AsyncReconfigBuilder.withJoiningAndLeaving
(List<String> joining, List<String> leaving, org.apache.zookeeper.data.Stat stat) Same asAsyncReconfigBuilder.withJoiningAndLeaving(java.util.List, java.util.List)
but allows a stat to hold the stat info from "/zookeeper/config"AsyncReconfigBuilder.withJoiningAndLeaving
(List<String> joining, List<String> leaving, org.apache.zookeeper.data.Stat stat, long fromConfig) Same asAsyncReconfigBuilder.withJoiningAndLeaving(java.util.List, java.util.List)
with stat and config versionAsyncCreateBuilder.withMode
(org.apache.zookeeper.CreateMode createMode) Use the given create mode.AsyncReconfigBuilder.withNewMembers
(List<String> servers) Sets one or more members that are meant to be the ensemble.AsyncReconfigBuilder.withNewMembers
(List<String> servers, long fromConfig) Same asAsyncReconfigBuilder.withNewMembers(java.util.List)
but allows specified the configuration version to use.AsyncReconfigBuilder.withNewMembers
(List<String> servers, org.apache.zookeeper.data.Stat stat) Same asAsyncReconfigBuilder.withNewMembers(java.util.List)
but allows a stat to hold the stat info from "/zookeeper/config"AsyncReconfigBuilder.withNewMembers
(List<String> servers, org.apache.zookeeper.data.Stat stat, long fromConfig) Same asAsyncReconfigBuilder.withNewMembers(java.util.List)
with stat and config versionAsyncCreateBuilder.withOptions
(Set<CreateOption> options) Options to change how the ZNode is createdAsyncCreateBuilder.withOptions
(Set<CreateOption> options, List<org.apache.zookeeper.data.ACL> aclList) set options and ACLsAsyncCreateBuilder.withOptions
(Set<CreateOption> options, org.apache.zookeeper.CreateMode createMode) set options and modeAsyncCreateBuilder.withOptions
(Set<CreateOption> options, org.apache.zookeeper.CreateMode createMode, List<org.apache.zookeeper.data.ACL> aclList) set options, mode and ACLsAsyncCreateBuilder.withOptions
(Set<CreateOption> options, org.apache.zookeeper.CreateMode createMode, List<org.apache.zookeeper.data.ACL> aclList, org.apache.zookeeper.data.Stat stat) set options, mode, ACLs, and statAsyncCreateBuilder.withOptions
(Set<CreateOption> options, org.apache.zookeeper.CreateMode createMode, List<org.apache.zookeeper.data.ACL> aclList, org.apache.zookeeper.data.Stat stat, long ttl) set options, mode, ACLs, and statAsyncCreateBuilder.withOptions
(Set<CreateOption> options, org.apache.zookeeper.CreateMode createMode, List<org.apache.zookeeper.data.ACL> aclList, org.apache.zookeeper.data.Stat stat, long ttl, int setDataVersion) set options, mode, ACLs, and statAsyncDeleteBuilder.withOptions
(Set<DeleteOption> options) Changes the deletion options.AsyncPathable
<AsyncStage<org.apache.zookeeper.data.Stat>> AsyncExistsBuilder.withOptions
(Set<ExistsOption> options) Use the given options.AsyncDeleteBuilder.withOptionsAndVersion
(Set<DeleteOption> options, int version) Set options and version.AsyncCreateBuilder.withSetDataVersion
(int version) Specify the setData expected matching version when using optionCreateOption.setDataIfExists
.AsyncCreateBuilder.withTtl
(long ttl) Specify a TTL when mode isCreateMode.PERSISTENT_WITH_TTL
orCreateMode.PERSISTENT_SEQUENTIAL_WITH_TTL
.AsyncDeleteBuilder.withVersion
(int version) Changes the version number passed to the delete() method.AsyncPathAndBytesable
<AsyncStage<org.apache.zookeeper.data.Stat>> AsyncSetDataBuilder.withVersion
(int version) Only sets if the version matches. -
Uses of AsyncStage in org.apache.curator.x.async.modeled
Modifier and TypeMethodDescriptionAsyncStage
<org.apache.zookeeper.data.Stat> ModeledFramework.checkExists()
Check to see if the ZNode at this instance's path existsModeledFramework.children()
Return the child paths of this instance's path (in no particular order)AsyncStage
<List<ZNode<T>>> ModeledFramework.childrenAsZNodes()
Return the child paths of this instance's path (in no particular order) and deserialize into a models.ModeledFramework.delete()
Delete the ZNode at this instance's path passing -1 for the delete versionModeledFramework.delete
(int version) Delete the ZNode at this instance's path passing the given delete versionModeledFramework.inTransaction
(List<CuratorOp> operations) Invoke ZooKeeper to commit the given operations as a single transaction.ModeledFramework.read()
Read the ZNode at this instance's path and deserialize into a modelModeledFramework.read
(org.apache.zookeeper.data.Stat storingStatIn) Read the ZNode at this instance's path and deserialize into a modelAsyncStage
<ZNode<T>> ModeledFramework.readAsZNode()
Read the ZNode at this instance's path and deserialize into a modelCreate (or update depending on build options) a ZNode at this instance's path with a serialized version of the given modelCreate (or update depending on build options) a ZNode at this instance's path with a serialized version of the given modelCreate (or update depending on build options) a ZNode at this instance's path with a serialized form of the given modelCreate (or update depending on build options) a ZNode at this instance's path with a serialized form of the given modelAsyncStage
<org.apache.zookeeper.data.Stat> Update the ZNode at this instance's path with a serialized form of the given model passing "-1" for the update versionAsyncStage
<org.apache.zookeeper.data.Stat> Update the ZNode at this instance's path with a serialized form of the given model passing the given update versionModifier and TypeMethodDescriptionstatic <T> CompletionStage
<T> ZNode.model
(AsyncStage<ZNode<T>> from) Utility that modifies an async stage of a znode into an async stage of a modelstatic <T> CompletionStage
<List<T>> ZNode.models
(AsyncStage<List<ZNode<T>>> from) Utility that modifies an async stage of znodes into an async stage of models -
Uses of AsyncStage in org.apache.curator.x.async.modeled.cached
Modifier and TypeMethodDescriptionAsyncStage
<List<ZNode<T>>> CachedModeledFramework.childrenAsZNodes()
Same asModeledFramework.childrenAsZNodes()
but always reads from cache - i.e.AsyncStage
<List<T>> CachedModeledFramework.list()
Return the instances of the base path of this cached frameworkCachedModeledFramework.readThrough()
Same asModeledFramework.read()
except that if the cache does not have a value for this path a direct query is made.CachedModeledFramework.readThrough
(org.apache.zookeeper.data.Stat storingStatIn) Same asModeledFramework.read(org.apache.zookeeper.data.Stat)
except that if the cache does not have a value for this path a direct query is made.AsyncStage
<ZNode<T>> CachedModeledFramework.readThroughAsZNode()
Same asModeledFramework.readAsZNode()
except that if the cache does not have a value for this path a direct query is made. -
Uses of AsyncStage in org.apache.curator.x.async.modeled.details
Modifier and TypeMethodDescriptionAsyncStage
<org.apache.zookeeper.data.Stat> ModeledFrameworkImpl.checkExists()
ModeledFrameworkImpl.children()
AsyncStage
<List<ZNode<T>>> ModeledFrameworkImpl.childrenAsZNodes()
ModeledFrameworkImpl.delete()
ModeledFrameworkImpl.delete
(int version) ModeledFrameworkImpl.inTransaction
(List<CuratorOp> operations) ModeledFrameworkImpl.read()
ModeledFrameworkImpl.read
(org.apache.zookeeper.data.Stat storingStatIn) AsyncStage
<ZNode<T>> ModeledFrameworkImpl.readAsZNode()
AsyncStage
<org.apache.zookeeper.data.Stat> AsyncStage
<org.apache.zookeeper.data.Stat> -
Uses of AsyncStage in org.apache.curator.x.async.modeled.versioned
Modifier and TypeMethodDescriptionVersionedModeledFramework.read()
VersionedModeledFramework.read
(org.apache.zookeeper.data.Stat storingStatIn) AsyncStage
<org.apache.zookeeper.data.Stat>