java.lang.Object
org.elasticsearch.action.DelegatingActionListener<ShardSnapshotResult,ShardSnapshotResult>
org.elasticsearch.repositories.SnapshotShardContext
- All Implemented Interfaces:
ActionListener<ShardSnapshotResult>
public final class SnapshotShardContext
extends DelegatingActionListener<ShardSnapshotResult,ShardSnapshotResult>
Context holding the state for creating a shard snapshot via
Repository.snapshotShard(SnapshotShardContext).
Wraps a Engine.IndexCommitRef that is released once this instances is completed by invoking
either its onResponse(ShardSnapshotResult) or DelegatingActionListener.onFailure(Exception) callback.-
Field Summary
Fields inherited from class org.elasticsearch.action.DelegatingActionListener
delegate -
Constructor Summary
ConstructorsConstructorDescriptionSnapshotShardContext(Store store, MapperService mapperService, SnapshotId snapshotId, IndexId indexId, SnapshotIndexCommit commitRef, String shardStateIdentifier, IndexShardSnapshotStatus snapshotStatus, IndexVersion repositoryMetaVersion, long snapshotStartTime, ActionListener<ShardSnapshotResult> listener) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.lucene.index.IndexCommitindexId()voidonResponse(ShardSnapshotResult result) Complete this listener with a successful (or at least, non-exceptional) response.longstatus()store()Methods inherited from class org.elasticsearch.action.DelegatingActionListener
onFailure, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.action.ActionListener
delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, safeMap
-
Constructor Details
-
SnapshotShardContext
public SnapshotShardContext(Store store, MapperService mapperService, SnapshotId snapshotId, IndexId indexId, SnapshotIndexCommit commitRef, @Nullable String shardStateIdentifier, IndexShardSnapshotStatus snapshotStatus, IndexVersion repositoryMetaVersion, long snapshotStartTime, ActionListener<ShardSnapshotResult> listener) - Parameters:
store- store to be snapshottedmapperService- the shards mapper servicesnapshotId- snapshot idindexId- id for the index being snapshottedcommitRef- commit point referenceshardStateIdentifier- a unique identifier of the state of the shard that is stored with the shard's snapshot and used to detect if the shard has changed between snapshots. Ifnullis passed as the identifier snapshotting will be done by inspecting the physical files referenced bysnapshotIndexCommitsnapshotStatus- snapshot statusrepositoryMetaVersion- version of the updated repository metadata to writesnapshotStartTime- start time of the snapshot found inSnapshotsInProgress.Entry.startTime()listener- listener invoked on completion
-
-
Method Details
-
store
-
mapperService
-
snapshotId
-
indexId
-
indexCommit
public org.apache.lucene.index.IndexCommit indexCommit() -
stateIdentifier
-
status
-
getRepositoryMetaVersion
-
snapshotStartTime
public long snapshotStartTime() -
onResponse
Description copied from interface:ActionListenerComplete this listener with a successful (or at least, non-exceptional) response. -
withCommitRef
-