Package org.elasticsearch.repositories

Class FinalizeSnapshotContext

java.lang.Object

org.elasticsearch.action.ActionListener.Delegating<Tuple<RepositoryData,SnapshotInfo>,Tuple<RepositoryData,SnapshotInfo>>

org.elasticsearch.repositories.FinalizeSnapshotContext

All Implemented Interfaces:

ActionListener<Tuple<RepositoryData,SnapshotInfo>>

public final class FinalizeSnapshotContext
extends ActionListener.Delegating<Tuple<RepositoryData,SnapshotInfo>,Tuple<RepositoryData,SnapshotInfo>>

Context for finalizing a snapshot.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Field Summary

Fields inherited from class org.elasticsearch.action.ActionListener.Delegating

delegate

Constructor Summary

Constructors

Constructor	Description
FinalizeSnapshotContext(ShardGenerations updatedShardGenerations, long repositoryStateId, Metadata clusterMetadata, SnapshotInfo snapshotInfo, Version repositoryMetaVersion, ActionListener<Tuple<RepositoryData,SnapshotInfo>> listener)

Method Summary

Modifier and Type	Method	Description
Metadata	clusterMetadata()
Map<RepositoryShardId,Set<ShardGeneration>>	obsoleteShardGenerations()
void	onResponse(Tuple<RepositoryData,SnapshotInfo> repositoryData)	Handle action response.
Version	repositoryMetaVersion()
long	repositoryStateId()
SnapshotInfo	snapshotInfo()
ClusterState	updatedClusterState(ClusterState state)
ShardGenerations	updatedShardGenerations()

Methods inherited from class org.elasticsearch.action.ActionListener.Delegating

onFailure, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Constructor Details

FinalizeSnapshotContext

public FinalizeSnapshotContext(ShardGenerations updatedShardGenerations,
 long repositoryStateId,
 Metadata clusterMetadata,
 SnapshotInfo snapshotInfo,
 Version repositoryMetaVersion,
 ActionListener<Tuple<RepositoryData,SnapshotInfo>> listener)

Parameters:

updatedShardGenerations - updated shard generations

repositoryStateId - the unique id identifying the state of the repository when the snapshot began

clusterMetadata - cluster metadata

snapshotInfo - SnapshotInfo instance to write for this snapshot

repositoryMetaVersion - version of the updated repository metadata to write

listener - listener to be invoked with the new RepositoryData and SnapshotInfo after completing the snapshot

Method Details

repositoryStateId

public long repositoryStateId()

updatedShardGenerations

public ShardGenerations updatedShardGenerations()

snapshotInfo

public SnapshotInfo snapshotInfo()

repositoryMetaVersion

public Version repositoryMetaVersion()

clusterMetadata

public Metadata clusterMetadata()

obsoleteShardGenerations

public Map<RepositoryShardId,Set<ShardGeneration>> obsoleteShardGenerations()

updatedClusterState

public ClusterState updatedClusterState(ClusterState state)

onResponse

public void onResponse(Tuple<RepositoryData,SnapshotInfo> repositoryData)

Description copied from interface: ActionListener

Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.