Package dev.getelements.elements.rt.transact.unix

Class UnixFSTransactionJournal

java.lang.Object
dev.getelements.elements.rt.transact.unix.UnixFSTransactionJournal
All Implemented Interfaces:
TransactionJournal
public class UnixFSTransactionJournal extends Object implements TransactionJournal

  • Field Details

    • UNIXFS_TRANSACTION_BUFFER_SIZE

      public static final String UNIXFS_TRANSACTION_BUFFER_SIZE
      The size of each transaction entry. This is a fixed size. If a transaction attempts to write more bytes than the size allows, then an exception will result.
      See Also:

    • JOURNAL_MAGIC

      public static final String JOURNAL_MAGIC
      Some magic bytes in the file to indicate what it is.
      See Also:

    • VERSION_MAJOR_1

      public static final int VERSION_MAJOR_1
      Constant for major version 1
      See Also:

    • VERSION_MINOR_0

      public static final int VERSION_MINOR_0
      Constant for minor version 0
      See Also:

    • VERSION_MAJOR_CURRENT

      public static final int VERSION_MAJOR_CURRENT
      Indicates the current major version.
      See Also:

    • VERSION_MINOR_CURRENT

      public static final int VERSION_MINOR_CURRENT
      Indicates the current minor version.
      See Also:

  • Constructor Details

    • UnixFSTransactionJournal

      public UnixFSTransactionJournal()

  • Method Details

    • start

      public void start()

    • stop

      public void stop()

    • newMutableEntry

      public dev.getelements.elements.rt.transact.unix.UnixFSJournalMutableEntry newMutableEntry(NodeId nodeId)
      Description copied from interface: TransactionJournal
      Gets a new entry for writing.
      Specified by:
      newMutableEntry in interface TransactionJournal
      Parameters:
      nodeId - the NodeId to use
      Returns:
      a new TransactionJournal.MutableEntry

    • getTxnBufferSize

      public int getTxnBufferSize()

    • setTxnBufferSize

      @Inject public void setTxnBufferSize(@Named("dev.getelements.elements.rt.transact.journal.buffer.size") int txnBufferSize)

    • getUtils

      public UnixFSUtils getUtils()

    • setUtils

      @Inject public void setUtils(UnixFSUtils utils)

    • getPreferredChecksumAlgorithm

      public UnixFSChecksumAlgorithm getPreferredChecksumAlgorithm()

    • setPreferredChecksumAlgorithm

      @Inject public void setPreferredChecksumAlgorithm(UnixFSChecksumAlgorithm preferredChecksumAlgorithm)

    • getProgramBuilderProvider

      public jakarta.inject.Provider<UnixFSTransactionProgramBuilder> getProgramBuilderProvider()

    • setProgramBuilderProvider

      @Inject public void setProgramBuilderProvider(jakarta.inject.Provider<UnixFSTransactionProgramBuilder> programBuilderProvider)

    • getDataStore

      public DataStore getDataStore()

    • setDataStore

      @Inject public void setDataStore(DataStore dataStore)