Package org.apache.curator.x.async.details

Class AsyncCuratorFrameworkImpl

java.lang.Object

org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl

All Implemented Interfaces:

AsyncCuratorFrameworkDsl, WatchableAsyncCuratorFramework, AsyncCuratorFramework

public class AsyncCuratorFrameworkImpl
extends Object
implements AsyncCuratorFramework

Constructor Summary

Constructors

Constructor	Description
AsyncCuratorFrameworkImpl(CuratorFramework client)
AsyncCuratorFrameworkImpl(CuratorFrameworkBase client, Filters filters, WatchMode watchMode, boolean watched)

Method Summary

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsyncCuratorFrameworkImpl

public AsyncCuratorFrameworkImpl(CuratorFramework client)

AsyncCuratorFrameworkImpl

public AsyncCuratorFrameworkImpl(CuratorFrameworkBase client,
 Filters filters,
 WatchMode watchMode,
 boolean watched)

Method Details

create

public AsyncCreateBuilder create()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a create builder

Specified by:

create in interface AsyncCuratorFrameworkDsl

Returns:

builder object

delete

public AsyncDeleteBuilder delete()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a delete builder

Specified by:

delete in interface AsyncCuratorFrameworkDsl

Returns:

builder object

setData

public AsyncSetDataBuilder setData()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a set data builder

Specified by:

setData in interface AsyncCuratorFrameworkDsl

Returns:

builder object

getACL

public AsyncGetACLBuilder getACL()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a get ACL builder

Specified by:

getACL in interface AsyncCuratorFrameworkDsl

Returns:

builder object

setACL

public AsyncSetACLBuilder setACL()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a set ACL builder

Specified by:

setACL in interface AsyncCuratorFrameworkDsl

Returns:

builder object

reconfig

public AsyncReconfigBuilder reconfig()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a reconfig builder

Specified by:

reconfig in interface AsyncCuratorFrameworkDsl

Returns:

builder object

transaction

public AsyncMultiTransaction transaction()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a transaction builder

Specified by:

transaction in interface AsyncCuratorFrameworkDsl

Returns:

builder object

sync

public AsyncSyncBuilder sync()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a sync builder

Specified by:

sync in interface AsyncCuratorFrameworkDsl

Returns:

builder object

removeWatches

public AsyncRemoveWatchesBuilder removeWatches()

Description copied from interface: AsyncCuratorFrameworkDsl

Start a remove watches builder

Specified by:

removeWatches in interface AsyncCuratorFrameworkDsl

Returns:

builder object

addWatch

public AsyncWatchBuilder addWatch()

Description copied from interface: AsyncCuratorFrameworkDsl

Start an add watch builder. Supported only when ZooKeeper JAR of version 3.6 or above is used, throws IllegalStateException for ZooKeeper JAR 3.5 or below

Specified by:

addWatch in interface AsyncCuratorFrameworkDsl

Returns:

builder object

unwrap

public CuratorFramework unwrap()

Description copied from interface: AsyncCuratorFramework

Returns the client that was originally passed to AsyncCuratorFramework.wrap(org.apache.curator.framework.CuratorFramework)

Specified by:

unwrap in interface AsyncCuratorFramework

Returns:

original client

watched

public WatchableAsyncCuratorFramework watched()

Description copied from interface: 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

Specified by:

watched in interface AsyncCuratorFrameworkDsl

Returns:

watcher facade

with

public AsyncCuratorFrameworkDsl with(WatchMode mode)

Description copied from interface: AsyncCuratorFramework

Returns a facade that changes how watchers are set when AsyncCuratorFrameworkDsl.watched() is called

Specified by:

with in interface AsyncCuratorFramework

Parameters:

mode - watch mode to use for subsequent calls to AsyncCuratorFrameworkDsl.watched()

Returns:

facade

with

public AsyncCuratorFrameworkDsl with(WatchMode mode,
 UnhandledErrorListener listener,
 UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Description copied from interface: AsyncCuratorFramework

Set any combination of listener, filters or watch mode

Specified by:

with in interface AsyncCuratorFramework

Parameters:

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

Returns:

facade

See Also:

• AsyncCuratorFramework.with(WatchMode)
• AsyncCuratorFramework.with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
• AsyncCuratorFramework.with(org.apache.curator.framework.api.UnhandledErrorListener)

with

public AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener)

Description copied from interface: AsyncCuratorFramework

Returns a facade that adds the given UnhandledErrorListener to all background operations

Specified by:

with in interface AsyncCuratorFramework

Parameters:

listener - lister to use

Returns:

facade

with

public AsyncCuratorFrameworkDsl with(UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Description copied from interface: AsyncCuratorFramework

Returns a facade that adds the the given filters to all background operations and watchers. 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.

Specified by:

with in interface AsyncCuratorFramework

Parameters:

resultFilter - filter to use or null

watcherFilter - filter to use or null

Returns:

facade

with

public AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener,
 UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Description copied from interface: AsyncCuratorFramework

Set any combination of listener or filters

Specified by:

with in interface AsyncCuratorFramework

Parameters:

listener - lister to use or null

resultFilter - filter to use or null

watcherFilter - filter to use or null

Returns:

facade

See Also:

• AsyncCuratorFramework.with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
• AsyncCuratorFramework.with(org.apache.curator.framework.api.UnhandledErrorListener)

transactionOp

public AsyncTransactionOp transactionOp()

Description copied from interface: AsyncCuratorFrameworkDsl

Allocate an operation that can be used with AsyncCuratorFrameworkDsl.transaction(). NOTE: CuratorOp instances created by this builder are reusable.

Specified by:

transactionOp in interface AsyncCuratorFrameworkDsl

Returns:

operation builder

checkExists

public AsyncExistsBuilder checkExists()

Description copied from interface: WatchableAsyncCuratorFramework

Start an exists builder. The builder will return a Stat object as if org.apache.zookeeper.ZooKeeper.exists() were called. Thus, a null means that it does not exist and an actual Stat object means it does exist.

Specified by:

checkExists in interface WatchableAsyncCuratorFramework

Returns:

builder object

getData

public AsyncGetDataBuilder getData()

Description copied from interface: WatchableAsyncCuratorFramework

Start a get data builder

Specified by:

getData in interface WatchableAsyncCuratorFramework

Returns:

builder object

getChildren

public AsyncGetChildrenBuilder getChildren()

Description copied from interface: WatchableAsyncCuratorFramework

Start a get children builder

Specified by:

getChildren in interface WatchableAsyncCuratorFramework

Returns:

builder object

getConfig

public AsyncGetConfigBuilder getConfig()

Description copied from interface: WatchableAsyncCuratorFramework

Start a getConfig builder

Specified by:

getConfig in interface WatchableAsyncCuratorFramework

Returns:

builder object