Uses of Interface
com.couchbase.client.core.retry.RetryStrategy

Packages that use RetryStrategy

Package	Description
com.couchbase.client.core.diagnostics
com.couchbase.client.core.endpoint.http
com.couchbase.client.core.env
com.couchbase.client.core.msg
com.couchbase.client.core.msg.analytics
com.couchbase.client.core.msg.kv
com.couchbase.client.core.msg.manager
com.couchbase.client.core.msg.query
com.couchbase.client.core.msg.search
com.couchbase.client.core.msg.view
com.couchbase.client.core.protostellar
com.couchbase.client.core.retry
com.couchbase.client.core.service.kv

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)
static Mono<PingResult>	HealthPinger.ping(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName, WaitUntilReadyHelper.WaitUntilReadyLogger log)	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

Modifier	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

Modifier	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)
	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, boolean translateExceptions, int apiVersion)

Uses of RetryStrategy in com.couchbase.client.core.msg.kv

Methods in com.couchbase.client.core.msg.kv with parameters of type RetryStrategy

Modifier and Type	Method	Description
static ReplicaSubdocGetRequest	ReplicaSubdocGetRequest.create(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, short replica, RequestSpan span)
static SubdocGetRequest	SubdocGetRequest.create(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, RequestSpan span)

Constructors in com.couchbase.client.core.msg.kv with parameters of type RetryStrategy

Modifier	Constructor	Description
	AppendRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, RequestSpan span)
protected	BaseKeyValueRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier)
protected	BaseKeyValueRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, RequestSpan span)
	CarrierBucketConfigRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan)
	CarrierGlobalConfigRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan)
	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)
	PredeterminedPartitionRequest(short partition, Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, 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 reviveDocument, boolean accessDeleted, boolean createAsDeleted, List<SubdocMutateRequest.Command> commands, long expiration, boolean preserveExpiry, long cas, int userFlags, Optional<DurabilityLevel> syncReplicationType, RequestSpan span)	Deprecated. Please use the other constructor instead.
	SubdocMutateRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, BucketConfig bucketConfig, RetryStrategy retryStrategy, String key, CoreStoreSemantics storeSemantics, boolean accessDeleted, boolean createAsDeleted, List<CoreSubdocMutateCommand> 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

Modifier	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

Modifier	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, 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

Modifier	Constructor	Description
	ServerSearchRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String indexName, byte[] content, RequestSpan span, CoreBucketAndScope scope)

Uses of RetryStrategy in com.couchbase.client.core.msg.view

Constructors in com.couchbase.client.core.msg.view with parameters of type RetryStrategy

Modifier	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.protostellar

Methods in com.couchbase.client.core.protostellar that return RetryStrategy

Modifier and Type	Method	Description
RetryStrategy	ProtostellarBaseRequest.retryStrategy()
RetryStrategy	ProtostellarRequest.retryStrategy()

Constructors in com.couchbase.client.core.protostellar with parameters of type RetryStrategy

Modifier	Constructor	Description
	ProtostellarCollectionManagerRequest(TGrpcRequest request, CoreProtostellar core, String bucketName, String scopeName, String collectionName, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext)
	ProtostellarKeyValueRequest(TGrpcRequest request, CoreProtostellar core, CoreKeyspace keyspace, String key, CoreDurability durability, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext, long encodeDurationNanos)
	ProtostellarRequest(TGrpcRequest request, CoreProtostellar core, ServiceType serviceType, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext, long encodeDurationNanos, Consumer<Map<String,Object>> contextSupplier)

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 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 <R> CompletableFuture<List<CompletableFuture<R>>>	ReplicaHelper.lookupInAllReplicasAsync(Core core, CollectionIdentifier collectionIdentifier, String documentId, List<CoreSubdocGetCommand> commands, Duration timeout, RetryStrategy retryStrategy, Map<String,Object> clientContext, RequestSpan parentSpan, Function<CoreSubdocGetResult,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<CoreSubdocGetResult>	ReplicaHelper.lookupInAllReplicasReactive(Core core, CollectionIdentifier collectionIdentifier, String documentId, List<CoreSubdocGetCommand> commands, Duration timeout, RetryStrategy retryStrategy, Map<String,Object> clientContext, RequestSpan parentSpan)
static CompletableFuture<Stream<SubdocGetRequest>>	ReplicaHelper.lookupInAllReplicasRequests(Core core, CollectionIdentifier collectionIdentifier, String documentId, List<CoreSubdocGetCommand> commands, 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.lookupInAnyReplicaAsync(Core core, CollectionIdentifier collectionIdentifier, String documentId, List<CoreSubdocGetCommand> commands, Duration timeout, RetryStrategy retryStrategy, Map<String,Object> clientContext, RequestSpan parentSpan, Function<CoreSubdocGetResult,R> responseMapper)