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

Class ProtostellarCoreKvBinaryOps

java.lang.Object

com.couchbase.client.core.protostellar.kv.ProtostellarCoreKvBinaryOps

All Implemented Interfaces:

CoreKvBinaryOps

@Internal
public class ProtostellarCoreKvBinaryOps
extends Object
implements CoreKvBinaryOps

Constructor Summary

Constructors

Constructor	Description
ProtostellarCoreKvBinaryOps(CoreProtostellar core, CoreKeyspace keyspace)

Method Summary

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreMutationResult	appendBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
reactor.core.publisher.Mono<CoreMutationResult>	appendReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreCounterResult	decrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
reactor.core.publisher.Mono<CoreCounterResult>	decrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreCounterResult	incrementBlocking(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
reactor.core.publisher.Mono<CoreCounterResult>	incrementReactive(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreMutationResult	prependBlocking(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
reactor.core.publisher.Mono<CoreMutationResult>	prependReactive(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProtostellarCoreKvBinaryOps

public ProtostellarCoreKvBinaryOps(CoreProtostellar core,
 CoreKeyspace keyspace)

Method Details

appendBlocking

public CoreMutationResult appendBlocking(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

appendBlocking in interface CoreKvBinaryOps

appendAsync

public CoreAsyncResponse<CoreMutationResult> appendAsync(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

appendAsync in interface CoreKvBinaryOps

appendReactive

public reactor.core.publisher.Mono<CoreMutationResult> appendReactive(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

appendReactive in interface CoreKvBinaryOps

prependBlocking

public CoreMutationResult prependBlocking(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

prependBlocking in interface CoreKvBinaryOps

prependAsync

public CoreAsyncResponse<CoreMutationResult> prependAsync(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

prependAsync in interface CoreKvBinaryOps

prependReactive

public reactor.core.publisher.Mono<CoreMutationResult> prependReactive(String id,
 byte[] content,
 CoreCommonOptions options,
 long cas,
 CoreDurability durability)

Specified by:

prependReactive in interface CoreKvBinaryOps

incrementBlocking

public CoreCounterResult incrementBlocking(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

incrementBlocking in interface CoreKvBinaryOps

incrementAsync

public CoreAsyncResponse<CoreCounterResult> incrementAsync(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

incrementAsync in interface CoreKvBinaryOps

incrementReactive

public reactor.core.publisher.Mono<CoreCounterResult> incrementReactive(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

incrementReactive in interface CoreKvBinaryOps

decrementBlocking

public CoreCounterResult decrementBlocking(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

decrementBlocking in interface CoreKvBinaryOps

decrementAsync

public CoreAsyncResponse<CoreCounterResult> decrementAsync(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

decrementAsync in interface CoreKvBinaryOps

decrementReactive

public reactor.core.publisher.Mono<CoreCounterResult> decrementReactive(String id,
 CoreCommonOptions options,
 CoreExpiry expiry,
 long delta,
 Optional<Long> initial,
 CoreDurability durability)

Specified by:

decrementReactive in interface CoreKvBinaryOps