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
reactor.core.publisher.Mono<TransactionCleanupAttemptEvent>	cleanupATREntry(CollectionIdentifier atrCollection, String atrId, String attemptId, ActiveTransactionRecordEntry atrEntry, boolean isRegularCleanup)	Kept purely for backwards compatibility with FIT performer.
CleanerHooks	hooks()
reactor.core.publisher.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 reactor.core.publisher.Mono<TransactionCleanupAttemptEvent> cleanupATREntry(CollectionIdentifier atrCollection,
 String atrId,
 String attemptId,
 ActiveTransactionRecordEntry atrEntry,
 boolean isRegularCleanup)

Kept purely for backwards compatibility with FIT performer.

performCleanup

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

hooks

public CleanerHooks hooks()