Package one.microstream.storage.types

Class StorageBackupItemQueue.Default

java.lang.Object

one.microstream.storage.types.StorageBackupItemQueue.Default

All Implemented Interfaces:

StorageBackupItemEnqueuer, StorageBackupItemQueue, StorageFileUser

Enclosing interface:

StorageBackupItemQueue

public static final class StorageBackupItemQueue.Default
extends Object
implements StorageBackupItemQueue

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageBackupItemQueue

StorageBackupItemQueue.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	enqueueCopyingItem(StorageLiveChannelFile<?> sourceFile, long sourcePosition, long length)
void	enqueueDeletionItem(StorageLiveChannelFile<?> file)
void	enqueueTruncatingItem(StorageLiveChannelFile<?> file, long newLength)
boolean	processNextItem(StorageBackupHandler handler, long timeoutMs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Default

public Default()

Method Details

enqueueCopyingItem

public final void enqueueCopyingItem(StorageLiveChannelFile<?> sourceFile, long sourcePosition, long length)

Specified by:

enqueueCopyingItem in interface StorageBackupItemEnqueuer

enqueueTruncatingItem

public final void enqueueTruncatingItem(StorageLiveChannelFile<?> file, long newLength)

Specified by:

enqueueTruncatingItem in interface StorageBackupItemEnqueuer

enqueueDeletionItem

public void enqueueDeletionItem(StorageLiveChannelFile<?> file)

Specified by:

enqueueDeletionItem in interface StorageBackupItemEnqueuer

processNextItem

public final boolean processNextItem(StorageBackupHandler handler, long timeoutMs) throws InterruptedException

Specified by:

processNextItem in interface StorageBackupItemQueue

Throws:

InterruptedException