Package com.couchbase.transactions.components

Class ATREntry

java.lang.Object

com.couchbase.transactions.components.ATREntry

@Internal
public class ATREntry
extends java.lang.Object

Constructor Summary

Constructors

Constructor

Description

ATREntry(java.lang.String atrBucket, java.lang.String atrId, java.lang.String attemptId, java.util.Optional<java.lang.String> transactionId, AttemptStates state, java.util.Optional<java.lang.Long> timestampStartMsecs, java.util.Optional<java.lang.Long> timestampCommitMsecs, java.util.Optional<java.lang.Long> timestampCompleteMsecs, java.util.Optional<java.lang.Long> timestampRollBackMsecs, java.util.Optional<java.lang.Long> timestampRolledBackMsecs, java.util.Optional<java.lang.Integer> expiresAfterMsecs, java.util.Optional<java.util.List<DocRecord>> insertedIds, java.util.Optional<java.util.List<DocRecord>> replacedIds, java.util.Optional<java.util.List<DocRecord>> removedIds, long cas, java.util.Optional<ForwardCompatibility> forwardCompatibility, java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel> durabilityLevel)

Method Summary

Modifier and Type	Method	Description
long	ageMsecs()
java.lang.String	atrId()
java.lang.String	attemptId()
long	cas()	Returns the CAS of the ATR documenting containing this entry
java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel>	durabilityLevel()
java.util.Optional<java.lang.Integer>	expiresAfterMsecs()
java.util.Optional<ForwardCompatibility>	forwardCompatibility()
boolean	hasExpired()
boolean	hasExpired(long safetyMarginMillis)
boolean	hasExpired(long cas, long txnExpiresAfterMsecs)
java.util.Optional<java.util.List<DocRecord>>	insertedIds()
java.util.Optional<java.util.List<DocRecord>>	removedIds()
java.util.Optional<java.util.List<DocRecord>>	replacedIds()
AttemptStates	state()
java.util.Optional<java.lang.Long>	timestampCommitMsecs()
java.util.Optional<java.lang.Long>	timestampCompleteMsecs()
java.util.Optional<java.lang.Long>	timestampRollBackMsecs()
java.util.Optional<java.lang.Long>	timestampRolledBackMsecs()
java.util.Optional<java.lang.Long>	timestampStartMsecs()
java.lang.String	toString()
java.util.Optional<java.lang.String>	transactionId()	This was added with {ExtTransactionId}

Methods inherited from class java.lang.Object

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

Constructor Detail

ATREntry

public ATREntry(java.lang.String atrBucket,
                java.lang.String atrId,
                java.lang.String attemptId,
                java.util.Optional<java.lang.String> transactionId,
                AttemptStates state,
                java.util.Optional<java.lang.Long> timestampStartMsecs,
                java.util.Optional<java.lang.Long> timestampCommitMsecs,
                java.util.Optional<java.lang.Long> timestampCompleteMsecs,
                java.util.Optional<java.lang.Long> timestampRollBackMsecs,
                java.util.Optional<java.lang.Long> timestampRolledBackMsecs,
                java.util.Optional<java.lang.Integer> expiresAfterMsecs,
                java.util.Optional<java.util.List<DocRecord>> insertedIds,
                java.util.Optional<java.util.List<DocRecord>> replacedIds,
                java.util.Optional<java.util.List<DocRecord>> removedIds,
                long cas,
                java.util.Optional<ForwardCompatibility> forwardCompatibility,
                java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel> durabilityLevel)

Method Detail

hasExpired

public boolean hasExpired()

hasExpired

public boolean hasExpired(long safetyMarginMillis)

hasExpired

public boolean hasExpired(long cas,
                          long txnExpiresAfterMsecs)

ageMsecs

public long ageMsecs()

atrId

public java.lang.String atrId()

attemptId

public java.lang.String attemptId()

transactionId

public java.util.Optional<java.lang.String> transactionId()

This was added with {ExtTransactionId}

state

public AttemptStates state()

timestampStartMsecs

public java.util.Optional<java.lang.Long> timestampStartMsecs()

timestampCommitMsecs

public java.util.Optional<java.lang.Long> timestampCommitMsecs()

timestampCompleteMsecs

public java.util.Optional<java.lang.Long> timestampCompleteMsecs()

timestampRollBackMsecs

public java.util.Optional<java.lang.Long> timestampRollBackMsecs()

timestampRolledBackMsecs

public java.util.Optional<java.lang.Long> timestampRolledBackMsecs()

cas

public long cas()

Returns the CAS of the ATR documenting containing this entry

insertedIds

public java.util.Optional<java.util.List<DocRecord>> insertedIds()

replacedIds

public java.util.Optional<java.util.List<DocRecord>> replacedIds()

removedIds

public java.util.Optional<java.util.List<DocRecord>> removedIds()

expiresAfterMsecs

public java.util.Optional<java.lang.Integer> expiresAfterMsecs()

forwardCompatibility

public java.util.Optional<ForwardCompatibility> forwardCompatibility()

durabilityLevel

public java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel> durabilityLevel()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object