public interface StorageEngine
This interface does not specify any query capabilities, which, of course, would be query engine specific. Instead it just specifies the minimum functionality required to reload a storage engine from its changelog as well as basic lifecycle management.
Modifier and Type | Method and Description |
---|---|
void |
flush()
Flush any cached messages
|
StoreProperties |
getStoreProperties()
Get store properties
|
void |
restore(java.util.Iterator<IncomingMessageEnvelope> envelopes)
Restore the content of this StorageEngine from the changelog.
|
void |
stop()
Close the storage engine
|
void restore(java.util.Iterator<IncomingMessageEnvelope> envelopes)
Iterator
and not deserialized for
efficiency, allowing the implementation to optimize replay, if possible.envelopes
- An iterator of envelopes that the storage engine can read from to
restore its state on startup.void flush()
void stop()
StoreProperties getStoreProperties()