Interface IndexingPlanSynchronizationStrategyConfigurationContext
- All Known Implementing Classes:
ConfiguredIndexingPlanSynchronizationStrategy.Builder
-
Method Summary
Modifier and TypeMethodDescriptionvoid
documentCommitStrategy
(DocumentCommitStrategy strategy) void
void
indexingFutureHandler
(Consumer<? super CompletableFuture<? extends SearchIndexingPlanExecutionReport>> handler) Set the handler for the (asynchronous) indexing future.void
operationSubmitter
(OperationSubmitter operationSubmitter) Set operation submitter to be applied while executing underlying plans.
-
Method Details
-
documentCommitStrategy
- Parameters:
strategy
- A strategy describing how commits should be handled after document changes are applied. Defaults toDocumentCommitStrategy.NONE
.
-
documentRefreshStrategy
- Parameters:
strategy
- A strategy describing how refresh should be handled after document changes are applied. Defaults toDocumentRefreshStrategy.NONE
.
-
indexingFutureHandler
void indexingFutureHandler(Consumer<? super CompletableFuture<? extends SearchIndexingPlanExecutionReport>> handler) Set the handler for the (asynchronous) indexing future.This typically involves waiting on the given future, to prevent the thread from resuming execution until indexing is complete.
- Parameters:
handler
- A handler that will be passed a future representing the progress of indexing. Defaults to a no-op handler. The future will be completed with an execution report once all document changes are applied. If any document change or the commit/refresh required bydocumentCommitStrategy(DocumentCommitStrategy)
anddocumentRefreshStrategy(DocumentRefreshStrategy)
failed, the report willcontain a throwable
and (if applicable)a list of failing entities
.
-
failureHandler
FailureHandler failureHandler()- Returns:
- The failure handler.
Use this to report failures that cannot be propagated by the
indexingFutureHandler(Consumer)
.
-
operationSubmitter
Set operation submitter to be applied while executing underlying plans.Using
OperationSubmitter.BLOCKING
by default.- Parameters:
operationSubmitter
- How to handle request to submit operation when the queue is full- See Also:
-