Uses of Interface
com.couchbase.client.core.retry.RetryStrategy
-
-
Uses of RetryStrategy in com.couchbase.client.core.diagnostics
Methods in com.couchbase.client.core.diagnostics with parameters of type RetryStrategy Modifier and Type Method Description static Mono<PingResult>
HealthPinger. ping(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName)
Performs a service ping against all or (if given) the services provided. -
Uses of RetryStrategy in com.couchbase.client.core.endpoint.http
Methods in com.couchbase.client.core.endpoint.http that return types with arguments of type RetryStrategy Modifier and Type Method Description Optional<RetryStrategy>
CoreCommonOptions. retryStrategy()
Methods in com.couchbase.client.core.endpoint.http with parameters of type RetryStrategy Modifier and Type Method Description static CoreCommonOptions
CoreCommonOptions. of(Duration timeout, RetryStrategy retryStrategy, RequestSpan parentSpan)
-
Uses of RetryStrategy in com.couchbase.client.core.env
Methods in com.couchbase.client.core.env that return RetryStrategy Modifier and Type Method Description RetryStrategy
CoreEnvironment. retryStrategy()
Returns the retry strategy on this environment.Methods in com.couchbase.client.core.env with parameters of type RetryStrategy Modifier and Type Method Description SELF
CoreEnvironment.Builder. retryStrategy(RetryStrategy retryStrategy)
Allows to customize the default retry strategy. -
Uses of RetryStrategy in com.couchbase.client.core.msg
Methods in com.couchbase.client.core.msg that return RetryStrategy Modifier and Type Method Description RetryStrategy
BaseRequest. retryStrategy()
RetryStrategy
Request. retryStrategy()
The retry strategy for this particular request.Constructors in com.couchbase.client.core.msg with parameters of type RetryStrategy Constructor Description BaseRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy)
BaseRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, RequestSpan requestSpan)
Creates a basic request that has all the required properties to be executed in general. -
Uses of RetryStrategy in com.couchbase.client.core.msg.analytics
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)
-
Uses of RetryStrategy in com.couchbase.client.core.msg.kv
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)
-
Uses of RetryStrategy in com.couchbase.client.core.msg.manager
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)
Deprecated. -
Uses of RetryStrategy in com.couchbase.client.core.msg.query
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)
-
Uses of RetryStrategy in com.couchbase.client.core.msg.search
Constructors in com.couchbase.client.core.msg.search with parameters of type RetryStrategy Constructor Description SearchRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String indexName, byte[] content, RequestSpan span)
-
Uses of RetryStrategy in com.couchbase.client.core.msg.view
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)
-
Uses of RetryStrategy in com.couchbase.client.core.retry
Classes in com.couchbase.client.core.retry that implement RetryStrategy Modifier and Type Class Description class
BestEffortRetryStrategy
Retries operations on a best-effort basis until they time out.class
FailFastRetryStrategy
An internal strategy to fail fast any request that goes through it. -
Uses of RetryStrategy in com.couchbase.client.core.service.kv
Methods in com.couchbase.client.core.service.kv that return RetryStrategy Modifier and Type Method Description RetryStrategy
ObserveContext. retryStrategy()
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 replicasstatic <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)
-