Interface OpenSearchIndexReplayService

All Known Implementing Classes:
DefaultOpenSearchIndexReplayService, NoOpOpenSearchIndexReplayService

public interface OpenSearchIndexReplayService
Interface for managing the OpenSearch Index Replay Job lifecycle.

Provides two implementations: NoOpOpenSearchIndexReplayService for Lucene (no-op) and DefaultOpenSearchIndexReplayService for OpenSearch (scheduled job). The job ensures consistency between the RIO table and OpenSearch index by replaying any missed index operations.

In clustered environments, the job runs on a single node using RUN_ONCE_PER_CLUSTER mode to prevent duplicate processing.

Since:
11.0
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Starts the index replay job.
    void
    Stops the index replay job.
  • Method Details

    • start

      void start()
      Starts the index replay job. For OpenSearch, this registers a scheduled job; for Lucene, this is a no-op operation.
    • stop

      void stop()
      Stops the index replay job. For OpenSearch, this cleans up resources; for Lucene, this is a no-op operation.