Class ClassicCoreKvOps
java.lang.Object
com.couchbase.client.core.classic.kv.ClassicCoreKvOps
- All Implemented Interfaces:
CoreKvOps
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionexistsAsync
(CoreCommonOptions common, String key) getAllReplicasReactive
(CoreCommonOptions common, String key, CoreReadPreference readPreference) getAndLockAsync
(CoreCommonOptions common, String key, Duration lockTime) getAndTouchAsync
(CoreCommonOptions common, String key, CoreExpiry expiry) getAnyReplicaReactive
(CoreCommonOptions common, String key, CoreReadPreference readPreference) getAsync
(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry) insertAsync
(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry) removeAsync
(CoreCommonOptions common, String key, long cas, CoreDurability durability) replaceAsync
(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry) scanRequestReactive
(CoreScanType scanType, CoreScanOptions options) subdocGetAllReplicasReactive
(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference) subdocGetAnyReplicaReactive
(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference) subdocGetAsync
(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted) subdocMutateAsync
(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted) touchAsync
(CoreCommonOptions common, String key, CoreExpiry expiry) unlockAsync
(CoreCommonOptions common, String key, long cas) upsertAsync
(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.couchbase.client.core.api.kv.CoreKvOps
checkProjectionLimits, existsBlocking, existsReactive, getAndLockBlocking, getAndLockReactive, getAndTouchBlocking, getAndTouchReactive, getBlocking, getReactive, insertBlocking, insertReactive, removeBlocking, removeReactive, replaceBlocking, replaceReactive, scanRequestAsync, scanRequestBlocking, subdocGetBlocking, subdocGetReactive, subdocMutateBlocking, subdocMutateReactive, touchBlocking, touchReactive, unlockBlocking, unlockReactive, upsertBlocking, upsertReactive
-
Constructor Details
-
ClassicCoreKvOps
-
-
Method Details
-
getAsync
public CoreAsyncResponse<CoreGetResult> getAsync(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry) -
getAndLockAsync
public CoreAsyncResponse<CoreGetResult> getAndLockAsync(CoreCommonOptions common, String key, Duration lockTime) - Specified by:
getAndLockAsync
in interfaceCoreKvOps
-
getAndTouchAsync
public CoreAsyncResponse<CoreGetResult> getAndTouchAsync(CoreCommonOptions common, String key, CoreExpiry expiry) - Specified by:
getAndTouchAsync
in interfaceCoreKvOps
-
insertAsync
public CoreAsyncResponse<CoreMutationResult> insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry) - Specified by:
insertAsync
in interfaceCoreKvOps
-
upsertAsync
public CoreAsyncResponse<CoreMutationResult> upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry) - Specified by:
upsertAsync
in interfaceCoreKvOps
-
replaceAsync
public CoreAsyncResponse<CoreMutationResult> replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry) - Specified by:
replaceAsync
in interfaceCoreKvOps
-
removeAsync
public CoreAsyncResponse<CoreMutationResult> removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability) - Specified by:
removeAsync
in interfaceCoreKvOps
-
existsAsync
- Specified by:
existsAsync
in interfaceCoreKvOps
-
touchAsync
public CoreAsyncResponse<CoreMutationResult> touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry) - Specified by:
touchAsync
in interfaceCoreKvOps
-
unlockAsync
- Specified by:
unlockAsync
in interfaceCoreKvOps
-
subdocGetAsync
public CoreAsyncResponse<CoreSubdocGetResult> subdocGetAsync(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted) - Specified by:
subdocGetAsync
in interfaceCoreKvOps
-
getAllReplicasReactive
public Flux<CoreGetResult> getAllReplicasReactive(CoreCommonOptions common, String key, CoreReadPreference readPreference) - Specified by:
getAllReplicasReactive
in interfaceCoreKvOps
-
getAnyReplicaReactive
public Mono<CoreGetResult> getAnyReplicaReactive(CoreCommonOptions common, String key, CoreReadPreference readPreference) - Specified by:
getAnyReplicaReactive
in interfaceCoreKvOps
-
subdocGetAllReplicasReactive
public Flux<CoreSubdocGetResult> subdocGetAllReplicasReactive(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference) - Specified by:
subdocGetAllReplicasReactive
in interfaceCoreKvOps
-
subdocGetAnyReplicaReactive
public Mono<CoreSubdocGetResult> subdocGetAnyReplicaReactive(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference) - Specified by:
subdocGetAnyReplicaReactive
in interfaceCoreKvOps
-
subdocMutateAsync
public CoreAsyncResponse<CoreSubdocMutateResult> subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted) - Specified by:
subdocMutateAsync
in interfaceCoreKvOps
-
scanRequestReactive
- Specified by:
scanRequestReactive
in interfaceCoreKvOps
-