Package one.microstream.storage.types
Interface StorageBackupHandler
- All Superinterfaces:
Runnable
,StorageActivePart
- All Known Implementing Classes:
StorageBackupHandler.Default
public interface StorageBackupHandler extends Runnable, StorageActivePart
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
StorageBackupHandler.Default
-
Method Summary
Modifier and Type Method Description void
copyFilePart(StorageLiveChannelFile<?> sourceFile, long sourcePosition, long length)
void
deleteFile(StorageLiveChannelFile<?> file)
void
initialize(int channelIndex)
boolean
isActive()
Queries whether the part is actually active right now.boolean
isRunning()
static StorageBackupHandler
New(StorageBackupSetup backupSetup, int channelCount, StorageBackupItemQueue itemQueue, StorageOperationController operationController, StorageWriteController writeController, StorageDataFileValidator validator)
StorageBackupHandler
setRunning(boolean running)
StorageBackupSetup
setup()
default StorageBackupHandler
start()
default StorageBackupHandler
stop()
void
synchronize(StorageInventory storageInventory)
void
truncateFile(StorageLiveChannelFile<?> file, long newLength)
-
Method Details
-
setup
StorageBackupSetup setup() -
initialize
void initialize(int channelIndex) -
synchronize
-
copyFilePart
-
truncateFile
-
deleteFile
-
start
-
stop
-
isRunning
boolean isRunning() -
isActive
boolean isActive()Description copied from interface:StorageActivePart
Queries whether the part is actually active right now. This might returntrue
even despite some "running" flag being set tofalse
because there might be one last loop cycle execution before checking the "running" flag again.- Specified by:
isActive
in interfaceStorageActivePart
- Returns:
- if the part is actually active right now.
-
setRunning
-
New
static StorageBackupHandler New(StorageBackupSetup backupSetup, int channelCount, StorageBackupItemQueue itemQueue, StorageOperationController operationController, StorageWriteController writeController, StorageDataFileValidator validator)
-