Package org.elasticsearch.index.shard
Class RestoreOnlyRepository
java.lang.Object
org.elasticsearch.common.component.AbstractLifecycleComponent
org.elasticsearch.index.shard.RestoreOnlyRepository
- All Implemented Interfaces:
Closeable,AutoCloseable,LifecycleComponent,org.elasticsearch.core.Releasable,Repository
public abstract class RestoreOnlyRepository
extends AbstractLifecycleComponent
implements Repository
A dummy repository for testing which just needs restore overridden
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.repositories.Repository
Repository.Factory -
Field Summary
Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
lifecycle -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidcloneShardSnapshot(SnapshotId source, SnapshotId target, RepositoryShardId repositoryShardId, ShardGeneration shardGeneration, ActionListener<ShardSnapshotResult> listener) voiddeleteSnapshots(Collection<SnapshotId> snapshotIds, long repositoryDataGeneration, IndexVersion minimumNodeVersion, ActionListener<RepositoryData> repositoryDataUpdateListener, Runnable onCompletion) protected voiddoClose()protected voiddoStart()protected voiddoStop()voidendVerification(String verificationToken) voidfinalizeSnapshot(FinalizeSnapshotContext finalizeSnapshotContext) voidgetRepositoryData(Executor responseExecutor, ActionListener<RepositoryData> listener) getShardSnapshotStatus(SnapshotId snapshotId, IndexId indexId, ShardId shardId) getSnapshotGlobalMetadata(SnapshotId snapshotId, boolean fromProjectMetadata) getSnapshotIndexMetaData(RepositoryData repositoryData, SnapshotId snapshotId, IndexId index) voidgetSnapshotInfo(Collection<SnapshotId> snapshotIds, boolean abortOnFailure, BooleanSupplier isCancelled, org.elasticsearch.core.CheckedConsumer<SnapshotInfo, Exception> consumer, ActionListener<Void> listener) booleanvoidsnapshotShard(SnapshotShardContext context) voidupdateState(ClusterState state) voidverify(String verificationToken, DiscoveryNode localNode) Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, start, stopMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.common.component.LifecycleComponent
addLifecycleListener, lifecycleState, start, stopMethods inherited from interface org.elasticsearch.core.Releasable
closeMethods inherited from interface org.elasticsearch.repositories.Repository
canUpdateInPlace, getProjectRepo, getSnapshotInfo, getUsageFeatures, restoreShard, stats
-
Constructor Details
-
RestoreOnlyRepository
-
-
Method Details
-
doStart
protected void doStart()- Specified by:
doStartin classAbstractLifecycleComponent
-
doStop
protected void doStop()- Specified by:
doStopin classAbstractLifecycleComponent
-
doClose
protected void doClose()- Specified by:
doClosein classAbstractLifecycleComponent
-
getProjectId
- Specified by:
getProjectIdin interfaceRepository
-
getMetadata
- Specified by:
getMetadatain interfaceRepository
-
getSnapshotInfo
public void getSnapshotInfo(Collection<SnapshotId> snapshotIds, boolean abortOnFailure, BooleanSupplier isCancelled, org.elasticsearch.core.CheckedConsumer<SnapshotInfo, Exception> consumer, ActionListener<Void> listener) - Specified by:
getSnapshotInfoin interfaceRepository
-
getSnapshotGlobalMetadata
- Specified by:
getSnapshotGlobalMetadatain interfaceRepository
-
getSnapshotIndexMetaData
public IndexMetadata getSnapshotIndexMetaData(RepositoryData repositoryData, SnapshotId snapshotId, IndexId index) - Specified by:
getSnapshotIndexMetaDatain interfaceRepository
-
getRepositoryData
- Specified by:
getRepositoryDatain interfaceRepository
-
finalizeSnapshot
- Specified by:
finalizeSnapshotin interfaceRepository
-
deleteSnapshots
public void deleteSnapshots(Collection<SnapshotId> snapshotIds, long repositoryDataGeneration, IndexVersion minimumNodeVersion, ActionListener<RepositoryData> repositoryDataUpdateListener, Runnable onCompletion) - Specified by:
deleteSnapshotsin interfaceRepository
-
startVerification
- Specified by:
startVerificationin interfaceRepository
-
endVerification
- Specified by:
endVerificationin interfaceRepository
-
isReadOnly
public boolean isReadOnly()- Specified by:
isReadOnlyin interfaceRepository
-
snapshotShard
- Specified by:
snapshotShardin interfaceRepository
-
getShardSnapshotStatus
public IndexShardSnapshotStatus.Copy getShardSnapshotStatus(SnapshotId snapshotId, IndexId indexId, ShardId shardId) - Specified by:
getShardSnapshotStatusin interfaceRepository
-
verify
- Specified by:
verifyin interfaceRepository
-
updateState
- Specified by:
updateStatein interfaceRepository
-
awaitIdle
public void awaitIdle()- Specified by:
awaitIdlein interfaceRepository
-
cloneShardSnapshot
public void cloneShardSnapshot(SnapshotId source, SnapshotId target, RepositoryShardId repositoryShardId, ShardGeneration shardGeneration, ActionListener<ShardSnapshotResult> listener) - Specified by:
cloneShardSnapshotin interfaceRepository
-
getShardSnapshotsInProgress
- Specified by:
getShardSnapshotsInProgressin interfaceRepository
-
getSnapshotStats
- Specified by:
getSnapshotStatsin interfaceRepository
-