Package one.microstream.storage.types

Class StorageIoHandler.Default

java.lang.Object

one.microstream.storage.types.StorageIoHandler.Default

All Implemented Interfaces:

PersistenceTypeDictionaryIoHandler.Provider, StorageFileProvider, StorageFileReader, StorageFileWriter, StorageIoHandler

Enclosing interface:

StorageIoHandler

public static final class StorageIoHandler.Default
extends Object
implements StorageIoHandler

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageFileProvider

StorageFileProvider.Builder<B extends StorageFileProvider.Builder<?>>, StorageFileProvider.Defaults, StorageFileProvider.Static

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageFileReader

StorageFileReader.Provider

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageFileWriter

StorageFileWriter.Provider

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageIoHandler

StorageIoHandler.Default

Constructor Summary

Constructors

Constructor	Description
Default(StorageFileProvider fileProvider, StorageFileWriter fileWriter)

Method Summary

Modifier and Type	Method	Description
<P extends Consumer<StorageNumberedFile>> P	collectDataFiles(P collector, int channelIndex)
long	copyFilePart(StorageLockedFile sourceFile, long sourceOffset, long length, StorageLockedFile targetfile)
void	delete(StorageInventoryFile file, StorageFileProvider storageFileProvider)
void	flush(StorageLockedFile targetfile)
String	getStorageLocationIdentifier()	Returns a String that uniquely identifies the storage location.
StorageNumberedFile	provideDataFile(int channelIndex, long fileNumber)
StorageNumberedFile	provideDeletionTargetFile(StorageNumberedFile fileToBeDeleted)
StorageLockedFile	provideLockFile()
StorageNumberedFile	provideTransactionsFile(int channelIndex)
StorageNumberedFile	provideTruncationBackupTargetFile(StorageNumberedFile fileToBeTruncated, long newLength)
PersistenceTypeDictionaryIoHandler	provideTypeDictionaryIoHandler(PersistenceTypeDictionaryStorer writeListener)
void	truncate(StorageInventoryFile file, long newLength, StorageFileProvider storageFileProvider)
long	write(StorageLockedFile file, ByteBuffer[] byteBuffers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface one.microstream.persistence.types.PersistenceTypeDictionaryIoHandler.Provider

provideTypeDictionaryIoHandler

Methods inherited from interface one.microstream.storage.types.StorageFileReader

readStorage

Methods inherited from interface one.microstream.storage.types.StorageFileWriter

copy, writeImport, writeStore, writeTransactionEntryCreate, writeTransactionEntryDelete, writeTransactionEntryStore, writeTransactionEntryTransfer, writeTransactionEntryTruncate, writeTransfer

Methods inherited from interface one.microstream.storage.types.StorageIoHandler

copyData, copyTransactions

Constructor Details

Default

public Default(StorageFileProvider fileProvider, StorageFileWriter fileWriter)

Method Details

getStorageLocationIdentifier

public String getStorageLocationIdentifier()

Description copied from interface: StorageFileProvider

Returns a String that uniquely identifies the storage location.

Specified by:

getStorageLocationIdentifier in interface StorageFileProvider

Returns:

a String that uniquely identifies the storage location.

provideTypeDictionaryIoHandler

public PersistenceTypeDictionaryIoHandler provideTypeDictionaryIoHandler(PersistenceTypeDictionaryStorer writeListener)

Specified by:

provideTypeDictionaryIoHandler in interface PersistenceTypeDictionaryIoHandler.Provider

Specified by:

provideTypeDictionaryIoHandler in interface StorageFileProvider

provideDataFile

public StorageNumberedFile provideDataFile(int channelIndex, long fileNumber)

Specified by:

provideDataFile in interface StorageFileProvider

provideTransactionsFile

public StorageNumberedFile provideTransactionsFile(int channelIndex)

Specified by:

provideTransactionsFile in interface StorageFileProvider

provideLockFile

public StorageLockedFile provideLockFile()

Specified by:

provideLockFile in interface StorageFileProvider

provideDeletionTargetFile

public StorageNumberedFile provideDeletionTargetFile(StorageNumberedFile fileToBeDeleted)

Specified by:

provideDeletionTargetFile in interface StorageFileProvider

provideTruncationBackupTargetFile

public StorageNumberedFile provideTruncationBackupTargetFile(StorageNumberedFile fileToBeTruncated, long newLength)

Specified by:

provideTruncationBackupTargetFile in interface StorageFileProvider

collectDataFiles

public <P extends Consumer<StorageNumberedFile>> P collectDataFiles(P collector, int channelIndex)

Specified by:

collectDataFiles in interface StorageFileProvider

write

public long write(StorageLockedFile file, ByteBuffer[] byteBuffers)

Specified by:

write in interface StorageFileWriter

copyFilePart

public long copyFilePart(StorageLockedFile sourceFile, long sourceOffset, long length, StorageLockedFile targetfile)

Specified by:

copyFilePart in interface StorageFileWriter

flush

public void flush(StorageLockedFile targetfile)

Specified by:

flush in interface StorageFileWriter

truncate

public void truncate(StorageInventoryFile file, long newLength, StorageFileProvider storageFileProvider)

Specified by:

truncate in interface StorageFileWriter

delete

public void delete(StorageInventoryFile file, StorageFileProvider storageFileProvider)

Specified by:

delete in interface StorageFileWriter