Uses of Class
com.couchbase.client.core.transaction.CoreTransactionAttemptContext

Packages that use CoreTransactionAttemptContext

Package	Description
com.couchbase.client.core.error.transaction
com.couchbase.client.core.transaction
com.couchbase.client.core.transaction.support
com.couchbase.client.core.transaction.threadlocal
com.couchbase.client.core.transaction.util

Uses of CoreTransactionAttemptContext in com.couchbase.client.core.error.transaction

Methods in com.couchbase.client.core.error.transaction with parameters of type CoreTransactionAttemptContext

Modifier and Type	Method	Description
static DocumentAlreadyInTransactionException	DocumentAlreadyInTransactionException.create(CoreTransactionAttemptContext ctx, CoreTransactionGetResult doc)

Uses of CoreTransactionAttemptContext in com.couchbase.client.core.transaction

Methods in com.couchbase.client.core.transaction that return CoreTransactionAttemptContext

Modifier and Type	Method	Description
CoreTransactionAttemptContext	CoreTransactionsReactive.createAttemptContext(CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId)

Methods in com.couchbase.client.core.transaction with parameters of type CoreTransactionAttemptContext

Modifier and Type	Method	Description
static TransactionOperationFailedException	AccessorUtil.operationFailed(CoreTransactionAttemptContext ctx, TransactionOperationFailedException err)
protected String	CoreTransactionAttemptContext.randomAtrIdForVbucket(CoreTransactionAttemptContext self, Integer vbucketIdForDoc, int numAtrs)

Method parameters in com.couchbase.client.core.transaction with type arguments of type CoreTransactionAttemptContext

Modifier and Type	Method	Description
reactor.core.publisher.Mono<CoreTransactionResult>	CoreTransactionsReactive.executeTransaction(reactor.core.publisher.Mono<CoreTransactionAttemptContext> createAttempt, CoreMergedTransactionConfig config, CoreTransactionContext overall, Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Void>> transactionLogic, boolean singleQueryTransactionMode)	The main transactions 'engine', responsible for attempting the transaction logic as many times as required, until the transaction commits, is explicitly rolled back, or expires.
reactor.core.publisher.Mono<CoreTransactionResult>	CoreTransactionsReactive.executeTransaction(reactor.core.publisher.Mono<CoreTransactionAttemptContext> createAttempt, CoreMergedTransactionConfig config, CoreTransactionContext overall, Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Void>> transactionLogic, boolean singleQueryTransactionMode)	The main transactions 'engine', responsible for attempting the transaction logic as many times as required, until the transaction commits, is explicitly rolled back, or expires.
reactor.core.publisher.Mono<CoreTransactionResult>	CoreTransactionsReactive.run(Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<?>> transactionLogic, CoreTransactionOptions perConfig)	Runs the supplied transactional logic until success or failure.

Uses of CoreTransactionAttemptContext in com.couchbase.client.core.transaction.support

Methods in com.couchbase.client.core.transaction.support that return CoreTransactionAttemptContext

Modifier and Type	Method	Description
CoreTransactionAttemptContext	TransactionAttemptContextFactory.create(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan)

Methods in com.couchbase.client.core.transaction.support with parameters of type CoreTransactionAttemptContext

Modifier and Type	Method	Description
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)

Uses of CoreTransactionAttemptContext in com.couchbase.client.core.transaction.threadlocal

Methods in com.couchbase.client.core.transaction.threadlocal that return CoreTransactionAttemptContext

Modifier and Type	Method	Description
CoreTransactionAttemptContext	TransactionMarker.context()

Constructors in com.couchbase.client.core.transaction.threadlocal with parameters of type CoreTransactionAttemptContext

Modifier	Constructor	Description
	TransactionMarker(CoreTransactionAttemptContext context)

Uses of CoreTransactionAttemptContext in com.couchbase.client.core.transaction.util

Fields in com.couchbase.client.core.transaction.util with type parameters of type CoreTransactionAttemptContext

Modifier and Type	Field	Description
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterAtrAborted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterAtrCommit
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterAtrComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterAtrPending
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterAtrRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocCommitted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocCommittedBeforeSavingCAS
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocRemovedPostRetry
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocRemovedPreRetry
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocsCommitted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterDocsRemoved
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterGetComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterRemoveStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterRollbackDeleteInserted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterRollbackReplaceOrRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterStagedInsertComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterStagedRemoveComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.afterStagedReplaceComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrAborted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrCommit
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrCommitAmbiguityResolution
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrPending
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeAtrRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeCheckATREntryForBlockingDoc
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocChangedDuringCommit
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocChangedDuringRollback
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocChangedDuringStaging
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocCommitted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocGet
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocRemoved
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeDocRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeGetDocInExistsDuringStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeOverwritingStagedInsertRemoval
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeRemoveStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeRollbackDeleteInserted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeStagedRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeStagedReplace
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeUnlockGet
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeUnlockInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeUnlockQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeUnlockRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	CoreTransactionAttemptContextHooks.beforeUnlockReplace
TriFunction<CoreTransactionAttemptContext,String,Optional<String>,Boolean>	CoreTransactionAttemptContextHooks.hasExpiredClientSideHook
Function<CoreTransactionAttemptContext,Optional<String>>	CoreTransactionAttemptContextHooks.randomAtrIdForVbucket

Methods in com.couchbase.client.core.transaction.util that return CoreTransactionAttemptContext

Modifier and Type	Method	Description
CoreTransactionAttemptContext	TestTransactionAttemptContextFactory.create(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan)

Constructors in com.couchbase.client.core.transaction.util with parameters of type CoreTransactionAttemptContext

Modifier	Constructor	Description
	ReactiveLock(CoreTransactionAttemptContext ctx, boolean debugMode)
	ReactiveWaitGroup(CoreTransactionAttemptContext ctx, boolean debugMode)