Class 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)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 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)