Package com.couchbase.transactions.cleanup

Class TransactionsCleanup

java.lang.Object

com.couchbase.transactions.cleanup.TransactionsCleanup

@Internal
public class TransactionsCleanup
extends java.lang.Object

Owns cleanup threads.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CATEGORY
static java.lang.String	CATEGORY_CLIENT_RECORD
static java.lang.String	CATEGORY_STATS
static java.lang.String	LOST_CATEGORY
static java.lang.String	REGULAR_CATEGORY

Constructor Summary

Constructors

Constructor	Description
TransactionsCleanup(MergedTransactionConfig config, ClusterData clusterData)

Method Summary

Modifier and Type	Method	Description
void	add(CleanupRequest cleanupRequest)
int	cleanupQueueLength()
void	clearCleanupQueue()
ClusterData	clusterData()
reactor.core.publisher.Mono<java.lang.Void>	forceATRCleanup(com.couchbase.client.java.ReactiveCollection atrCollection, java.lang.String atrId)	Called only from tests.
java.util.List<TransactionCleanupAttempt>	forceCleanupQueueEmpty()
Cleaner	getCleaner()
LostCleanupDistributed	lostCleanup()
void	stopBackgroundProcesses()

Methods inherited from class java.lang.Object

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

Field Detail

CATEGORY

public static java.lang.String CATEGORY

CATEGORY_STATS

public static java.lang.String CATEGORY_STATS

CATEGORY_CLIENT_RECORD

public static java.lang.String CATEGORY_CLIENT_RECORD

LOST_CATEGORY

public static java.lang.String LOST_CATEGORY

REGULAR_CATEGORY

public static java.lang.String REGULAR_CATEGORY

Constructor Detail

TransactionsCleanup

public TransactionsCleanup(MergedTransactionConfig config,
                           ClusterData clusterData)

Method Detail

clusterData

public ClusterData clusterData()

forceCleanupQueueEmpty

public java.util.List<TransactionCleanupAttempt> forceCleanupQueueEmpty()

stopBackgroundProcesses

public void stopBackgroundProcesses()

lostCleanup

public LostCleanupDistributed lostCleanup()

getCleaner

public Cleaner getCleaner()

clearCleanupQueue

public void clearCleanupQueue()

cleanupQueueLength

public int cleanupQueueLength()

add

public void add(CleanupRequest cleanupRequest)

forceATRCleanup

public reactor.core.publisher.Mono<java.lang.Void> forceATRCleanup(com.couchbase.client.java.ReactiveCollection atrCollection,
                                                                   java.lang.String atrId)

Called only from tests.