Interface EntryLogManager

    • Method Detail

      • addEntry

        long addEntry​(long ledger,
                      io.netty.buffer.ByteBuf entry,
                      boolean rollLog)
               throws java.io.IOException
        Throws:
        java.io.IOException
      • getDirForNextEntryLog

        java.io.File getDirForNextEntryLog​(java.util.List<java.io.File> writableLedgerDirs)
      • checkpoint

        void checkpoint()
                 throws java.io.IOException
        Throws:
        java.io.IOException
      • flush

        void flush()
            throws java.io.IOException
        Throws:
        java.io.IOException
      • close

        void close()
            throws java.io.IOException
        Throws:
        java.io.IOException
      • forceClose

        void forceClose()
      • prepareSortedLedgerStorageCheckpoint

        void prepareSortedLedgerStorageCheckpoint​(long numBytesFlushed)
                                           throws java.io.IOException
        Throws:
        java.io.IOException
      • prepareEntryMemTableFlush

        void prepareEntryMemTableFlush()
      • commitEntryMemTableFlush

        boolean commitEntryMemTableFlush()
                                  throws java.io.IOException
        Throws:
        java.io.IOException