public class GetDataBuilderImpl extends Object implements GetDataBuilder, ErrorListenerPathable<byte[]>
Constructor and Description |
---|
GetDataBuilderImpl(CuratorFrameworkImpl client,
org.apache.zookeeper.data.Stat responseStat,
org.apache.zookeeper.Watcher watcher,
Backgrounding backgrounding,
boolean decompress) |
Modifier and Type | Method and Description |
---|---|
GetDataWatchBackgroundStatable |
decompressed()
Cause the data to be de-compressed using the configured compression provider
|
byte[] |
forPath(String path)
Commit the currently building operation using the given path
|
ErrorListenerPathable<byte[]> |
inBackground()
Perform the action in the background
|
ErrorListenerPathable<byte[]> |
inBackground(BackgroundCallback callback)
Perform the action in the background
|
ErrorListenerPathable<byte[]> |
inBackground(BackgroundCallback callback,
Executor executor)
Perform the action in the background
|
ErrorListenerPathable<byte[]> |
inBackground(BackgroundCallback callback,
Object context)
Perform the action in the background
|
ErrorListenerPathable<byte[]> |
inBackground(BackgroundCallback callback,
Object context,
Executor executor)
Perform the action in the background
|
ErrorListenerPathable<byte[]> |
inBackground(Object context)
Perform the action in the background
|
void |
performBackgroundOperation(org.apache.curator.framework.imps.OperationAndData<String> operationAndData) |
WatchPathable<byte[]> |
storingStatIn(org.apache.zookeeper.data.Stat stat)
Have the operation fill the provided stat object
|
BackgroundPathable<byte[]> |
usingWatcher(CuratorWatcher watcher)
Set a watcher for the operation
|
BackgroundPathable<byte[]> |
usingWatcher(org.apache.zookeeper.Watcher watcher)
Set a watcher for the operation
|
BackgroundPathable<byte[]> |
watched()
Have the operation set a watch
|
Pathable<byte[]> |
withUnhandledErrorListener(UnhandledErrorListener listener)
Set an error listener for this background operation.
|
public GetDataBuilderImpl(CuratorFrameworkImpl client, org.apache.zookeeper.data.Stat responseStat, org.apache.zookeeper.Watcher watcher, Backgrounding backgrounding, boolean decompress)
public GetDataWatchBackgroundStatable decompressed()
Decompressible
decompressed
in interface Decompressible<GetDataWatchBackgroundStatable>
public WatchPathable<byte[]> storingStatIn(org.apache.zookeeper.data.Stat stat)
Statable
storingStatIn
in interface Statable<WatchPathable<byte[]>>
stat
- the stat to have filled inpublic ErrorListenerPathable<byte[]> inBackground(BackgroundCallback callback, Object context)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
callback
- a functor that will get called when the operation has completedcontext
- context object - will be available from the event sent to the listenerpublic ErrorListenerPathable<byte[]> inBackground(BackgroundCallback callback, Object context, Executor executor)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
callback
- a functor that will get called when the operation has completedcontext
- context object - will be available from the event sent to the listenerexecutor
- executor to use for the background callpublic ErrorListenerPathable<byte[]> inBackground(BackgroundCallback callback)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
callback
- a functor that will get called when the operation has completedpublic ErrorListenerPathable<byte[]> inBackground(BackgroundCallback callback, Executor executor)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
callback
- a functor that will get called when the operation has completedexecutor
- executor to use for the background callpublic ErrorListenerPathable<byte[]> inBackground()
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
public ErrorListenerPathable<byte[]> inBackground(Object context)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<byte[]>>
context
- context object - will be available from the event sent to the listenerpublic Pathable<byte[]> withUnhandledErrorListener(UnhandledErrorListener listener)
ErrorListenerPathable
withUnhandledErrorListener
in interface ErrorListenerPathable<byte[]>
listener
- the listenerpublic BackgroundPathable<byte[]> watched()
Watchable
watched
in interface Watchable<BackgroundPathable<byte[]>>
public BackgroundPathable<byte[]> usingWatcher(org.apache.zookeeper.Watcher watcher)
WatchableBase
usingWatcher
in interface WatchableBase<BackgroundPathable<byte[]>>
watcher
- the watcherpublic BackgroundPathable<byte[]> usingWatcher(CuratorWatcher watcher)
WatchableBase
usingWatcher
in interface WatchableBase<BackgroundPathable<byte[]>>
watcher
- the watcherpublic void performBackgroundOperation(org.apache.curator.framework.imps.OperationAndData<String> operationAndData) throws Exception
Exception
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.