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() 
 -