Interface ReIndexJobManagerInternal

    • Method Detail

      • updateReIndexJobIfPresent

        void updateReIndexJobIfPresent​(Consumer<ReIndexJob> updater)
                                throws InterruptedException,
                                       TimeoutException
        Try to update current re-index job in an atomic operation. 3 steps: 1. Fetch current ReIndexJob, if not found then skip 2 and 3. 2. Mutate the running reIndexJob using the provided updater. 3. Persist the updated reIndexJob.
        Parameters:
        updater - a callback to mutate running ReIndexJob
        Throws:
        InterruptedException - if interrupted while waiting to update the job
        TimeoutException - if cannot obtain exclusive access in order to update the job within reasonable time
      • clear

        void clear()
        Delete most recent or running re-index job. No-op if there is neither