Package one.microstream.storage.types

Interface StorageRequestTaskCreator

All Known Implementing Classes:

StorageRequestTaskCreator.Default

public interface StorageRequestTaskCreator

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	StorageRequestTaskCreator.Default

Method Summary

Modifier and Type	Method	Description
StorageRequestTaskCreateStatistics	createCreateRawFileStatisticsTask(int channelCount)
default StorageRequestTaskExportEntitiesByType	createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider)
StorageRequestTaskExportEntitiesByType	createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)
StorageRequestTaskCacheCheck	createFullCacheCheckTask(int channelCount, long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)
StorageRequestTaskFileCheck	createFullFileCheckTask(int channelCount, long nanoTimeBudget)
StorageRequestTaskImportData	createImportFromFilesTask(int channelCount, StorageDataFileEvaluator fileEvaluator, StorageObjectIdRangeEvaluator objectIdRangeEvaluator, XGettingEnum<AFile> importFiles)
StorageChannelTaskInitialize	createInitializationTask(int channelCount, StorageOperationController operationController)
StorageRequestTaskLoadByOids	createLoadTaskByOids(PersistenceIdSet[] loadOids)
StorageRequestTaskLoadByTids	createLoadTaskByTids(PersistenceIdSet loadTids, int channelCount)
StorageRequestTaskLoadRoots	createRootsLoadTask(int channelCount)
StorageRequestTaskStoreEntities	createSaveTask(Binary data)
StorageChannelTaskShutdown	createShutdownTask(int channelCount, StorageOperationController operationController)
StorageRequestTaskExportChannels	createTaskExportChannels(int channelCount, StorageLiveFileProvider fileProvider)

Method Details

createInitializationTask

StorageChannelTaskInitialize createInitializationTask(int channelCount, StorageOperationController operationController)

createSaveTask

StorageRequestTaskStoreEntities createSaveTask(Binary data)

createLoadTaskByOids

StorageRequestTaskLoadByOids createLoadTaskByOids(PersistenceIdSet[] loadOids)

createRootsLoadTask

StorageRequestTaskLoadRoots createRootsLoadTask(int channelCount)

createLoadTaskByTids

StorageRequestTaskLoadByTids createLoadTaskByTids(PersistenceIdSet loadTids, int channelCount)

createExportTypesTask

default StorageRequestTaskExportEntitiesByType createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider)

createExportTypesTask

StorageRequestTaskExportEntitiesByType createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)

createTaskExportChannels

StorageRequestTaskExportChannels createTaskExportChannels(int channelCount, StorageLiveFileProvider fileProvider)

createCreateRawFileStatisticsTask

StorageRequestTaskCreateStatistics createCreateRawFileStatisticsTask(int channelCount)

createFullFileCheckTask

StorageRequestTaskFileCheck createFullFileCheckTask(int channelCount, long nanoTimeBudget)

createFullCacheCheckTask

StorageRequestTaskCacheCheck createFullCacheCheckTask(int channelCount, long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)

createImportFromFilesTask

StorageRequestTaskImportData createImportFromFilesTask(int channelCount, StorageDataFileEvaluator fileEvaluator, StorageObjectIdRangeEvaluator objectIdRangeEvaluator, XGettingEnum<AFile> importFiles)

createShutdownTask

StorageChannelTaskShutdown createShutdownTask(int channelCount, StorageOperationController operationController)