Package com.couchbase.client.core.protostellar.kv

Class ProtostellarCoreKvOps

java.lang.Object

com.couchbase.client.core.protostellar.kv.ProtostellarCoreKvOps

All Implemented Interfaces:

CoreKvOps

@Internal
public final class ProtostellarCoreKvOps
extends Object
implements CoreKvOps

Constructor Summary

Constructors

Constructor	Description
ProtostellarCoreKvOps(CoreProtostellar core, CoreKeyspace keyspace)

Method Summary

Modifier and Type	Method	Description
CoreAsyncResponse<CoreExistsResult>	existsAsync(CoreCommonOptions common, String key)
CoreExistsResult	existsBlocking(CoreCommonOptions common, String key)
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)
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)
CoreGetResult	getBlocking(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
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)
CoreMutationResult	insertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
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)
CoreMutationResult	removeBlocking(CoreCommonOptions common, String key, long cas, CoreDurability durability)
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)
CoreMutationResult	replaceBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
reactor.core.publisher.Mono<CoreMutationResult>	replaceReactive(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CompletableFuture<List<CoreRangeScanItem>>	scanRequestAsync(CoreScanType scanType, CoreScanOptions options)
Stream<CoreRangeScanItem>	scanRequestBlocking(CoreScanType scanType, CoreScanOptions options)
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)
CoreSubdocGetResult	subdocGetBlocking(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
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)
CoreSubdocMutateResult	subdocMutateBlocking(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
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)
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)
CoreMutationResult	upsertBlocking(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
reactor.core.publisher.Mono<CoreMutationResult>	upsertReactive(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, getAndLockBlocking, getAndLockReactive, getAndTouchBlocking, getAndTouchReactive, touchBlocking, touchReactive, unlockBlocking, unlockReactive

Constructor Details

ProtostellarCoreKvOps

public ProtostellarCoreKvOps(CoreProtostellar core,
 CoreKeyspace keyspace)

Method Details

getBlocking

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

Specified by:

getBlocking in interface CoreKvOps

getAsync

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

Specified by:

getAsync in interface CoreKvOps

getReactive

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

Specified by:

getReactive 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

insertBlocking

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

Specified by:

insertBlocking 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

insertReactive

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

Specified by:

insertReactive in interface CoreKvOps

upsertBlocking

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

Specified by:

upsertBlocking 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

upsertReactive

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

Specified by:

upsertReactive in interface CoreKvOps

replaceBlocking

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

Specified by:

replaceBlocking 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

replaceReactive

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

Specified by:

replaceReactive in interface CoreKvOps

removeBlocking

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

Specified by:

removeBlocking in interface CoreKvOps

removeAsync

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

Specified by:

removeAsync in interface CoreKvOps

removeReactive

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

Specified by:

removeReactive in interface CoreKvOps

existsBlocking

public CoreExistsResult existsBlocking(CoreCommonOptions common,
 String key)

Specified by:

existsBlocking in interface CoreKvOps

existsAsync

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

Specified by:

existsAsync in interface CoreKvOps

existsReactive

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

Specified by:

existsReactive 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

subdocGetBlocking

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

Specified by:

subdocGetBlocking in interface CoreKvOps

subdocGetAsync

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

Specified by:

subdocGetAsync in interface CoreKvOps

subdocGetReactive

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

Specified by:

subdocGetReactive 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

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

subdocMutateBlocking

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

Specified by:

subdocMutateBlocking 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

subdocMutateReactive

public 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)

Specified by:

subdocMutateReactive in interface CoreKvOps

scanRequestReactive

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

Specified by:

scanRequestReactive in interface CoreKvOps

scanRequestAsync

public CompletableFuture<List<CoreRangeScanItem>> scanRequestAsync(CoreScanType scanType,
 CoreScanOptions options)

Specified by:

scanRequestAsync in interface CoreKvOps

scanRequestBlocking

public Stream<CoreRangeScanItem> scanRequestBlocking(CoreScanType scanType,
 CoreScanOptions options)

Specified by:

scanRequestBlocking in interface CoreKvOps