Class DocumentGetter
- java.lang.Object
-
- com.couchbase.transactions.components.DocumentGetter
-
@Internal public class DocumentGetter extends java.lang.Object
Responsible for doing transaction-aware get()s.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>>
getAsync(com.couchbase.client.java.Cluster cluster, com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, java.lang.String byAttemptId, SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder)
static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>>
getAsync(com.couchbase.client.java.Cluster cluster, TransactionLogger LOGGER, com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, java.lang.String byAttemptId, boolean justReturn, SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder, java.util.Optional<java.lang.String> resolvingMissingATREntry)
static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>>
justGetDoc(com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder)
static reactor.core.publisher.Mono<java.util.Optional<reactor.util.function.Tuple2<TransactionGetResult,com.couchbase.client.java.kv.LookupInResult>>>
justGetDoc(com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder, boolean accessDeleted, TransactionLogger logger)
-
-
-
Method Detail
-
getAsync
public static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>> getAsync(com.couchbase.client.java.Cluster cluster, com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, java.lang.String byAttemptId, @Nullable SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder)
-
getAsync
public static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>> getAsync(com.couchbase.client.java.Cluster cluster, TransactionLogger LOGGER, com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, java.lang.String byAttemptId, boolean justReturn, @Nullable SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder, java.util.Optional<java.lang.String> resolvingMissingATREntry)
-
justGetDoc
public static reactor.core.publisher.Mono<java.util.Optional<TransactionGetResult>> justGetDoc(com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder)
-
justGetDoc
public static reactor.core.publisher.Mono<java.util.Optional<reactor.util.function.Tuple2<TransactionGetResult,com.couchbase.client.java.kv.LookupInResult>>> justGetDoc(com.couchbase.client.java.ReactiveCollection collection, MergedTransactionConfig config, java.lang.String docId, @Nullable SpanWrapper span, com.couchbase.client.java.codec.Transcoder transcoder, boolean accessDeleted, @Nullable TransactionLogger logger)
-
-