Interface SystemMaintenanceTaskQueue
-
- All Known Implementing Classes:
JournalSystemMaintenanceTaskQueue
public interface SystemMaintenanceTaskQueueA queue containingSystemMaintenanceTasks for indexing. Each task represents an operation to be performed either per-node (on Lucene) or per-cluster (on OpenSearch)- Since:
- 7.3.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidenqueue(SystemMaintenanceTask task)Add a new task to this queue.voidprocessEntries()Apply the given action to contents of the queue.
-
-
-
Method Detail
-
enqueue
void enqueue(SystemMaintenanceTask task)
Add a new task to this queue.
-
processEntries
void processEntries()
Apply the given action to contents of the queue. If the action throws aMaintenanceTaskExecutionExceptionwhen processing an element, processing will be stopped immediately and the next call to processEntries will start from the failing element. If any other exception type is thrown, the failed element will be skipped, and processing will continue.
-
-