Package com.couchbase.client.core.transaction.components

Class DocumentGetter

java.lang.Object

com.couchbase.client.core.transaction.components.DocumentGetter

@Internal
public class DocumentGetter
extends Object

Responsible for doing transaction-aware get()s.

Method Summary

Modifier and Type	Method	Description
static reactor.core.publisher.Mono<Optional<CoreTransactionGetResult>>	getAsync(Core core, CoreTransactionLogger LOGGER, CollectionIdentifier collection, CoreMergedTransactionConfig config, String docId, String byAttemptId, boolean justReturn, SpanWrapper span, Optional<String> resolvingMissingATREntry, MeteringUnits.MeteringUnitsBuilder units, CoreTransactionsSupportedExtensions supported, boolean preferredReplicaMode)
static reactor.core.publisher.Mono<Optional<reactor.util.function.Tuple2<CoreTransactionGetResult,CoreSubdocGetResult>>>	justGetDoc(Core core, CollectionIdentifier collection, String docId, Duration timeout, SpanWrapper span, boolean accessDeleted, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units, boolean preferredReplicaMode)
static reactor.core.publisher.Mono<Optional<CoreTransactionGetResult>>	lookupStatusFromATR(Core core, CollectionIdentifier collection, CoreTransactionGetResult doc, String byAttemptId, CoreMergedTransactionConfig config, SpanWrapper span, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units, CoreTransactionsSupportedExtensions supported)

Methods inherited from class java.lang.Object

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

Method Details

getAsync

public static reactor.core.publisher.Mono<Optional<CoreTransactionGetResult>> getAsync(Core core,
 CoreTransactionLogger LOGGER,
 CollectionIdentifier collection,
 CoreMergedTransactionConfig config,
 String docId,
 String byAttemptId,
 boolean justReturn,
 @Nullable
 SpanWrapper span,
 Optional<String> resolvingMissingATREntry,
 MeteringUnits.MeteringUnitsBuilder units,
 CoreTransactionsSupportedExtensions supported,
 boolean preferredReplicaMode)

justGetDoc

public static reactor.core.publisher.Mono<Optional<reactor.util.function.Tuple2<CoreTransactionGetResult,CoreSubdocGetResult>>> justGetDoc(Core core,
 CollectionIdentifier collection,
 String docId,
 Duration timeout,
 @Nullable
 SpanWrapper span,
 boolean accessDeleted,
 CoreTransactionLogger logger,
 MeteringUnits.MeteringUnitsBuilder units,
 boolean preferredReplicaMode)

lookupStatusFromATR

public static reactor.core.publisher.Mono<Optional<CoreTransactionGetResult>> lookupStatusFromATR(Core core,
 CollectionIdentifier collection,
 CoreTransactionGetResult doc,
 String byAttemptId,
 CoreMergedTransactionConfig config,
 SpanWrapper span,
 @Nullable
 CoreTransactionLogger logger,
 MeteringUnits.MeteringUnitsBuilder units,
 CoreTransactionsSupportedExtensions supported)