Class LogAppender

  • All Implemented Interfaces:
    io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>

    public class LogAppender
    extends Object
    implements io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>
    • Constructor Detail

      • LogAppender

        public LogAppender​(NonBlockingManager nonBlockingManager,
                           org.infinispan.persistence.sifs.Index index,
                           TemporaryTable temporaryTable,
                           org.infinispan.persistence.sifs.Compactor compactor,
                           FileProvider fileProvider,
                           boolean syncWrites,
                           int maxFileSize)
    • Method Detail

      • start

        public void start​(Executor executor)
      • stop

        public void stop()
      • clearAndPause

        public CompletionStage<Void> clearAndPause()
        Clears all the log entries returning a stage when the completion is done. Note that after the clear is complete this appender will also be paused. To resume it callers must ensure they invoke resume() to restart the appender
        Returns:
        a stage that when complete the log will be cleared and this appender is paused
      • accept

        public void accept​(org.infinispan.persistence.sifs.LogAppender.WriteOperation writeOperation)
        Specified by:
        accept in interface io.reactivex.rxjava3.functions.Consumer<org.infinispan.persistence.sifs.LogAppender.WriteOperation>
      • setSeqId

        public void setSeqId​(long seqId)