Package com.couchbase.transactions.cleanup

Class CleanerMockCreatorFactory

java.lang.Object

com.couchbase.transactions.cleanup.CleanerFactory

com.couchbase.transactions.cleanup.CleanerMockCreatorFactory

@Internal
public class CleanerMockCreatorFactory
extends CleanerFactory

Used for testing/mocking. Creates a CleanerMock.

Field Summary

Fields

Modifier and Type	Field	Description
java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>>	beforeAtrGet
java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Integer>>	beforeAtrRemove
java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>>	beforeCommitDoc
java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>>	beforeRemoveDoc
java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>>	beforeRemoveLinks
reactor.core.publisher.Mono<java.lang.Integer>	standard
java.util.Optional<java.time.Duration>	timeBeforeRehandlingFailedCleanup

Constructor Summary

Constructors

Constructor	Description
CleanerMockCreatorFactory()

Method Summary

Modifier and Type	Method	Description
Cleaner	create(MergedTransactionConfig config, ClusterData clusterData)

Methods inherited from class com.couchbase.transactions.cleanup.CleanerFactory

create

Methods inherited from class java.lang.Object

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

Field Detail

standard

public reactor.core.publisher.Mono<java.lang.Integer> standard

beforeAtrGet

public java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>> beforeAtrGet

beforeCommitDoc

public java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>> beforeCommitDoc

beforeRemoveDoc

public java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>> beforeRemoveDoc

beforeRemoveLinks

public java.util.function.Function<java.lang.String,reactor.core.publisher.Mono<java.lang.Integer>> beforeRemoveLinks

beforeAtrRemove

public java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Integer>> beforeAtrRemove

timeBeforeRehandlingFailedCleanup

public java.util.Optional<java.time.Duration> timeBeforeRehandlingFailedCleanup

Constructor Detail

CleanerMockCreatorFactory

public CleanerMockCreatorFactory()

Method Detail

create

public Cleaner create(MergedTransactionConfig config,
                      ClusterData clusterData)

Overrides:

create in class CleanerFactory