Interface IndexStatsMBean
-
@ProviderType public interface IndexStatsMBean
-
-
Field Summary
Fields Modifier and Type Field Description static String
STATUS_DONE
static String
STATUS_FAILING
static String
STATUS_INIT
static String
STATUS_INTERRUPTED
static String
STATUS_RUNNING
static String
TYPE
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description String
abortAndPause()
String
forceIndexLaneCatchup(String confirmationMessage)
long
getConsecutiveFailedExecutions()
CompositeData
getConsolidatedExecutionStats()
Returns the consolidated execution stats since last resetString
getDone()
CompositeData
getExecutionCount()
Returns the number of executions as aorg.apache.jackrabbit.api.stats.TimeSeries
.CompositeData
getExecutionTime()
Deprecated.TabularData
getFailingIndexStats()
String
getFailingSince()
CompositeData
getIndexedNodesCount()
Returns the number of indexed nodes as aorg.apache.jackrabbit.api.stats.TimeSeries
.String
getLastIndexedTime()
String
getLatestError()
String
getLatestErrorTime()
String
getName()
Name of the async indexing lanelong
getNodesReadCount()
Returns the number of which have been read so far.String
getProcessedCheckpoint()
Returns the processed checkpoint used by the async indexer.String
getReferenceCheckpoint()
Returns the current reference checkpoint used by the async indexerString
getStart()
String
getStatus()
Returns the current status of the indexing jobString
getTemporaryCheckpoints()
Temporary checkpoints represent old checkpoints that have been processed but the cleanup was not successful of did not happen at all (like in the event the system was forcibly stopped).long
getTotalExecutionCount()
Returns the number of executions.long
getUpdates()
Returns the number of updates from the current run cycle.boolean
isFailing()
boolean
isPaused()
Returns the value of the 'paused' flagvoid
pause()
Pauses the background indexing process.void
registerAsyncIndexer(String name, long delayInSeconds)
Starts a new background indexing task and registers the JMX MBeans for itString
releaseLeaseForPausedLane()
void
resetConsolidatedExecutionStats()
Deprecated.void
resume()
Resumes the indexing process.void
splitIndexingTask(String paths, String newIndexTaskName)
Splits the current indexing tasks into 2, indexes that are passed in as an input will have their 'async' property updated tonewIndexTaskName
.
-
-
-
Field Detail
-
TYPE
static final String TYPE
- See Also:
- Constant Field Values
-
STATUS_INIT
static final String STATUS_INIT
- See Also:
- Constant Field Values
-
STATUS_RUNNING
static final String STATUS_RUNNING
- See Also:
- Constant Field Values
-
STATUS_DONE
static final String STATUS_DONE
- See Also:
- Constant Field Values
-
STATUS_FAILING
static final String STATUS_FAILING
- See Also:
- Constant Field Values
-
STATUS_INTERRUPTED
static final String STATUS_INTERRUPTED
- See Also:
- Constant Field Values
-
-
Method Detail
-
getName
String getName()
Name of the async indexing lane
-
getStart
String getStart()
- Returns:
- The time the indexing job stared at, or
""
if it is not currently running.
-
getDone
String getDone()
- Returns:
- The time the indexing job finished at, or
""
if it is still running.
-
getStatus
String getStatus()
Returns the current status of the indexing job
-
getLastIndexedTime
String getLastIndexedTime()
- Returns:
- the last upto which the repository was indexed
-
pause
void pause()
Pauses the background indexing process. Future changes are not indexed until theresume()
method is called. The pause call will take effect on the next run cycle and will affect all indexes marked as 'async'. Note: this is experimental and should only be used for debugging/diagnosis purposes!
-
abortAndPause
@Description("Aborts any running indexing cycle and pauses the indexer. Invoke \'resume\' once you are read to resume indexing again") String abortAndPause()
-
releaseLeaseForPausedLane
@Description("Release lease for a paused lane") String releaseLeaseForPausedLane()
-
resume
void resume()
Resumes the indexing process. All changes from the previous indexed state will be indexed.- See Also:
pause()
-
isPaused
boolean isPaused()
Returns the value of the 'paused' flag- Returns:
- true if the indexing job is paused
-
getUpdates
long getUpdates()
Returns the number of updates from the current run cycle. This value is kept until the next cycle begins.- Returns:
- the number of updates from the current run cycle. This value is kept until the next cycle begins.
-
getNodesReadCount
long getNodesReadCount()
Returns the number of which have been read so far. This value is kept until the next cycle begins.- Returns:
- the number of node read from the current run cycle. This value is kept until the next cycle begins.
-
getReferenceCheckpoint
String getReferenceCheckpoint()
Returns the current reference checkpoint used by the async indexer- Returns:
- the reference checkpoint
-
forceIndexLaneCatchup
@Description("Force update the indexing lane to a checkpoint created during execution of this function. This will abort and pause the running lane, release it\'s lease and set the reference checkpoint to a latest one.Any content changes between the old reference checkpoint and the new one will be not be indexed and a reindexing would be required.Only use this operation if you are sure that the lane is stuck and not updated since many days and cannot catch up on its own.Once this operation is completed, reindexing for all indexes on the lane is required.") String forceIndexLaneCatchup(@Name("Confirmation Message") @Description("Enter \'CONFIRM\' to confirm the operation") String confirmationMessage) throws CommitFailedException
- Throws:
CommitFailedException
-
getProcessedCheckpoint
String getProcessedCheckpoint()
Returns the processed checkpoint used by the async indexer. If this index round finishes successfully, the processed checkpoint will become the reference checkpoint, and the old reference checkpoint wil be released.- Returns:
- the processed checkpoint
-
getTemporaryCheckpoints
String getTemporaryCheckpoints()
Temporary checkpoints represent old checkpoints that have been processed but the cleanup was not successful of did not happen at all (like in the event the system was forcibly stopped).- Returns:
- the already processed checkpoints
-
getTotalExecutionCount
long getTotalExecutionCount()
Returns the number of executions.- Returns:
- the execution count
-
getExecutionCount
CompositeData getExecutionCount()
Returns the number of executions as aorg.apache.jackrabbit.api.stats.TimeSeries
.- Returns:
- the execution count time series
-
getExecutionTime
@Deprecated CompositeData getExecutionTime()
Deprecated.Returns the execution time as aorg.apache.jackrabbit.api.stats.TimeSeries
.- Returns:
- the execution times time series
-
getIndexedNodesCount
CompositeData getIndexedNodesCount()
Returns the number of indexed nodes as aorg.apache.jackrabbit.api.stats.TimeSeries
.- Returns:
- the indexed nodes time series
-
getConsolidatedExecutionStats
CompositeData getConsolidatedExecutionStats()
Returns the consolidated execution stats since last reset- Returns:
- consolidated execution stats
-
resetConsolidatedExecutionStats
@Deprecated void resetConsolidatedExecutionStats()
Deprecated.Resets the consolidated stats.
-
splitIndexingTask
void splitIndexingTask(@Name("paths") @Description("Comma separated list of paths of the index definitions") String paths, @Name("newIndexTaskName") @Description("The indexing task name set on the async property") String newIndexTaskName)
Splits the current indexing tasks into 2, indexes that are passed in as an input will have their 'async' property updated tonewIndexTaskName
. Note that this call will *not* bootstrap a new indexing task for the given name.
-
registerAsyncIndexer
void registerAsyncIndexer(@Name("name") String name, @Name("delayInSeconds") long delayInSeconds)
Starts a new background indexing task and registers the JMX MBeans for it
-
isFailing
boolean isFailing()
- Returns:
- true if the indexing job is failing
-
getFailingSince
String getFailingSince()
- Returns:
- The time the indexing job stared failing, or
""
if the job is not currently failing.
-
getConsecutiveFailedExecutions
long getConsecutiveFailedExecutions()
- Returns:
- the number of consecutive failed executions or
0
if the job is not currently failing.
-
getLatestError
String getLatestError()
- Returns:
- the latest indexing error seen, will not be reset once the job starts working again
-
getLatestErrorTime
String getLatestErrorTime()
- Returns:
- the time when the latest indexing error has been seen, will not be reset once the job starts working again
-
getFailingIndexStats
TabularData getFailingIndexStats()
-
-