Uses of Class
com.couchbase.client.core.api.kv.CoreDurability

Packages that use CoreDurability

Package	Description
com.couchbase.client.core.api.kv
com.couchbase.client.core.classic
com.couchbase.client.core.classic.kv
com.couchbase.client.core.protostellar
com.couchbase.client.core.protostellar.kv

Uses of CoreDurability in com.couchbase.client.core.api.kv

Fields in com.couchbase.client.core.api.kv declared as CoreDurability

Modifier and Type	Field	Description
static final CoreDurability	CoreDurability.NONE

Methods in com.couchbase.client.core.api.kv that return CoreDurability

Modifier and Type	Method	Description
static CoreDurability	CoreDurability.of(DurabilityLevel level)
static CoreDurability	CoreDurability.of(Observe.ObservePersistTo persistTo, Observe.ObserveReplicateTo replicateTo)

Methods in com.couchbase.client.core.api.kv with parameters of type CoreDurability

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	CoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
default CoreMutationResult	CoreKvBinaryOps.appendBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
default Mono<CoreMutationResult>	CoreKvBinaryOps.appendReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	CoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
default CoreCounterResult	CoreKvBinaryOps.decrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
default Mono<CoreCounterResult>	CoreKvBinaryOps.decrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	CoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
default CoreCounterResult	CoreKvBinaryOps.incrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
default Mono<CoreCounterResult>	CoreKvBinaryOps.incrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
default CoreMutationResult	CoreKvOps.insertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
default Mono<CoreMutationResult>	CoreKvOps.insertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreAsyncResponse<CoreMutationResult>	CoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durabilityLevel)
default CoreMutationResult	CoreKvBinaryOps.prependBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
default Mono<CoreMutationResult>	CoreKvBinaryOps.prependReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
default CoreMutationResult	CoreKvOps.removeBlocking(CoreCommonOptions common, String key, long cas, CoreDurability durability)
default Mono<CoreMutationResult>	CoreKvOps.removeReactive(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default CoreMutationResult	CoreKvOps.replaceBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default Mono<CoreMutationResult>	CoreKvOps.replaceReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreAsyncResponse<CoreSubdocMutateResult>	CoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
default CoreSubdocMutateResult	CoreKvOps.subdocMutateBlocking(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
default Mono<CoreSubdocMutateResult>	CoreKvOps.subdocMutateReactive(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default CoreMutationResult	CoreKvOps.upsertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default Mono<CoreMutationResult>	CoreKvOps.upsertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
static void	CoreKvBinaryParamValidators.validateAppendPrependArgs(String key, CoreKeyspace keyspace, CoreCommonOptions options, byte[] content, long cas, CoreDurability durability)
static void	CoreKvBinaryParamValidators.validateIncrementDecrementArgs(String key, CoreKeyspace keyspace, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
static void	CoreKvParamValidators.validateInsertParams(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
static void	CoreKvParamValidators.validateRemoveParams(CoreCommonOptions common, String key, long cas, CoreDurability durability)
static void	CoreKvParamValidators.validateReplaceParams(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
static void	CoreKvParamValidators.validateUpsertParams(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Uses of CoreDurability in com.couchbase.client.core.classic

Methods in com.couchbase.client.core.classic with parameters of type CoreDurability

Modifier and Type	Method	Description
static <T extends CoreMutationResult> CompletableFuture<T>	ClassicHelper.maybeWrapWithLegacyDurability(CompletableFuture<T> input, String key, CoreDurability durability, Core core, KeyValueRequest<?> request)	Helper method to wrap a mutation result to perform legacy durability requirements if needed.

Uses of CoreDurability in com.couchbase.client.core.classic.kv

Methods in com.couchbase.client.core.classic.kv with parameters of type CoreDurability

Modifier and Type	Method	Description
static CompletableFuture<CoreMutationResult>	BinaryAccessor.append(Core core, AppendRequest request, String key, CoreKeyspace keyspace, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)	Appends binary content to the document with custom options.
static CompletableFuture<CoreCounterResult>	BinaryAccessor.decrement(Core core, DecrementRequest request, String id, CoreKeyspace keyspace, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	ClassicCoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)	Decrements the counter document by one or the number defined in the options.
static CompletableFuture<CoreCounterResult>	BinaryAccessor.increment(Core core, IncrementRequest request, String id, CoreKeyspace keyspace, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	ClassicCoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)	Increments the counter document by one or the number defined in the options.
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
static CompletableFuture<CoreMutationResult>	BinaryAccessor.prepend(Core core, PrependRequest request, String key, CoreKeyspace keyspace, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)	Prepends binary content to the document with custom options.
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreAsyncResponse<CoreSubdocMutateResult>	ClassicCoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Uses of CoreDurability in com.couchbase.client.core.protostellar

Methods in com.couchbase.client.core.protostellar with parameters of type CoreDurability

Modifier and Type	Method	Description
static com.couchbase.client.protostellar.kv.v1.DurabilityLevel	CoreProtostellarUtil.convert(CoreDurability dl)
static RequestSpan	CoreProtostellarUtil.createSpan(CoreProtostellar core, String spanName, CoreDurability durability, RequestSpan parent)
static Duration	CoreProtostellarUtil.kvDurableTimeout(Optional<Duration> customTimeout, CoreDurability dl, CoreProtostellar core)

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

Modifier	Constructor	Description
	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)

Uses of CoreDurability in com.couchbase.client.core.protostellar.kv

Methods in com.couchbase.client.core.protostellar.kv with parameters of type CoreDurability

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreMutationResult	ProtostellarCoreKvBinaryOps.appendBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
Mono<CoreMutationResult>	ProtostellarCoreKvBinaryOps.appendReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.AppendRequest>	CoreProtoStellarKvBinaryRequests.appendRequest(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, byte[] content, long cas, CoreDurability durability)	For creating Protostellar GRPC requests.
CoreAsyncResponse<CoreCounterResult>	ProtostellarCoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreCounterResult	ProtostellarCoreKvBinaryOps.decrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
Mono<CoreCounterResult>	ProtostellarCoreKvBinaryOps.decrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.DecrementRequest>	CoreProtoStellarKvBinaryRequests.decrementRequest(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	ProtostellarCoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreCounterResult	ProtostellarCoreKvBinaryOps.incrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
Mono<CoreCounterResult>	ProtostellarCoreKvBinaryOps.incrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.IncrementRequest>	CoreProtoStellarKvBinaryRequests.incrementRequest(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreMutationResult	ProtostellarCoreKvOps.insertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
Mono<CoreMutationResult>	ProtostellarCoreKvOps.insertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.InsertRequest>	CoreProtostellarKeyValueRequests.insertRequest(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, CompressionConfig compressionConfig)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.MutateInRequest>	CoreProtostellarKeyValueRequests.mutateInRequest(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, List<CoreSubdocMutateCommand> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreMutationResult	ProtostellarCoreKvBinaryOps.prependBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
Mono<CoreMutationResult>	ProtostellarCoreKvBinaryOps.prependReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.PrependRequest>	CoreProtoStellarKvBinaryRequests.prependRequest(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, byte[] content, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreMutationResult	ProtostellarCoreKvOps.removeBlocking(CoreCommonOptions common, String key, long cas, CoreDurability durability)
Mono<CoreMutationResult>	ProtostellarCoreKvOps.removeReactive(CoreCommonOptions common, String key, long cas, CoreDurability durability)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.RemoveRequest>	CoreProtostellarKeyValueRequests.removeRequest(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreMutationResult	ProtostellarCoreKvOps.replaceBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
Mono<CoreMutationResult>	ProtostellarCoreKvOps.replaceReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.ReplaceRequest>	CoreProtostellarKeyValueRequests.replaceRequest(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, CompressionConfig compressionConfig)
CoreAsyncResponse<CoreSubdocMutateResult>	ProtostellarCoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreSubdocMutateResult	ProtostellarCoreKvOps.subdocMutateBlocking(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
Mono<CoreSubdocMutateResult>	ProtostellarCoreKvOps.subdocMutateReactive(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreMutationResult	ProtostellarCoreKvOps.upsertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
Mono<CoreMutationResult>	ProtostellarCoreKvOps.upsertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.UpsertRequest>	CoreProtostellarKeyValueRequests.upsertRequest(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, CompressionConfig compressionConfig)