RecoveryTarget
, RemoteRecoveryTargetHandler
public interface RecoveryTargetHandler
Modifier and Type | Method | Description |
---|---|---|
void |
cleanFiles(int totalTranslogOps,
Store.MetadataSnapshot sourceMetaData) |
After all source files has been sent over, this command is sent to the target so it can clean any local
files that are not part of the source store
|
void |
ensureClusterStateVersion(long clusterStateVersion) |
Blockingly waits for cluster state with at least clusterStateVersion to be available
|
void |
finalizeRecovery(long globalCheckpoint) |
The finalize request refreshes the engine now that new segments are available, enables garbage collection of tombstone files, and
updates the global checkpoint.
|
void |
handoffPrimaryContext(ReplicationTracker.PrimaryContext primaryContext) |
Handoff the primary context between the relocation source and the relocation target.
|
long |
indexTranslogOperations(java.util.List<Translog.Operation> operations,
int totalTranslogOps) |
Index a set of translog operations on the target
|
void |
prepareForTranslogOperations(boolean fileBasedRecovery,
int totalTranslogOps) |
Prepares the target to receive translog operations, after all file have been copied
|
void |
receiveFileInfo(java.util.List<java.lang.String> phase1FileNames,
java.util.List<java.lang.Long> phase1FileSizes,
java.util.List<java.lang.String> phase1ExistingFileNames,
java.util.List<java.lang.Long> phase1ExistingFileSizes,
int totalTranslogOps) |
Notifies the target of the files it is going to receive
|
void |
writeFileChunk(StoreFileMetaData fileMetaData,
long position,
BytesReference content,
boolean lastChunk,
int totalTranslogOps) |
writes a partial file chunk to the target store
|
void prepareForTranslogOperations(boolean fileBasedRecovery, int totalTranslogOps) throws java.io.IOException
fileBasedRecovery
- whether or not this call is part of an file based recoverytotalTranslogOps
- total translog operations expected to be sentjava.io.IOException
void finalizeRecovery(long globalCheckpoint) throws java.io.IOException
globalCheckpoint
- the global checkpoint on the recovery sourcejava.io.IOException
void ensureClusterStateVersion(long clusterStateVersion)
void handoffPrimaryContext(ReplicationTracker.PrimaryContext primaryContext)
primaryContext
- the primary context from the relocation sourcelong indexTranslogOperations(java.util.List<Translog.Operation> operations, int totalTranslogOps) throws java.io.IOException
operations
- operations to indextotalTranslogOps
- current number of total operations expected to be indexedjava.io.IOException
void receiveFileInfo(java.util.List<java.lang.String> phase1FileNames, java.util.List<java.lang.Long> phase1FileSizes, java.util.List<java.lang.String> phase1ExistingFileNames, java.util.List<java.lang.Long> phase1ExistingFileSizes, int totalTranslogOps)
void cleanFiles(int totalTranslogOps, Store.MetadataSnapshot sourceMetaData) throws java.io.IOException
totalTranslogOps
- an update number of translog operations that will be replayed later onsourceMetaData
- meta data of the source storejava.io.IOException
void writeFileChunk(StoreFileMetaData fileMetaData, long position, BytesReference content, boolean lastChunk, int totalTranslogOps) throws java.io.IOException
java.io.IOException