Modifier and Type | Field and Description |
---|---|
static CoreDurability |
CoreDurability.NONE |
Modifier and Type | Method and Description |
---|---|
static CoreDurability |
CoreDurability.of(DurabilityLevel level) |
static CoreDurability |
CoreDurability.of(Observe.ObservePersistTo persistTo,
Observe.ObserveReplicateTo replicateTo) |
Modifier and Type | Method and Description |
---|---|
static <T extends CoreMutationResult> |
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.
|
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Constructor and 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) |
Modifier and Type | Method and 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) |
Copyright © 2024 Couchbase, Inc.. All rights reserved.