-
-
-
-
-
-
Constructors in com.couchbase.client.core.msg.analytics with parameters of type RetryStrategy
Constructor |
Description |
AnalyticsRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
byte[] query,
int priority,
boolean idempotent,
String contextId,
String statement,
RequestSpan span,
String bucket,
String scope) |
|
-
Constructors in com.couchbase.client.core.msg.kv with parameters of type RetryStrategy
Constructor |
Description |
AppendRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte[] content,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
BaseKeyValueRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier) |
|
BaseKeyValueRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier,
RequestSpan span) |
|
CarrierBucketConfigRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
NodeIdentifier target) |
|
CarrierGlobalConfigRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
NodeIdentifier target) |
|
DecrementRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long delta,
Optional<Long> initial,
long expiry,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
GetAndLockRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Duration lockFor,
RequestSpan span) |
|
GetAndTouchRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
long expiration,
RequestSpan span) |
|
GetCollectionIdRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier collectionIdentifier) |
|
GetCollectionManifestRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier collectionIdentifier) |
|
GetMetaRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
RequestSpan span) |
|
GetRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
RequestSpan span) |
|
IncrementRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long delta,
Optional<Long> initial,
long expiration,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
InsertRequest(String key,
byte[] content,
long expiration,
int flags,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
KvPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier identifier,
NodeIdentifier target) |
|
MultiObserveViaCasRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier collectionIdentifier,
NodeIdentifier target,
Map<byte[],Short> keys,
Predicate<ObserveViaCasResponse.ObserveStatus> responsePredicate) |
|
NoopRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier collectionIdentifier) |
|
ObserveViaCasRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
boolean active,
int replica) |
|
ObserveViaSeqnoRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
int replica,
boolean active,
long vbucketUUID,
String key,
RequestSpan span) |
|
PrependRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte[] content,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
RemoveRequest(String key,
long cas,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
ReplaceRequest(String key,
byte[] content,
long expiration,
boolean preserveExpiry,
int flags,
Duration timeout,
long cas,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
ReplicaGetRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
short replica,
RequestSpan span) |
|
SubdocGetRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte flags,
List<SubdocGetRequest.Command> commands,
RequestSpan span) |
|
SubdocMutateRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
BucketConfig bucketConfig,
RetryStrategy retryStrategy,
String key,
boolean insertDocument,
boolean upsertDocument,
boolean accessDeleted,
boolean createAsDeleted,
List<SubdocMutateRequest.Command> commands,
long expiration,
boolean preserveExpiry,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
TouchRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long expiry,
RequestSpan span) |
|
UnlockRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long cas,
RequestSpan span) |
|
UpsertRequest(String key,
byte[] content,
long expiration,
boolean preserveExpiry,
int flags,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
-
Constructors in com.couchbase.client.core.msg.manager with parameters of type RetryStrategy
Constructor |
Description |
BucketConfigRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String bucketName,
Authenticator authenticator,
NodeIdentifier target) |
|
BucketConfigStreamingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String bucketName,
Authenticator authenticator) |
|
GenericManagerRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier,
boolean idempotent,
RequestSpan span) |
|
-
Constructors in com.couchbase.client.core.msg.query with parameters of type RetryStrategy
Constructor |
Description |
QueryRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String statement,
byte[] query,
boolean idempotent,
String contextId,
RequestSpan span,
String bucket,
String scope) |
|
TargetedQueryRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String statement,
byte[] query,
boolean idempotent,
String contextId,
RequestSpan parentSpan,
String bucket,
String scope,
NodeIdentifier target) |
|
-
-
Constructors in com.couchbase.client.core.msg.view with parameters of type RetryStrategy
Constructor |
Description |
ViewRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String bucket,
String design,
String view,
String query,
Optional<byte[]> keysJson,
boolean development,
RequestSpan span) |
|
-
-
Methods in com.couchbase.client.core.service.kv with parameters of type RetryStrategy
Modifier and Type |
Method |
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 Flux<ReplicaHelper.GetReplicaResponse> |
ReplicaHelper.getAllReplicasReactive(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan) |
|
static CompletableFuture<Stream<GetRequest>> |
ReplicaHelper.getAllReplicasRequests(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Map<String,Object> clientContext,
RetryStrategy retryStrategy,
Duration timeout,
RequestSpan parent) |
Helper method to assemble a stream of requests to the active and all replicas
|
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) |
|
static Mono<ReplicaHelper.GetReplicaResponse> |
ReplicaHelper.getAnyReplicaReactive(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan) |
|