public interface RecoveryTargetHandler
Modifier and Type | Method and 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(GlobalCheckpointTracker.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(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(int totalTranslogOps) throws java.io.IOException
totalTranslogOps
- total translog operations expected to be sentjava.io.IOException
void finalizeRecovery(long globalCheckpoint)
globalCheckpoint
- the global checkpoint on the recovery sourcevoid ensureClusterStateVersion(long clusterStateVersion)
void handoffPrimaryContext(GlobalCheckpointTracker.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