Class ReindexActiveAliasResolverImpl

java.lang.Object

com.flowable.indexing.reindex.dualwrite.ReindexActiveAliasResolverImpl

All Implemented Interfaces:

ReindexActiveAliasResolver

public class ReindexActiveAliasResolverImpl
extends Object
implements ReindexActiveAliasResolver

Caches the dual-write target per alias with a TTL. A reindex start/end is picked up within the TTL; the propagation gate (activeAliasCacheTtl + propagationGrace) waits out that window before backfilling, so no live write is missed.

Constructor Summary

Constructors

Constructor	Description
ReindexActiveAliasResolverImpl(Function<String,String> propertyReader, Duration ttl, LongSupplier clock, String indexNamePrefix)

Method Summary

Modifier and Type	Method	Description
String	getCurrentReindexingTargetForAlias(String fullAlias)

Methods inherited from class Object

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

Constructor Details

ReindexActiveAliasResolverImpl

public ReindexActiveAliasResolverImpl(Function<String,String> propertyReader,
 Duration ttl,
 LongSupplier clock,
 String indexNamePrefix)

Method Details

getCurrentReindexingTargetForAlias

public String getCurrentReindexingTargetForAlias(String fullAlias)

Specified by:

getCurrentReindexingTargetForAlias in interface ReindexActiveAliasResolver