Package one.microstream.storage.types

Interface StorageFileManager

All Known Implementing Classes:

StorageFileManager.Default

public interface StorageFileManager

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	StorageFileManager.Default

Method Summary

Modifier and Type	Method	Description
int	channelIndex()
void	commitWrite()
StorageRawFileStatistics.ChannelStatistics	createRawFileStatistics()
StorageDataFile<?>	currentStorageFile()
void	exportData(StorageIoHandler fileHandler)
boolean	incrementalFileCleanupCheck(long nanoTimeBudgetBound)
StorageIdAnalysis	initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)
boolean	issuedFileCleanupCheck(long nanoTimeBudgetBound, StorageDataFileDissolvingEvaluator fileDissolver)
void	iterateStorageFiles(Consumer<? super StorageDataFile<?>> procedure)
StorageInventory	readStorage()
void	resetFileCleanupCursor()
void	rollbackWrite()
long[]	storeChunks(long timestamp, ByteBuffer[] dataBuffers)

Method Detail

channelIndex

int channelIndex()

storeChunks

long[] storeChunks(long timestamp,
                   ByteBuffer[] dataBuffers)
            throws StorageExceptionIoWritingChunk

Throws:

StorageExceptionIoWritingChunk

rollbackWrite

void rollbackWrite()

commitWrite

void commitWrite()

readStorage

StorageInventory readStorage()

initializeStorage

StorageIdAnalysis initializeStorage(long taskTimestamp,
                                    long consistentStoreTimestamp,
                                    StorageInventory storageInventory)

currentStorageFile

StorageDataFile<?> currentStorageFile()

iterateStorageFiles

void iterateStorageFiles(Consumer<? super StorageDataFile<?>> procedure)

incrementalFileCleanupCheck

boolean incrementalFileCleanupCheck(long nanoTimeBudgetBound)

issuedFileCleanupCheck

boolean issuedFileCleanupCheck(long nanoTimeBudgetBound,
                               StorageDataFileDissolvingEvaluator fileDissolver)

exportData

void exportData(StorageIoHandler fileHandler)

createRawFileStatistics

StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()

resetFileCleanupCursor

void resetFileCleanupCursor()