Package com.couchbase.client.core.transaction.cleanup

Class CleanupRequest

java.lang.Object

com.couchbase.client.core.transaction.cleanup.CleanupRequest

All Implemented Interfaces:

Comparable<Delayed>, Delayed

@Internal
public class CleanupRequest
extends Object
implements Delayed

Constructor Summary

Constructors

Constructor	Description
CleanupRequest(String attemptId, String atrId, CollectionIdentifier atrCollection, AttemptState state, List<DocRecord> stagedReplaces, List<DocRecord> stagedRemoves, List<DocRecord> stagedInserts, Duration delay, Optional<ForwardCompatibility> forwardCompatibility, long ageMillis, Optional<DurabilityLevel> durabilityLevel)

Method Summary

Modifier and Type	Method	Description
long	ageMillis()
CollectionIdentifier	atrCollection()
String	atrId()
String	attemptId()
int	compareTo(Delayed o)
long	createdAt()
Optional<DurabilityLevel>	durabilityLevel()
Optional<ForwardCompatibility>	forwardCompatibility()
static CleanupRequest	fromAtrEntry(CollectionIdentifier atrCollection, ActiveTransactionRecordEntry atrEntry)
long	getDelay(TimeUnit unit)
List<DocRecord>	stagedInserts()
List<DocRecord>	stagedRemoves()
List<DocRecord>	stagedReplaces()
AttemptState	state()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

CleanupRequest

public CleanupRequest(String attemptId,
 String atrId,
 CollectionIdentifier atrCollection,
 AttemptState state,
 List<DocRecord> stagedReplaces,
 List<DocRecord> stagedRemoves,
 List<DocRecord> stagedInserts,
 Duration delay,
 Optional<ForwardCompatibility> forwardCompatibility,
 long ageMillis,
 Optional<DurabilityLevel> durabilityLevel)

Parameters:

attemptId - Of the attempt making this request

atrId - The ATR document's ID

delay - When this request will be handled

Method Details

fromAtrEntry

public static CleanupRequest fromAtrEntry(CollectionIdentifier atrCollection,
 ActiveTransactionRecordEntry atrEntry)

createdAt

public long createdAt()

attemptId

public String attemptId()

atrId

public String atrId()

atrCollection

public CollectionIdentifier atrCollection()

stagedReplaces

public List<DocRecord> stagedReplaces()

stagedRemoves

public List<DocRecord> stagedRemoves()

stagedInserts

public List<DocRecord> stagedInserts()

state

public AttemptState state()

forwardCompatibility

public Optional<ForwardCompatibility> forwardCompatibility()

durabilityLevel

public Optional<DurabilityLevel> durabilityLevel()

ageMillis

public long ageMillis()

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<Delayed>

toString

public String toString()

Overrides:

toString in class Object