Package one.microstream.storage.types

Class StorageRequestAcceptor.Default

java.lang.Object

one.microstream.storage.types.StorageRequestAcceptor.Default

All Implemented Interfaces:

StorageRequestAcceptor

Enclosing interface:

StorageRequestAcceptor

public static final class StorageRequestAcceptor.Default
extends Object
implements StorageRequestAcceptor

Nested Class Summary

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

StorageRequestAcceptor.Creator, StorageRequestAcceptor.Default

Constructor Summary

Constructors

Constructor	Description
Default(StorageDataChunkValidator dataChunkValidator, StorageTaskBroker taskBroker)

Method Summary

Modifier and Type	Method	Description
StorageRawFileStatistics	createStatistics()
void	exportChannels(StorageLiveFileProvider fileProvider, boolean performGarbageCollection)
StorageEntityTypeExportStatistics	exportTypes(StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)
void	importFiles(XGettingEnum<AFile> importFiles)
boolean	issueCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)
boolean	issueFileCheck(long nanoTimeBudget)
boolean	issueGarbageCollection(long nanoTimeBudget)
Binary	queryByObjectIds(PersistenceIdSet[] loadOids)
Binary	queryByTypeIds(PersistenceIdSet loadTids)
Binary	recallRoots()
void	storeData(Binary data)

Methods inherited from class java.lang.Object

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

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

exportTypes

Constructor Details

Default

public Default(StorageDataChunkValidator dataChunkValidator, StorageTaskBroker taskBroker)

Method Details

storeData

public final void storeData(Binary data) throws InterruptedException

Specified by:

storeData in interface StorageRequestAcceptor

Throws:

InterruptedException

queryByObjectIds

public final Binary queryByObjectIds(PersistenceIdSet[] loadOids) throws InterruptedException

Specified by:

queryByObjectIds in interface StorageRequestAcceptor

Throws:

InterruptedException

queryByTypeIds

public Binary queryByTypeIds(PersistenceIdSet loadTids) throws StorageExceptionRequest, InterruptedException

Specified by:

queryByTypeIds in interface StorageRequestAcceptor

Throws:

StorageExceptionRequest

InterruptedException

recallRoots

public Binary recallRoots() throws StorageExceptionRequest, InterruptedException

Specified by:

recallRoots in interface StorageRequestAcceptor

Throws:

StorageExceptionRequest

InterruptedException

issueGarbageCollection

public boolean issueGarbageCollection(long nanoTimeBudget) throws InterruptedException

Specified by:

issueGarbageCollection in interface StorageRequestAcceptor

Throws:

InterruptedException

issueCacheCheck

public boolean issueCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator) throws InterruptedException

Specified by:

issueCacheCheck in interface StorageRequestAcceptor

Throws:

InterruptedException

issueFileCheck

public boolean issueFileCheck(long nanoTimeBudget) throws InterruptedException

Specified by:

issueFileCheck in interface StorageRequestAcceptor

Throws:

InterruptedException

exportTypes

public final StorageEntityTypeExportStatistics exportTypes(StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType) throws InterruptedException

Specified by:

exportTypes in interface StorageRequestAcceptor

Throws:

InterruptedException

exportChannels

public final void exportChannels(StorageLiveFileProvider fileProvider, boolean performGarbageCollection) throws InterruptedException

Specified by:

exportChannels in interface StorageRequestAcceptor

Throws:

InterruptedException

createStatistics

public StorageRawFileStatistics createStatistics() throws InterruptedException

Specified by:

createStatistics in interface StorageRequestAcceptor

Throws:

InterruptedException

importFiles

public void importFiles(XGettingEnum<AFile> importFiles) throws InterruptedException

Specified by:

importFiles in interface StorageRequestAcceptor

Throws:

InterruptedException