Package com.couchbase.client.core.transaction

Class CoreTransactionContext

java.lang.Object

com.couchbase.client.core.transaction.CoreTransactionContext

@Internal
public class CoreTransactionContext
extends Object

Stores some context related to a transaction.

This is an immutable value class.

Field Summary

Fields

Modifier and Type	Field	Description
final CoreTransactionLogger	LOGGER

Constructor Summary

Constructors

Constructor	Description
CoreTransactionContext(CoreContext coreContext, String transactionId, CoreMergedTransactionConfig config, CoreTransactionsCleanup cleanup)

Method Summary

Modifier and Type	Method	Description
CoreTransactionsCleanup	cleanup()
Duration	expirationTime()
void	finish(Throwable err)
boolean	hasExpiredClientSide()
void	incAttempts()
void	incrementRetryAttempts(Duration lastRetryDuration, RetryReason reason)
int	numAttempts()
SpanWrapper	span()
long	startTimeClient()
CoreTransactionsSupportedExtensions	supported()
long	timeSinceStartOfTransactionsMillis(long now)
String	transactionId()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

public final CoreTransactionLogger LOGGER

Constructor Details

CoreTransactionContext

public CoreTransactionContext(CoreContext coreContext,
 String transactionId,
 CoreMergedTransactionConfig config,
 CoreTransactionsCleanup cleanup)

Method Details

expirationTime

public Duration expirationTime()

timeSinceStartOfTransactionsMillis

public long timeSinceStartOfTransactionsMillis(long now)

hasExpiredClientSide

public boolean hasExpiredClientSide()

transactionId

public String transactionId()

startTimeClient

public long startTimeClient()

span

public SpanWrapper span()

numAttempts

public int numAttempts()

incAttempts

public void incAttempts()

cleanup

public CoreTransactionsCleanup cleanup()

incrementRetryAttempts

public void incrementRetryAttempts(Duration lastRetryDuration,
 RetryReason reason)

finish

public void finish(@Nullable
 Throwable err)

supported

public CoreTransactionsSupportedExtensions supported()