Package one.microstream.storage.types

Interface StorageFileManager

All Superinterfaces:

StorageChannelResetablePart, StorageHashChannelPart

All Known Implementing Classes:

StorageFileManager.Default

public interface StorageFileManager
extends StorageChannelResetablePart

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, StorageChannel parent)
boolean	issuedFileCleanupCheck(long nanoTimeBudget)
void	iterateStorageFiles(Consumer<? super StorageDataFile<?>> procedure)
StorageInventory	readStorage()
void	reset()	Closes all resources (files, locks, etc.).
void	restartFileCleanupCursor()
void	rollbackWrite()
long[]	storeChunks(long timestamp, ByteBuffer[] dataBuffers)

Method Details

channelIndex

int channelIndex()

Specified by:

channelIndex in interface StorageHashChannelPart

reset

void reset()

Description copied from interface: StorageChannelResetablePart

Closes all resources (files, locks, etc.). Clears all variable length items (cache, registry, etc.). Resets internal state to initial values. For itself and all its parts (entity cache, file manager, etc.). Basically a "back to just being born" action.

Specified by:

reset in interface StorageChannelResetablePart

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, StorageChannel parent)

currentStorageFile

StorageDataFile<?> currentStorageFile()

iterateStorageFiles

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

incrementalFileCleanupCheck

boolean incrementalFileCleanupCheck(long nanoTimeBudgetBound)

issuedFileCleanupCheck

boolean issuedFileCleanupCheck(long nanoTimeBudget)

exportData

void exportData(StorageIoHandler fileHandler)

createRawFileStatistics

StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()

restartFileCleanupCursor

void restartFileCleanupCursor()