Package com.couchbase.client.core.classic.kv

Class ClassicCoreKvOps

java.lang.Object

com.couchbase.client.core.classic.kv.ClassicCoreKvOps

All Implemented Interfaces:

CoreKvOps

@Internal
public final class ClassicCoreKvOps
extends Object
implements CoreKvOps

Constructor Summary

Constructors

Constructor	Description
ClassicCoreKvOps(Core core, CoreKeyspace keyspace)

Method Summary

Modifier and Type	Method	Description
CoreAsyncResponse<CoreExistsResult>	existsAsync(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)
CoreAsyncResponse<CoreGetResult>	getAndTouchAsync(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)
CoreAsyncResponse<CoreMutationResult>	insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreAsyncResponse<CoreMutationResult>	removeAsync(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)
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)
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)
CoreAsyncResponse<CoreMutationResult>	touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<Void>	unlockAsync(CoreCommonOptions common, String key, long cas)
CoreAsyncResponse<CoreMutationResult>	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

public ClassicCoreKvOps(Core core,
 CoreKeyspace keyspace)

Method Details

getAsync

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

Specified by:

getAsync in interface CoreKvOps

getAndLockAsync

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

Specified by:

getAndLockAsync in interface CoreKvOps

getAndTouchAsync

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

Specified by:

getAndTouchAsync in interface CoreKvOps

insertAsync

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

Specified by:

insertAsync in interface CoreKvOps

upsertAsync

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

Specified by:

upsertAsync in interface CoreKvOps

replaceAsync

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

Specified by:

replaceAsync in interface CoreKvOps

removeAsync

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

Specified by:

removeAsync in interface CoreKvOps

existsAsync

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

Specified by:

existsAsync in interface CoreKvOps

touchAsync

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

Specified by:

touchAsync in interface CoreKvOps

unlockAsync

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

Specified by:

unlockAsync in interface CoreKvOps

subdocGetAsync

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

Specified by:

subdocGetAsync in interface CoreKvOps

getAllReplicasReactive

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

Specified by:

getAllReplicasReactive in interface CoreKvOps

getAnyReplicaReactive

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

Specified by:

getAnyReplicaReactive in interface CoreKvOps

subdocGetAllReplicasReactive

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

Specified by:

subdocGetAllReplicasReactive in interface CoreKvOps

subdocGetAnyReplicaReactive

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

Specified by:

subdocGetAnyReplicaReactive in interface CoreKvOps

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 interface CoreKvOps

scanRequestReactive

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

Specified by:

scanRequestReactive in interface CoreKvOps