ManagementPlaneSyncRecordPersisterToObjectStore e.g. with FileBasedStoreObjectAccessor@Beta @Deprecated public class ManagementPlaneSyncRecordPersisterToMultiFile extends java.lang.Object implements ManagementPlaneSyncRecordPersister
plane/ - top-level directory
master - contains the id of the management-node that is currently master
change.log - log of changes made
nodes/ - sub-directory, containing one file per management-node
a9WiuVKp - file named after the management-node's id, containing the management node's current state
E1eDXQF3
ManagementPlaneSyncRecordPersister.Delta| Constructor and Description |
|---|
ManagementPlaneSyncRecordPersisterToMultiFile(java.io.File dir,
java.lang.ClassLoader classLoader,
java.lang.String id)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
delta(ManagementPlaneSyncRecordPersister.Delta delta)
Deprecated.
|
java.io.File |
getDir()
Deprecated.
|
ManagementPlaneSyncRecord |
loadSyncRecord()
Deprecated.
Analogue to
BrooklynMementoPersister#loadMemento(brooklyn.mementos.BrooklynMementoPersister.LookupContext) |
void |
stop()
Deprecated.
|
void |
waitForWritesCompleted(Duration timeout)
Deprecated.
|
public ManagementPlaneSyncRecordPersisterToMultiFile(java.io.File dir,
java.lang.ClassLoader classLoader,
java.lang.String id)
dir - Directory to write management-plane dataclassLoader - ClassLoader to use when deserializing dataid - Unique identifier, e.g. used for temp file suffix in case multpile concurrent writerspublic void stop()
stop in interface ManagementPlaneSyncRecordPersisterpublic java.io.File getDir()
public ManagementPlaneSyncRecord loadSyncRecord() throws java.io.IOException
ManagementPlaneSyncRecordPersisterBrooklynMementoPersister#loadMemento(brooklyn.mementos.BrooklynMementoPersister.LookupContext)
Note that this method is *not* thread safe.
loadSyncRecord in interface ManagementPlaneSyncRecordPersisterjava.io.IOExceptionpublic void delta(ManagementPlaneSyncRecordPersister.Delta delta)
delta in interface ManagementPlaneSyncRecordPersisterpublic void waitForWritesCompleted(Duration timeout) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
waitForWritesCompleted in interface ManagementPlaneSyncRecordPersisterjava.lang.InterruptedExceptionjava.util.concurrent.TimeoutException