Package com.couchbase.client.core.transaction.util

Class TransactionKVHandler

java.lang.Object

com.couchbase.client.core.transaction.util.TransactionKVHandler

@Internal
public class TransactionKVHandler
extends Object

Transactions does a lot of KV work from core-io. This logic is essentially a mini version of java-client, providing the bare minimum of required KV functionality.

Method Summary

Modifier and Type	Method	Description
static Mono<InsertResponse>	insert(Core core, CollectionIdentifier collectionIdentifier, String id, byte[] transcodedContent, int flags, Duration timeout, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper pspan)
static Mono<CoreSubdocGetResult>	lookupIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean accessDeleted, Map<String,Object> clientContext, SpanWrapper pspan, boolean preferredReplicaMode, List<SubdocGetRequest.Command> commands)
static Mono<SubdocMutateResponse>	mutateIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, int userFlags, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper span, List<SubdocMutateRequest.Command> commands)
static Mono<SubdocMutateResponse>	mutateIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, int userFlags, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper pspan, List<SubdocMutateRequest.Command> commands, CoreTransactionLogger logger)
static Mono<RemoveResponse>	remove(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper pspan)

Methods inherited from class java.lang.Object

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

Method Details

insert

public static Mono<InsertResponse> insert(Core core,
 CollectionIdentifier collectionIdentifier,
 String id,
 byte[] transcodedContent,
 int flags,
 Duration timeout,
 Optional<DurabilityLevel> durabilityLevel,
 Map<String,Object> clientContext,
 SpanWrapper pspan)

remove

public static Mono<RemoveResponse> remove(Core core,
 CollectionIdentifier collectionIdentifier,
 String id,
 Duration timeout,
 long cas,
 Optional<DurabilityLevel> durabilityLevel,
 Map<String,Object> clientContext,
 SpanWrapper pspan)

lookupIn

public static Mono<CoreSubdocGetResult> lookupIn(Core core,
 CollectionIdentifier collectionIdentifier,
 String id,
 Duration timeout,
 boolean accessDeleted,
 Map<String,Object> clientContext,
 @Nullable
 SpanWrapper pspan,
 boolean preferredReplicaMode,
 List<SubdocGetRequest.Command> commands)

mutateIn

public static Mono<SubdocMutateResponse> mutateIn(Core core,
 CollectionIdentifier collectionIdentifier,
 String id,
 Duration timeout,
 boolean insertDocument,
 boolean upsertDocument,
 boolean reviveDocument,
 boolean accessDeleted,
 boolean createAsDeleted,
 long cas,
 int userFlags,
 Optional<DurabilityLevel> durabilityLevel,
 Map<String,Object> clientContext,
 SpanWrapper span,
 List<SubdocMutateRequest.Command> commands)

mutateIn

public static Mono<SubdocMutateResponse> mutateIn(Core core,
 CollectionIdentifier collectionIdentifier,
 String id,
 Duration timeout,
 boolean insertDocument,
 boolean upsertDocument,
 boolean reviveDocument,
 boolean accessDeleted,
 boolean createAsDeleted,
 long cas,
 int userFlags,
 Optional<DurabilityLevel> durabilityLevel,
 Map<String,Object> clientContext,
 SpanWrapper pspan,
 List<SubdocMutateRequest.Command> commands,
 CoreTransactionLogger logger)