Package com.couchbase.transactions.cleanup

Class CleanupRequest

java.lang.Object

com.couchbase.transactions.cleanup.CleanupRequest

All Implemented Interfaces:

java.lang.Comparable<java.util.concurrent.Delayed>, java.util.concurrent.Delayed

@Internal
public class CleanupRequest
extends java.lang.Object
implements java.util.concurrent.Delayed

Constructor Summary

Constructors

Constructor

Description

CleanupRequest(java.lang.String attemptId, java.lang.String atrId, com.couchbase.client.java.ReactiveCollection atrCollection, AttemptStates state, java.util.List<DocRecord> stagedReplaces, java.util.List<DocRecord> stagedRemoves, java.util.List<DocRecord> stagedInserts, java.time.Duration delay, java.util.Optional<ForwardCompatibility> forwardCompatibility, long ageMillis, java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel> durabilityLevel)

Method Summary

Modifier and Type	Method	Description
long	ageMillis()
com.couchbase.client.java.ReactiveCollection	atrCollection()
java.lang.String	atrId()
java.lang.String	attemptId()
int	compareTo(java.util.concurrent.Delayed o)
long	createdAt()
java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel>	durabilityLevel()
java.util.Optional<ForwardCompatibility>	forwardCompatibility()
static CleanupRequest	fromAtrEntry(com.couchbase.client.java.ReactiveCollection atrCollection, ATREntry atrEntry)
long	getDelay(java.util.concurrent.TimeUnit unit)
java.util.List<DocRecord>	stagedInserts()
java.util.List<DocRecord>	stagedRemoves()
java.util.List<DocRecord>	stagedReplaces()
AttemptStates	state()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CleanupRequest

public CleanupRequest(java.lang.String attemptId,
                      java.lang.String atrId,
                      com.couchbase.client.java.ReactiveCollection atrCollection,
                      AttemptStates state,
                      java.util.List<DocRecord> stagedReplaces,
                      java.util.List<DocRecord> stagedRemoves,
                      java.util.List<DocRecord> stagedInserts,
                      java.time.Duration delay,
                      java.util.Optional<ForwardCompatibility> forwardCompatibility,
                      long ageMillis,
                      java.util.Optional<com.couchbase.client.core.msg.kv.DurabilityLevel> durabilityLevel)

Parameters:

attemptId - Of the attempt making this request

atrId - The ATR document's ID

delay - When this request will be handled

Method Detail

fromAtrEntry

public static CleanupRequest fromAtrEntry(com.couchbase.client.java.ReactiveCollection atrCollection,
                                          ATREntry atrEntry)

createdAt

public long createdAt()

attemptId

public java.lang.String attemptId()

atrId

public java.lang.String atrId()

atrCollection

public com.couchbase.client.java.ReactiveCollection atrCollection()

stagedReplaces

public java.util.List<DocRecord> stagedReplaces()

stagedRemoves

public java.util.List<DocRecord> stagedRemoves()

stagedInserts

public java.util.List<DocRecord> stagedInserts()

state

public AttemptStates state()

forwardCompatibility

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

durabilityLevel

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

ageMillis

public long ageMillis()

getDelay

public long getDelay(java.util.concurrent.TimeUnit unit)

Specified by:

getDelay in interface java.util.concurrent.Delayed

compareTo

public int compareTo(java.util.concurrent.Delayed o)

Specified by:

compareTo in interface java.lang.Comparable<java.util.concurrent.Delayed>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object