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 class
StorageTask.Abstract
static class
StorageTask.DummyTask
-
Method Summary
Modifier and Type Method Description StorageTask
awaitNext(long ms)
boolean
hasProblems()
boolean
isComplete()
StorageTask
next()
Throwable
problemForChannel(StorageChannel channel)
Throwable[]
problems()
void
processBy(StorageChannel storageChannel)
void
setNext(StorageTask saveChunkEntry)
long
timestamp()
void
waitOnCompletion()
-
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()
-