Package | Description |
---|---|
com.couchbase.client.core.service.kv |
Modifier and Type | Method and Description |
---|---|
static Flux<ReplicaHelper.GetReplicaResponse> |
ReplicaHelper.getAllReplicasReactive(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan) |
Modifier and Type | Method and Description |
---|---|
static <R> CompletableFuture<List<CompletableFuture<R>>> |
ReplicaHelper.getAllReplicasAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<ReplicaHelper.GetReplicaResponse,R> responseMapper)
Reads from replicas or the active node based on the options and returns the results as a list
of futures that might complete or fail.
|
static <R> CompletableFuture<R> |
ReplicaHelper.getAnyReplicaAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<ReplicaHelper.GetReplicaResponse,R> responseMapper) |
Copyright © 2024 Couchbase, Inc.. All rights reserved.