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

Class CoreTransactionsCleanup

java.lang.Object

com.couchbase.client.core.transaction.cleanup.CoreTransactionsCleanup

@Internal
public class CoreTransactionsCleanup
extends Object

Owns cleanup threads.

Author:

Graham Pople

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CATEGORY
static final String	CATEGORY_CLIENT_RECORD
static final String	CATEGORY_STATS
static final String	LOST_CATEGORY
static final String	REGULAR_CATEGORY

Constructor Summary

Constructors

Constructor	Description
CoreTransactionsCleanup(Core core, CoreTransactionsConfig config)

Method Summary

Modifier and Type	Method	Description
void	add(CleanupRequest cleanupRequest)
void	addToCleanupSet(CollectionIdentifier coll)
Optional<Integer>	cleanupQueueLength()
Set<CollectionIdentifier>	cleanupSet()
TransactionsCleaner	getCleaner()
reactor.core.publisher.Mono<Void>	shutdown(Duration timeout)

Methods inherited from class java.lang.Object

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

Field Details

CATEGORY

public static final String CATEGORY

See Also:

• Constant Field Values

CATEGORY_STATS

public static final String CATEGORY_STATS

See Also:

• Constant Field Values

CATEGORY_CLIENT_RECORD

public static final String CATEGORY_CLIENT_RECORD

See Also:

• Constant Field Values

LOST_CATEGORY

public static final String LOST_CATEGORY

See Also:

• Constant Field Values

REGULAR_CATEGORY

public static final String REGULAR_CATEGORY

See Also:

• Constant Field Values

Constructor Details

CoreTransactionsCleanup

public CoreTransactionsCleanup(Core core,
 CoreTransactionsConfig config)

Method Details

addToCleanupSet

public void addToCleanupSet(CollectionIdentifier coll)

cleanupSet

public Set<CollectionIdentifier> cleanupSet()

getCleaner

public TransactionsCleaner getCleaner()

cleanupQueueLength

public Optional<Integer> cleanupQueueLength()

add

public void add(CleanupRequest cleanupRequest)

shutdown

public reactor.core.publisher.Mono<Void> shutdown(Duration timeout)