Package one.microstream.storage.types

Interface StorageChannel

All Superinterfaces:

Runnable, StorageActivePart, StorageHashChannelPart

All Known Implementing Classes:

StorageChannel.Default

public interface StorageChannel
extends Runnable, StorageHashChannelPart, StorageActivePart

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	StorageChannel.Default
static class	StorageChannel.EntityCollectorByOid
static class	StorageChannel.EntityCollectorByTid
static interface	StorageChannel.HousekeepingTask

Method Summary

Modifier and Type	Method	Description
void	cleanupStore()
void	clear()
ChunksBuffer	collectLoadByOids(ChunksBuffer[] channelChunks, PersistenceIdSet loadOids)
ChunksBuffer	collectLoadByTids(ChunksBuffer[] channelChunks, PersistenceIdSet loadTids)
ChunksBuffer	collectLoadRoots(ChunksBuffer[] channelChunks)
void	commitChunkStorage()
void	commitImportData(long taskTimestamp)
StorageRawFileStatistics.ChannelStatistics	createRawFileStatistics()
void	exportData(StorageIoHandler fileHandler)
KeyValue<Long,Long>	exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file)
KeyValue<Long,Long>	exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file, Predicate<? super StorageEntity> predicateEntity)
void	importData(StorageChannelImportSourceFile importFile)
StorageIdAnalysis	initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)
boolean	issuedCacheCheck(long nanoTimeBudgetBound, StorageEntityCacheEvaluator entityEvaluator)
boolean	issuedFileCheck(long nanoTimeBudgetBound, StorageDataFileDissolvingEvaluator fileDissolver)
boolean	issuedGarbageCollection(long nanoTimeBudgetBound)
void	postStoreUpdateEntityCache(ByteBuffer[] chunks, long[] chunksStoragePositions)
StorageEntityCache.Default	prepareImportData()
StorageInventory	readStorage()
void	rollbackChunkStorage()
void	rollbackImportData(Throwable cause)
void	signalGarbageCollectionSweepCompleted()
KeyValue<ByteBuffer[],long[]>	storeEntities(long timestamp, Chunk chunkData)
StorageTypeDictionary	typeDictionary()

Methods inherited from interface java.lang.Runnable

run

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

isActive

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

channelIndex

Method Detail

typeDictionary

StorageTypeDictionary typeDictionary()

collectLoadByOids

ChunksBuffer collectLoadByOids(ChunksBuffer[] channelChunks,
                               PersistenceIdSet loadOids)

collectLoadRoots

ChunksBuffer collectLoadRoots(ChunksBuffer[] channelChunks)

collectLoadByTids

ChunksBuffer collectLoadByTids(ChunksBuffer[] channelChunks,
                               PersistenceIdSet loadTids)

storeEntities

KeyValue<ByteBuffer[],long[]> storeEntities(long timestamp,
                                                  Chunk chunkData)

rollbackChunkStorage

void rollbackChunkStorage()

commitChunkStorage

void commitChunkStorage()

postStoreUpdateEntityCache

void postStoreUpdateEntityCache(ByteBuffer[] chunks,
                                long[] chunksStoragePositions)
                         throws InterruptedException

Throws:

InterruptedException

readStorage

StorageInventory readStorage()

issuedGarbageCollection

boolean issuedGarbageCollection(long nanoTimeBudgetBound)

issuedFileCheck

boolean issuedFileCheck(long nanoTimeBudgetBound,
                        StorageDataFileDissolvingEvaluator fileDissolver)

issuedCacheCheck

boolean issuedCacheCheck(long nanoTimeBudgetBound,
                         StorageEntityCacheEvaluator entityEvaluator)

exportData

void exportData(StorageIoHandler fileHandler)

prepareImportData

StorageEntityCache.Default prepareImportData()

importData

void importData(StorageChannelImportSourceFile importFile)

rollbackImportData

void rollbackImportData(Throwable cause)

commitImportData

void commitImportData(long taskTimestamp)

exportTypeEntities

KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type,
                                             StorageLockedFile file)
                                      throws IOException

Throws:

IOException

exportTypeEntities

KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type,
                                             StorageLockedFile file,
                                             Predicate<? super StorageEntity> predicateEntity)
                                      throws IOException

Throws:

IOException

createRawFileStatistics

StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()

initializeStorage

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

clear

void clear()

signalGarbageCollectionSweepCompleted

void signalGarbageCollectionSweepCompleted()

cleanupStore

void cleanupStore()