public class AsyncCuratorFrameworkImpl extends Object implements AsyncCuratorFramework
Constructor and Description |
---|
AsyncCuratorFrameworkImpl(CuratorFramework client) |
AsyncCuratorFrameworkImpl(CuratorFrameworkImpl client,
Filters filters,
WatchMode watchMode,
boolean watched) |
Modifier and Type | Method and Description |
---|---|
AsyncWatchBuilder |
addWatch()
Start an add watch builder.
|
AsyncExistsBuilder |
checkExists()
Start an exists builder.
|
AsyncCreateBuilder |
create()
Start a create builder
|
AsyncDeleteBuilder |
delete()
Start a delete builder
|
AsyncGetACLBuilder |
getACL()
Start a get ACL builder
|
AsyncGetChildrenBuilder |
getChildren()
Start a get children builder
|
AsyncGetConfigBuilder |
getConfig()
Start a getConfig builder
|
AsyncGetDataBuilder |
getData()
Start a get data builder
|
AsyncReconfigBuilder |
reconfig()
Start a reconfig builder
|
AsyncRemoveWatchesBuilder |
removeWatches()
Start a remove watches builder
|
AsyncSetACLBuilder |
setACL()
Start a set ACL builder
|
AsyncSetDataBuilder |
setData()
Start a set data builder
|
AsyncSyncBuilder |
sync()
Start a sync builder
|
AsyncMultiTransaction |
transaction()
Start a transaction builder
|
AsyncTransactionOp |
transactionOp()
Allocate an operation that can be used with
AsyncCuratorFrameworkDsl.transaction() . |
CuratorFramework |
unwrap()
Returns the client that was originally passed to
AsyncCuratorFramework.wrap(org.apache.curator.framework.CuratorFramework) |
WatchableAsyncCuratorFramework |
watched()
Returns a facade that adds watching to any of the subsequently created builders.
|
AsyncCuratorFrameworkDsl |
with(UnaryOperator<CuratorEvent> resultFilter,
UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
Returns a facade that adds the the given filters to all background operations and watchers.
|
AsyncCuratorFrameworkDsl |
with(UnhandledErrorListener listener)
Returns a facade that adds the given UnhandledErrorListener to all background operations
|
AsyncCuratorFrameworkDsl |
with(UnhandledErrorListener listener,
UnaryOperator<CuratorEvent> resultFilter,
UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
Set any combination of listener or filters
|
AsyncCuratorFrameworkDsl |
with(WatchMode mode)
Returns a facade that changes how watchers are set when
AsyncCuratorFrameworkDsl.watched() is called |
AsyncCuratorFrameworkDsl |
with(WatchMode mode,
UnhandledErrorListener listener,
UnaryOperator<CuratorEvent> resultFilter,
UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
Set any combination of listener, filters or watch mode
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
wrap
public AsyncCuratorFrameworkImpl(CuratorFramework client)
public AsyncCuratorFrameworkImpl(CuratorFrameworkImpl client, Filters filters, WatchMode watchMode, boolean watched)
public AsyncCreateBuilder create()
AsyncCuratorFrameworkDsl
create
in interface AsyncCuratorFrameworkDsl
public AsyncDeleteBuilder delete()
AsyncCuratorFrameworkDsl
delete
in interface AsyncCuratorFrameworkDsl
public AsyncSetDataBuilder setData()
AsyncCuratorFrameworkDsl
setData
in interface AsyncCuratorFrameworkDsl
public AsyncGetACLBuilder getACL()
AsyncCuratorFrameworkDsl
getACL
in interface AsyncCuratorFrameworkDsl
public AsyncSetACLBuilder setACL()
AsyncCuratorFrameworkDsl
setACL
in interface AsyncCuratorFrameworkDsl
public AsyncReconfigBuilder reconfig()
AsyncCuratorFrameworkDsl
reconfig
in interface AsyncCuratorFrameworkDsl
public AsyncMultiTransaction transaction()
AsyncCuratorFrameworkDsl
transaction
in interface AsyncCuratorFrameworkDsl
public AsyncSyncBuilder sync()
AsyncCuratorFrameworkDsl
sync
in interface AsyncCuratorFrameworkDsl
public AsyncRemoveWatchesBuilder removeWatches()
AsyncCuratorFrameworkDsl
removeWatches
in interface AsyncCuratorFrameworkDsl
public AsyncWatchBuilder addWatch()
AsyncCuratorFrameworkDsl
IllegalStateException
for ZooKeeper JAR 3.5 or belowaddWatch
in interface AsyncCuratorFrameworkDsl
public CuratorFramework unwrap()
AsyncCuratorFramework
AsyncCuratorFramework.wrap(org.apache.curator.framework.CuratorFramework)
unwrap
in interface AsyncCuratorFramework
public WatchableAsyncCuratorFramework watched()
AsyncCuratorFrameworkDsl
Returns a facade that adds watching to any of the subsequently created builders. i.e. all
operations on the WatchableAsyncCuratorFramework facade will have watchers set. Also,
the AsyncStage
returned from these builders will
have a loaded staged watcher that is accessed from AsyncStage.event()
WatchMode.stateChangeAndSuccess
is used
watched
in interface AsyncCuratorFrameworkDsl
public AsyncCuratorFrameworkDsl with(WatchMode mode)
AsyncCuratorFramework
AsyncCuratorFrameworkDsl.watched()
is calledwith
in interface AsyncCuratorFramework
mode
- watch mode to use for subsequent calls to AsyncCuratorFrameworkDsl.watched()
public AsyncCuratorFrameworkDsl with(WatchMode mode, UnhandledErrorListener listener, UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
AsyncCuratorFramework
with
in interface AsyncCuratorFramework
mode
- watch mode to use for subsequent calls to AsyncCuratorFrameworkDsl.watched()
(cannot be null
)listener
- lister to use or null
resultFilter
- filter to use or null
watcherFilter
- filter to use or null
AsyncCuratorFramework.with(WatchMode)
,
AsyncCuratorFramework.with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
,
AsyncCuratorFramework.with(org.apache.curator.framework.api.UnhandledErrorListener)
public AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener)
AsyncCuratorFramework
with
in interface AsyncCuratorFramework
listener
- lister to usepublic AsyncCuratorFrameworkDsl with(UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
AsyncCuratorFramework
resultFilter
will get called for every background callback. watcherFilter
will get called for every watcher. The filters can return new versions or unchanged versions
of the arguments.with
in interface AsyncCuratorFramework
resultFilter
- filter to use or null
watcherFilter
- filter to use or null
public AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener, UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)
AsyncCuratorFramework
with
in interface AsyncCuratorFramework
listener
- lister to use or null
resultFilter
- filter to use or null
watcherFilter
- filter to use or null
AsyncCuratorFramework.with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
,
AsyncCuratorFramework.with(org.apache.curator.framework.api.UnhandledErrorListener)
public AsyncTransactionOp transactionOp()
AsyncCuratorFrameworkDsl
AsyncCuratorFrameworkDsl.transaction()
.
NOTE: CuratorOp
instances created by this builder are
reusable.transactionOp
in interface AsyncCuratorFrameworkDsl
public AsyncExistsBuilder checkExists()
WatchableAsyncCuratorFramework
checkExists
in interface WatchableAsyncCuratorFramework
public AsyncGetDataBuilder getData()
WatchableAsyncCuratorFramework
getData
in interface WatchableAsyncCuratorFramework
public AsyncGetChildrenBuilder getChildren()
WatchableAsyncCuratorFramework
getChildren
in interface WatchableAsyncCuratorFramework
public AsyncGetConfigBuilder getConfig()
WatchableAsyncCuratorFramework
getConfig
in interface WatchableAsyncCuratorFramework
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.