Package com.couchbase.client.core.api.kv

Interface CoreKvOps

All Known Implementing Classes:

ClassicCoreKvOps, ProtostellarCoreKvOps

@Internal
public interface CoreKvOps

Method Summary

Modifier and Type	Method	Description
default void	checkProjectionLimits(List<String> projections, boolean withExpiry)
CoreAsyncResponse<CoreExistsResult>	existsAsync(CoreCommonOptions common, String key)
default CoreExistsResult	existsBlocking(CoreCommonOptions common, String key)
default reactor.core.publisher.Mono<CoreExistsResult>	existsReactive(CoreCommonOptions common, String key)
reactor.core.publisher.Flux<CoreGetResult>	getAllReplicasReactive(CoreCommonOptions common, String key, CoreReadPreference readPreference)
CoreAsyncResponse<CoreGetResult>	getAndLockAsync(CoreCommonOptions common, String key, Duration lockTime)
default CoreGetResult	getAndLockBlocking(CoreCommonOptions common, String key, Duration lockTime)
default reactor.core.publisher.Mono<CoreGetResult>	getAndLockReactive(CoreCommonOptions common, String key, Duration lockTime)
CoreAsyncResponse<CoreGetResult>	getAndTouchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
default CoreGetResult	getAndTouchBlocking(CoreCommonOptions common, String key, CoreExpiry expiry)
default reactor.core.publisher.Mono<CoreGetResult>	getAndTouchReactive(CoreCommonOptions common, String key, CoreExpiry expiry)
reactor.core.publisher.Mono<CoreGetResult>	getAnyReplicaReactive(CoreCommonOptions common, String key, CoreReadPreference readPreference)
CoreAsyncResponse<CoreGetResult>	getAsync(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
default CoreGetResult	getBlocking(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
default reactor.core.publisher.Mono<CoreGetResult>	getReactive(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
CoreAsyncResponse<CoreMutationResult>	insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
default CoreMutationResult	insertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
default reactor.core.publisher.Mono<CoreMutationResult>	insertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreAsyncResponse<CoreMutationResult>	removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
default CoreMutationResult	removeBlocking(CoreCommonOptions common, String key, long cas, CoreDurability durability)
default reactor.core.publisher.Mono<CoreMutationResult>	removeReactive(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default CoreMutationResult	replaceBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default reactor.core.publisher.Mono<CoreMutationResult>	replaceReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default CompletableFuture<List<CoreRangeScanItem>>	scanRequestAsync(CoreScanType coreScanType, CoreScanOptions coreScanOptions)
default Stream<CoreRangeScanItem>	scanRequestBlocking(CoreScanType coreScanType, CoreScanOptions coreScanOptions)
reactor.core.publisher.Flux<CoreRangeScanItem>	scanRequestReactive(CoreScanType scanType, CoreScanOptions options)
reactor.core.publisher.Flux<CoreSubdocGetResult>	subdocGetAllReplicasReactive(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference)
reactor.core.publisher.Mono<CoreSubdocGetResult>	subdocGetAnyReplicaReactive(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, CoreReadPreference readPreference)
CoreAsyncResponse<CoreSubdocGetResult>	subdocGetAsync(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
default CoreSubdocGetResult	subdocGetBlocking(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
default reactor.core.publisher.Mono<CoreSubdocGetResult>	subdocGetReactive(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
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)
default CoreSubdocMutateResult	subdocMutateBlocking(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
default reactor.core.publisher.Mono<CoreSubdocMutateResult>	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>	touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
default CoreMutationResult	touchBlocking(CoreCommonOptions common, String key, CoreExpiry expiry)
default reactor.core.publisher.Mono<CoreMutationResult>	touchReactive(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<Void>	unlockAsync(CoreCommonOptions common, String key, long cas)
default void	unlockBlocking(CoreCommonOptions common, String key, long cas)
default reactor.core.publisher.Mono<Void>	unlockReactive(CoreCommonOptions common, String key, long cas)
CoreAsyncResponse<CoreMutationResult>	upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default CoreMutationResult	upsertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
default reactor.core.publisher.Mono<CoreMutationResult>	upsertReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Method Details

getAsync

CoreAsyncResponse<CoreGetResult> getAsync(CoreCommonOptions common,
 String key,
 List<String> projections,
 boolean withExpiry)

getBlocking

default CoreGetResult getBlocking(CoreCommonOptions common,
 String key,
 List<String> projections,
 boolean withExpiry)

getReactive

default reactor.core.publisher.Mono<CoreGetResult> getReactive(CoreCommonOptions common,
 String key,
 List<String> projections,
 boolean withExpiry)

checkProjectionLimits

default void checkProjectionLimits(List<String> projections,
 boolean withExpiry)

getAndLockAsync

CoreAsyncResponse<CoreGetResult> getAndLockAsync(CoreCommonOptions common,
 String key,
 Duration lockTime)

getAndLockBlocking

default CoreGetResult getAndLockBlocking(CoreCommonOptions common,
 String key,
 Duration lockTime)

getAndLockReactive

default reactor.core.publisher.Mono<CoreGetResult> getAndLockReactive(CoreCommonOptions common,
 String key,
 Duration lockTime)

getAndTouchAsync

CoreAsyncResponse<CoreGetResult> getAndTouchAsync(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

getAndTouchBlocking

default CoreGetResult getAndTouchBlocking(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

getAndTouchReactive

default reactor.core.publisher.Mono<CoreGetResult> getAndTouchReactive(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

insertAsync

CoreAsyncResponse<CoreMutationResult> insertAsync(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry)

insertBlocking

default CoreMutationResult insertBlocking(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry)

insertReactive

default reactor.core.publisher.Mono<CoreMutationResult> insertReactive(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry)

upsertAsync

CoreAsyncResponse<CoreMutationResult> upsertAsync(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

upsertBlocking

default CoreMutationResult upsertBlocking(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

upsertReactive

default reactor.core.publisher.Mono<CoreMutationResult> upsertReactive(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

replaceAsync

CoreAsyncResponse<CoreMutationResult> replaceAsync(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 long cas,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

replaceBlocking

default CoreMutationResult replaceBlocking(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 long cas,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

replaceReactive

default reactor.core.publisher.Mono<CoreMutationResult> replaceReactive(CoreCommonOptions common,
 String key,
 Supplier<CoreEncodedContent> content,
 long cas,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry)

removeAsync

CoreAsyncResponse<CoreMutationResult> removeAsync(CoreCommonOptions common,
 String key,
 long cas,
 CoreDurability durability)

removeBlocking

default CoreMutationResult removeBlocking(CoreCommonOptions common,
 String key,
 long cas,
 CoreDurability durability)

removeReactive

default reactor.core.publisher.Mono<CoreMutationResult> removeReactive(CoreCommonOptions common,
 String key,
 long cas,
 CoreDurability durability)

existsAsync

CoreAsyncResponse<CoreExistsResult> existsAsync(CoreCommonOptions common,
 String key)

existsBlocking

default CoreExistsResult existsBlocking(CoreCommonOptions common,
 String key)

existsReactive

default reactor.core.publisher.Mono<CoreExistsResult> existsReactive(CoreCommonOptions common,
 String key)

touchAsync

CoreAsyncResponse<CoreMutationResult> touchAsync(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

touchBlocking

default CoreMutationResult touchBlocking(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

touchReactive

default reactor.core.publisher.Mono<CoreMutationResult> touchReactive(CoreCommonOptions common,
 String key,
 CoreExpiry expiry)

unlockAsync

CoreAsyncResponse<Void> unlockAsync(CoreCommonOptions common,
 String key,
 long cas)

unlockBlocking

default void unlockBlocking(CoreCommonOptions common,
 String key,
 long cas)

unlockReactive

default reactor.core.publisher.Mono<Void> unlockReactive(CoreCommonOptions common,
 String key,
 long cas)

subdocGetAsync

CoreAsyncResponse<CoreSubdocGetResult> subdocGetAsync(CoreCommonOptions common,
 String key,
 List<CoreSubdocGetCommand> commands,
 boolean accessDeleted)

subdocGetBlocking

default CoreSubdocGetResult subdocGetBlocking(CoreCommonOptions common,
 String key,
 List<CoreSubdocGetCommand> commands,
 boolean accessDeleted)

subdocGetReactive

default reactor.core.publisher.Mono<CoreSubdocGetResult> subdocGetReactive(CoreCommonOptions common,
 String key,
 List<CoreSubdocGetCommand> commands,
 boolean accessDeleted)

subdocGetAllReplicasReactive

reactor.core.publisher.Flux<CoreSubdocGetResult> subdocGetAllReplicasReactive(CoreCommonOptions common,
 String key,
 List<CoreSubdocGetCommand> commands,
 CoreReadPreference readPreference)

subdocGetAnyReplicaReactive

reactor.core.publisher.Mono<CoreSubdocGetResult> subdocGetAnyReplicaReactive(CoreCommonOptions common,
 String key,
 List<CoreSubdocGetCommand> commands,
 CoreReadPreference readPreference)

getAllReplicasReactive

reactor.core.publisher.Flux<CoreGetResult> getAllReplicasReactive(CoreCommonOptions common,
 String key,
 CoreReadPreference readPreference)

getAnyReplicaReactive

reactor.core.publisher.Mono<CoreGetResult> getAnyReplicaReactive(CoreCommonOptions common,
 String key,
 CoreReadPreference readPreference)

subdocMutateAsync

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)

subdocMutateBlocking

default CoreSubdocMutateResult subdocMutateBlocking(CoreCommonOptions common,
 String key,
 Supplier<List<CoreSubdocMutateCommand>> commands,
 CoreStoreSemantics storeSemantics,
 long cas,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry,
 boolean accessDeleted,
 boolean createAsDeleted)

subdocMutateReactive

default reactor.core.publisher.Mono<CoreSubdocMutateResult> subdocMutateReactive(CoreCommonOptions common,
 String key,
 Supplier<List<CoreSubdocMutateCommand>> commands,
 CoreStoreSemantics storeSemantics,
 long cas,
 CoreDurability durability,
 CoreExpiry expiry,
 boolean preserveExpiry,
 boolean accessDeleted,
 boolean createAsDeleted)

scanRequestReactive

reactor.core.publisher.Flux<CoreRangeScanItem> scanRequestReactive(CoreScanType scanType,
 CoreScanOptions options)

scanRequestAsync

default CompletableFuture<List<CoreRangeScanItem>> scanRequestAsync(CoreScanType coreScanType,
 CoreScanOptions coreScanOptions)

scanRequestBlocking

default Stream<CoreRangeScanItem> scanRequestBlocking(CoreScanType coreScanType,
 CoreScanOptions coreScanOptions)