Modifier and Type | Method and Description |
---|---|
static AsyncCuratorFramework |
AsyncExamples.wrap(CuratorFramework client) |
Modifier and Type | Method and Description |
---|---|
static ModeledFramework<PersonModel> |
ModeledCuratorExamples.wrap(AsyncCuratorFramework client) |
Constructor and Description |
---|
PersonModelSpec(AsyncCuratorFramework client) |
Modifier and Type | Method and Description |
---|---|
static AsyncCuratorFramework |
AsyncCuratorFramework.wrap(CuratorFramework client)
Takes an old-style Curator instance and returns a new async instance that
wraps it.
|
Modifier and Type | Method and Description |
---|---|
static CompletionStage<Void> |
AsyncWrappers.asyncEnsureContainers(AsyncCuratorFramework client,
String path)
Asynchronously ensure that the parents of the given path are created as containers
|
static CompletionStage<Void> |
AsyncWrappers.asyncEnsureParents(AsyncCuratorFramework client,
String path)
Asynchronously ensure that the parents of the given path are created
|
static CompletionStage<Map<String,byte[]>> |
AsyncWrappers.childrenWithData(AsyncCuratorFramework client,
String path)
Return the children of the given path (keyed by the full path) and the data for each node.
|
static CompletionStage<Map<String,byte[]>> |
AsyncWrappers.childrenWithData(AsyncCuratorFramework client,
String path,
boolean isCompressed)
Return the children of the given path (keyed by the full path) and the data for each node.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncCuratorFrameworkImpl |
Constructor and Description |
---|
MigrationManager(AsyncCuratorFramework client,
String lockPath,
String metaDataPath,
Executor executor,
Duration lockMax) |
Modifier and Type | Method and Description |
---|---|
AsyncCuratorFramework |
ModeledFramework.unwrap()
Returns the client that was originally passed to
ModeledFramework.wrap(org.apache.curator.x.async.AsyncCuratorFramework, ModelSpec) or
the builder. |
Modifier and Type | Method and Description |
---|---|
static <T> ModeledFrameworkBuilder<T> |
ModeledFramework.builder(AsyncCuratorFramework client,
ModelSpec<T> model)
Start a new ModeledFrameworkBuilder for the given model
|
ModeledFrameworkBuilder<T> |
ModeledFrameworkBuilder.withClient(AsyncCuratorFramework client)
Change the client to use
|
static <T> ModeledFramework<T> |
ModeledFramework.wrap(AsyncCuratorFramework client,
ModelSpec<T> model)
Return a new ModeledFramework for the given model
|
Modifier and Type | Method and Description |
---|---|
AsyncCuratorFramework |
ModeledFrameworkImpl.unwrap() |
Modifier and Type | Method and Description |
---|---|
static <T> ModeledFrameworkImpl<T> |
ModeledFrameworkImpl.build(AsyncCuratorFramework client,
ModelSpec<T> model,
WatchMode watchMode,
UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter,
UnhandledErrorListener unhandledErrorListener,
UnaryOperator<CuratorEvent> resultFilter,
Set<ModeledOptions> modeledOptions) |
Modifier and Type | Method and Description |
---|---|
ModeledFramework<M> |
TypedModeledFramework0.resolved(AsyncCuratorFramework client) |
ModeledFramework<M> |
TypedModeledFramework.resolved(AsyncCuratorFramework client,
P1 p1)
Resolve into a ModeledFramework using the given parameter
|
ModeledFramework<M> |
TypedModeledFramework2.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2) |
ModeledFramework<M> |
TypedModeledFramework3.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3) |
ModeledFramework<M> |
TypedModeledFramework4.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4) |
ModeledFramework<M> |
TypedModeledFramework5.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5) |
ModeledFramework<M> |
TypedModeledFramework6.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5,
P6 p6) |
ModeledFramework<M> |
TypedModeledFramework7.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5,
P6 p6,
P7 p7) |
ModeledFramework<M> |
TypedModeledFramework8.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5,
P6 p6,
P7 p7,
P8 p8) |
ModeledFramework<M> |
TypedModeledFramework9.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5,
P6 p6,
P7 p7,
P8 p8,
P9 p9) |
ModeledFramework<M> |
TypedModeledFramework10.resolved(AsyncCuratorFramework client,
P1 p1,
P2 p2,
P3 p3,
P4 p4,
P5 p5,
P6 p6,
P7 p7,
P8 p8,
P9 p9,
P10 p10) |
Constructor and Description |
---|
Publisher(AsyncCuratorFramework client) |
Subscriber(AsyncCuratorFramework client) |
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.