Package one.microstream.storage.types
Interface StorageTask
- All Known Subinterfaces:
StorageChannelSynchronizingTask,StorageChannelTask,StorageChannelTaskInitialize,StorageChannelTaskLoadByOids,StorageChannelTaskLoadByTid,StorageChannelTaskShutdown,StorageChannelTaskStoreEntities,StorageRequestTask,StorageRequestTaskCacheCheck,StorageRequestTaskCreateStatistics,StorageRequestTaskExportChannels,StorageRequestTaskExportEntitiesByType,StorageRequestTaskFileCheck,StorageRequestTaskGarbageCollection,StorageRequestTaskImportData,StorageRequestTaskLoad,StorageRequestTaskLoadByOids,StorageRequestTaskLoadByTids,StorageRequestTaskLoadRoots,StorageRequestTaskStoreEntities,StorageTaskCollectGarbage
- All Known Implementing Classes:
StorageChannelSynchronizingTask.AbstractCompletingTask,StorageChannelSynchronizingTask.AbstractCompletingTask.Dummy,StorageChannelTask.Abstract,StorageChannelTaskInitialize.Default,StorageChannelTaskShutdown.Default,StorageRequestTaskCacheCheck.Default,StorageRequestTaskCreateStatistics.Default,StorageRequestTaskExportChannels.Default,StorageRequestTaskExportEntitiesByType.Default,StorageRequestTaskFileCheck.Default,StorageRequestTaskGarbageCollection.Default,StorageRequestTaskImportData.Default,StorageRequestTaskLoad.Abstract,StorageRequestTaskLoadByOids.Default,StorageRequestTaskLoadByTids.Default,StorageRequestTaskLoadRoots.Default,StorageRequestTaskStoreEntities.Default,StorageTask.Abstract,StorageTask.DummyTask
public interface StorageTask
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classStorageTask.Abstractstatic classStorageTask.DummyTask -
Method Summary
Modifier and Type Method Description StorageTaskawaitNext(long ms)booleanhasProblems()booleanisComplete()StorageTasknext()ThrowableproblemForChannel(StorageChannel channel)Throwable[]problems()voidprocessBy(StorageChannel storageChannel)voidsetNext(StorageTask saveChunkEntry)longtimestamp()voidwaitOnCompletion()
-
Method Details
-
setNext
-
awaitNext
- Throws:
InterruptedException
-
next
StorageTask next() -
processBy
- Throws:
InterruptedException
-
isComplete
boolean isComplete() -
waitOnCompletion
- Throws:
InterruptedException
-
hasProblems
boolean hasProblems() -
problems
Throwable[] problems() -
problemForChannel
-
timestamp
long timestamp()
-