com.atlassian.confluence.impl.search

Class IndexFlushScheduler

java.lang.Object

com.atlassian.confluence.impl.search.IndexFlushScheduler

public class IndexFlushScheduler
extends Object

Each time a flush is requested, this class will schedule a job to flush the index queue in 5 seconds, unless a flush has already been scheduled.

Since:

5.10

Constructor Summary

Constructors

Constructor and Description
IndexFlushScheduler(com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar, com.atlassian.scheduler.SchedulerService schedulerService, String jobRunnerKeyAndId, com.atlassian.scheduler.config.RunMode runMode, long journalIgnoreWithinMillis, IndexManager indexManager)
IndexFlushScheduler(com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar, com.atlassian.scheduler.SchedulerService schedulerService, String jobRunnerKeyAndId, com.atlassian.scheduler.config.RunMode runMode, long journalIgnoreWithinMillis, IndexManager indexManager, BooleanSupplier indexFlushEnabledSupplier) JobRunnerKey and JobId use same value.

Method Summary

Modifier and Type	Method and Description
void	destroy()
Instant	getFirstRunTime()
void	init()
void	requestFlush(ClusterEventWrapper wrapper)
void	requestFlush(DefaultIndexFlushRequester.RequestIndexFlushEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexFlushScheduler

public IndexFlushScheduler(com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar,
                           com.atlassian.scheduler.SchedulerService schedulerService,
                           String jobRunnerKeyAndId,
                           com.atlassian.scheduler.config.RunMode runMode,
                           long journalIgnoreWithinMillis,
                           IndexManager indexManager)

IndexFlushScheduler

public IndexFlushScheduler(com.atlassian.event.api.EventListenerRegistrar eventListenerRegistrar,
                           com.atlassian.scheduler.SchedulerService schedulerService,
                           String jobRunnerKeyAndId,
                           com.atlassian.scheduler.config.RunMode runMode,
                           long journalIgnoreWithinMillis,
                           IndexManager indexManager,
                           BooleanSupplier indexFlushEnabledSupplier)

JobRunnerKey and JobId use same value. JobId must be the same at each schedule for runMode RUN_ONCE_PER_CLUSTER to work.

Parameters:

journalIgnoreWithinMillis - Entries added to journal within the last given milliseconds are ignored.

indexFlushEnabledSupplier - Nullable; for optimisation, if non-null and returns false, nothing will happen when DefaultIndexFlushRequester.RequestIndexFlushEvent arrives

Method Detail

init

@PostConstruct
public void init()

destroy

@PreDestroy
public void destroy()

requestFlush

@EventListener
public void requestFlush(DefaultIndexFlushRequester.RequestIndexFlushEvent event)

requestFlush

@EventListener
public void requestFlush(ClusterEventWrapper wrapper)

getFirstRunTime

public Instant getFirstRunTime()