Uses of Class
com.couchbase.client.core.transaction.support.SpanWrapper
Package
Description
-
Uses of SpanWrapper in com.couchbase.client.core.transaction
Modifier and TypeMethodDescription<T> Mono<T>
CoreTransactionAttemptContext.doQueryOperation
(String lockDebugIn, String statement, SpanWrapper pspan, TriFunction<Integer, AtomicReference<ReactiveLock.Waiter>, SpanWrapper, Mono<T>> op) Doesn't need everything from doKVOperation, as queryWrapper already centralises a lot of logicCoreTransactionAttemptContext.insert
(CollectionIdentifier collection, String id, byte[] content, SpanWrapper pspan) Inserts a new document into the specified Couchbasecollection
.CoreTransactionAttemptContext.queryWrapperLocked
(int sidx, CoreQueryContext qc, String statement, CoreQueryOptions options, String hookPoint, boolean isBeginWork, boolean existingErrorCheck, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode txdata, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ArrayNode params, SpanWrapper span, boolean tximplicit, AtomicReference<ReactiveLock.Waiter> lockToken, boolean updateInternalState) This will return a TransactionOperationFailedException if that's what query returns, else will return the error after passing through convertQueryError.CoreTransactionAttemptContext.remove
(CoreTransactionGetResult doc, SpanWrapper pspan) Removes the specifieddoc
, using the document's lastCoreTransactionGetResult.cas()
.CoreTransactionAttemptContext.replace
(CoreTransactionGetResult doc, byte[] content, SpanWrapper pspan) Mutates the specifieddoc
with new content, using the document's lastCoreTransactionGetResult.cas()
.Modifier and TypeMethodDescription<T> Mono<T>
CoreTransactionAttemptContext.doQueryOperation
(String lockDebugIn, String statement, SpanWrapper pspan, TriFunction<Integer, AtomicReference<ReactiveLock.Waiter>, SpanWrapper, Mono<T>> op) Doesn't need everything from doKVOperation, as queryWrapper already centralises a lot of logicModifierConstructorDescriptionCoreTransactionAttemptContext
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan, CoreTransactionAttemptContextHooks hooks) -
Uses of SpanWrapper in com.couchbase.client.core.transaction.cleanup
Modifier and TypeMethodDescriptionClientRecord.getClientRecord
(CollectionIdentifier collection, SpanWrapper span) LostCleanupDistributed.handleATRCleanup
(String bp, CollectionIdentifier atrCollection, String atrId, ActiveTransactionRecordStats stats, Duration safetyMargin, SpanWrapper pspan) Looks at an ATR, finds any expired entries, and cleans them up.TransactionsCleaner.performCleanup
(CleanupRequest req, boolean isRegularCleanup, SpanWrapper pspan) ClientRecord.processClient
(String clientUuid, CollectionIdentifier collection, CoreTransactionsConfig config, SpanWrapper pspan) -
Uses of SpanWrapper in com.couchbase.client.core.transaction.components
Modifier and TypeMethodDescriptionstatic Mono<Optional<ActiveTransactionRecordEntry>>
ActiveTransactionRecord.findEntryForTransaction
(Core core, CollectionIdentifier atrCollection, String atrId, String attemptId, CoreMergedTransactionConfig config, SpanWrapper pspan, CoreTransactionLogger logger) static Mono<Optional<ActiveTransactionRecordEntry>>
ActiveTransactionRecord.findEntryForTransaction
(Core core, CollectionIdentifier atrCollection, String atrId, String attemptId, CoreMergedTransactionConfig config, SpanWrapper pspan, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units) static Mono<Optional<CoreTransactionGetResult>>
DocumentGetter.getAsync
(Core core, CoreTransactionLogger LOGGER, CollectionIdentifier collection, CoreMergedTransactionConfig config, String docId, String byAttemptId, boolean justReturn, SpanWrapper span, Optional<String> resolvingMissingATREntry, MeteringUnits.MeteringUnitsBuilder units) static Mono<Optional<ActiveTransactionRecords>>
ActiveTransactionRecord.getAtr
(Core core, CollectionIdentifier atrCollection, String atrId, Duration timeout, SpanWrapper pspan) TXNJ-13: Get the ATR.DocumentGetter.justGetDoc
(Core core, CollectionIdentifier collection, String docId, Duration timeout, SpanWrapper span, boolean accessDeleted, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units) -
Uses of SpanWrapper in com.couchbase.client.core.transaction.support
Modifier and TypeMethodDescription<T> SpanWrapper
static SpanWrapper
SpanWrapper.create
(RequestTracer tracer, String op, SpanWrapper parent) static SpanWrapper
SpanWrapperUtil.createOp
(CoreTransactionAttemptContext ctx, RequestTracer tracer, CollectionIdentifier collection, String id, String op, SpanWrapper attemptSpan) <T> SpanWrapper
SpanWrapper.lowCardinalityAttribute
(String key, T value) static SpanWrapper
SpanWrapperUtil.setAttributes
(SpanWrapper out, CoreTransactionAttemptContext ctx, CollectionIdentifier collection, String id) Modifier and TypeMethodDescriptionstatic SpanWrapper
SpanWrapper.create
(RequestTracer tracer, String op, SpanWrapper parent) static SpanWrapper
SpanWrapperUtil.createOp
(CoreTransactionAttemptContext ctx, RequestTracer tracer, CollectionIdentifier collection, String id, String op, SpanWrapper attemptSpan) static SpanWrapper
SpanWrapperUtil.setAttributes
(SpanWrapper out, CoreTransactionAttemptContext ctx, CollectionIdentifier collection, String id) Modifier and TypeMethodDescriptionTransactionAttemptContextFactory.create
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan) -
Uses of SpanWrapper in com.couchbase.client.core.transaction.util
Modifier and TypeMethodDescriptionstatic Mono<InsertResponse>
TransactionKVHandler.insert
(Core core, CollectionIdentifier collectionIdentifier, String id, byte[] transcodedContent, Duration timeout, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan) static Mono<SubdocGetResponse>
TransactionKVHandler.lookupIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean accessDeleted, Map<String, Object> clientContext, SpanWrapper pspan, List<SubdocGetRequest.Command> commands) static Mono<SubdocMutateResponse>
TransactionKVHandler.mutateIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper span, List<SubdocMutateRequest.Command> commands) static Mono<SubdocMutateResponse>
TransactionKVHandler.mutateIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan, List<SubdocMutateRequest.Command> commands, CoreTransactionLogger logger) static Mono<RemoveResponse>
TransactionKVHandler.remove
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan) Modifier and TypeMethodDescriptionTestTransactionAttemptContextFactory.create
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan)