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

Class TransactionsCleaner

java.lang.Object

com.couchbase.client.core.transaction.cleanup.TransactionsCleaner

@Internal
public class TransactionsCleaner
extends Object

Handles cleaning up expired/lost transactions.

Author:

Graham Pople

Constructor Summary

Constructors

Constructor	Description
TransactionsCleaner(Core core, CleanerHooks hooks, CoreTransactionsSupportedExtensions supported)

Method Summary

Modifier and Type	Method	Description
Mono<TransactionCleanupAttemptEvent>	cleanupATREntry(CollectionIdentifier atrCollection, String atrId, String attemptId, ActiveTransactionRecordEntry atrEntry, boolean isRegularCleanup)	Kept purely for backwards compatibility with FIT performer.
CleanerHooks	hooks()
Mono<TransactionCleanupAttemptEvent>	performCleanup(CleanupRequest req, boolean isRegularCleanup, SpanWrapper pspan)

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionsCleaner

public TransactionsCleaner(Core core,
 CleanerHooks hooks,
 CoreTransactionsSupportedExtensions supported)

Method Details

cleanupATREntry

public Mono<TransactionCleanupAttemptEvent> cleanupATREntry(CollectionIdentifier atrCollection,
 String atrId,
 String attemptId,
 ActiveTransactionRecordEntry atrEntry,
 boolean isRegularCleanup)

Kept purely for backwards compatibility with FIT performer.

performCleanup

public Mono<TransactionCleanupAttemptEvent> performCleanup(CleanupRequest req,
 boolean isRegularCleanup,
 @Nullable
 SpanWrapper pspan)

hooks

public CleanerHooks hooks()