Package one.microstream.storage.types

Class StorageTaskBroker.Default

java.lang.Object

one.microstream.storage.types.StorageTaskBroker.Default

All Implemented Interfaces:

StorageTaskBroker

Enclosing interface:

StorageTaskBroker

public static final class StorageTaskBroker.Default
extends Object
implements StorageTaskBroker

Nested Class Summary

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

StorageTaskBroker.Creator, StorageTaskBroker.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
StorageTask	currentTask()
StorageRequestTaskCreateStatistics	enqueueCreateRawFileStatisticsTask()
StorageRequestTask	enqueueExportChannelsTask(StorageIoHandler fileHandler, boolean performGarbageCollection)
StorageRequestTaskExportEntitiesByType	enqueueExportTypesTask(StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)
StorageRequestTask	enqueueImportFromFilesTask(XGettingEnum<Path> importFiles)
StorageRequestTaskLoadByOids	enqueueLoadTaskByOids(PersistenceIdSet[] loadOids)
StorageRequestTaskLoadByTids	enqueueLoadTaskByTids(PersistenceIdSet loadTids)
StorageRequestTaskLoadRoots	enqueueRootsLoadTask()
StorageRequestTaskStoreEntities	enqueueStoreTask(Binary data)
StorageRequestTaskCacheCheck	issueCacheCheck(long nanoTimeBudgetBound, StorageEntityCacheEvaluator entityEvaluator)
StorageChannelTaskInitialize	issueChannelInitialization(StorageOperationController operationController)
StorageChannelTaskShutdown	issueChannelShutdown(StorageOperationController operationController)
StorageRequestTaskFileCheck	issueFileCheck(long nanoTimeBudgetBound, StorageDataFileDissolvingEvaluator fileDissolver)
StorageRequestTaskGarbageCollection	issueGarbageCollection(long nanoTimeBudgetBound)

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.StorageTaskBroker

enqueueExportTypesTask

Constructor Detail

Default

public Default()

Method Detail

currentTask

public final StorageTask currentTask()

Specified by:

currentTask in interface StorageTaskBroker

issueGarbageCollection

public final StorageRequestTaskGarbageCollection issueGarbageCollection(long nanoTimeBudgetBound)
                                                                 throws InterruptedException

Specified by:

issueGarbageCollection in interface StorageTaskBroker

Throws:

InterruptedException

issueCacheCheck

public final StorageRequestTaskCacheCheck issueCacheCheck(long nanoTimeBudgetBound,
                                                          StorageEntityCacheEvaluator entityEvaluator)
                                                   throws InterruptedException

Specified by:

issueCacheCheck in interface StorageTaskBroker

Throws:

InterruptedException

issueFileCheck

public final StorageRequestTaskFileCheck issueFileCheck(long nanoTimeBudgetBound,
                                                        StorageDataFileDissolvingEvaluator fileDissolver)
                                                 throws InterruptedException

Specified by:

issueFileCheck in interface StorageTaskBroker

Throws:

InterruptedException

enqueueExportChannelsTask

public final StorageRequestTask enqueueExportChannelsTask(StorageIoHandler fileHandler,
                                                          boolean performGarbageCollection)
                                                   throws InterruptedException

Specified by:

enqueueExportChannelsTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueImportFromFilesTask

public StorageRequestTask enqueueImportFromFilesTask(XGettingEnum<Path> importFiles)
                                              throws InterruptedException

Specified by:

enqueueImportFromFilesTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueCreateRawFileStatisticsTask

public StorageRequestTaskCreateStatistics enqueueCreateRawFileStatisticsTask()
                                                                      throws InterruptedException

Specified by:

enqueueCreateRawFileStatisticsTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueExportTypesTask

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

Specified by:

enqueueExportTypesTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueStoreTask

public final StorageRequestTaskStoreEntities enqueueStoreTask(Binary data)
                                                       throws InterruptedException

Specified by:

enqueueStoreTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueLoadTaskByOids

public final StorageRequestTaskLoadByOids enqueueLoadTaskByOids(PersistenceIdSet[] loadOids)
                                                         throws InterruptedException

Specified by:

enqueueLoadTaskByOids in interface StorageTaskBroker

Throws:

InterruptedException

enqueueRootsLoadTask

public final StorageRequestTaskLoadRoots enqueueRootsLoadTask()
                                                       throws InterruptedException

Specified by:

enqueueRootsLoadTask in interface StorageTaskBroker

Throws:

InterruptedException

enqueueLoadTaskByTids

public final StorageRequestTaskLoadByTids enqueueLoadTaskByTids(PersistenceIdSet loadTids)
                                                         throws InterruptedException

Specified by:

enqueueLoadTaskByTids in interface StorageTaskBroker

Throws:

InterruptedException

issueChannelInitialization

public final StorageChannelTaskInitialize issueChannelInitialization(StorageOperationController operationController)
                                                              throws InterruptedException

Specified by:

issueChannelInitialization in interface StorageTaskBroker

Throws:

InterruptedException

issueChannelShutdown

public final StorageChannelTaskShutdown issueChannelShutdown(StorageOperationController operationController)
                                                      throws InterruptedException

Specified by:

issueChannelShutdown in interface StorageTaskBroker

Throws:

InterruptedException