Package org.elasticsearch.snapshots

Class SnapshotsService

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.snapshots.SnapshotsService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ClusterStateApplier, LifecycleComponent, Releasable

public class SnapshotsService
extends AbstractLifecycleComponent
implements ClusterStateApplier

Service responsible for creating snapshots. See package level documentation of org.elasticsearch.snapshots for details.

Field Summary

Fields

Modifier and Type	Field	Description
static Version	MULTI_DELETE_VERSION
static Version	NO_REPO_INITIALIZE_VERSION	Minimum node version which does not use Repository.initializeSnapshot(SnapshotId, List, Metadata) to write snapshot metadata when starting a snapshot.
static Version	OLD_SNAPSHOT_FORMAT
static Version	SHARD_GEN_IN_REPO_DATA_VERSION
static java.lang.String	UPDATE_SNAPSHOT_STATUS_ACTION_NAME

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Constructor Summary

Constructors

Constructor	Description
SnapshotsService(Settings settings, ClusterService clusterService, IndexNameExpressionResolver indexNameExpressionResolver, RepositoriesService repositoriesService, ThreadPool threadPool)

Method Summary

Modifier and Type	Method	Description
void	applyClusterState(ClusterChangedEvent event)	Called when a new cluster state (ClusterChangedEvent.state() needs to be applied.
boolean	assertAllListenersResolved()	Assert that no in-memory state for any running snapshot operation exists in this instance.
void	createSnapshot(CreateSnapshotRequest request, ActionListener<Snapshot> listener)	Initializes the snapshotting process.
static java.util.List<SnapshotsInProgress.Entry>	currentSnapshots(SnapshotsInProgress snapshotsInProgress, java.lang.String repository, java.util.List<java.lang.String> snapshots)	Returns status of the currently running snapshots
void	deleteSnapshots(DeleteSnapshotRequest request, ActionListener<java.lang.Void> listener)	Deletes snapshots from the repository.
protected void	doClose()
protected void	doStart()
protected void	doStop()
void	executeSnapshot(CreateSnapshotRequest request, ActionListener<SnapshotInfo> listener)	Same as createSnapshot(CreateSnapshotRequest, ActionListener) but invokes its callback on completion of the snapshot.
Version	minCompatibleVersion(Version minNodeVersion, java.lang.String repositoryName, RepositoryData repositoryData, java.util.Collection<SnapshotId> excluded)	Determines the minimum Version that the snapshot repository must be compatible with from the current nodes in the cluster and the contents of the repository.
static java.util.Set<Index>	snapshottingIndices(ClusterState currentState, java.util.Set<Index> indicesToCheck)	Returns the indices that are currently being snapshotted (with partial == false) and that are contained in the indices-to-check set.
static boolean	useShardGenerations(Version repositoryMetaVersion)	Checks whether the metadata version supports writing ShardGenerations to the repository.

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

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

Field Details

NO_REPO_INITIALIZE_VERSION

public static final Version NO_REPO_INITIALIZE_VERSION

Minimum node version which does not use Repository.initializeSnapshot(SnapshotId, List, Metadata) to write snapshot metadata when starting a snapshot.

SHARD_GEN_IN_REPO_DATA_VERSION

public static final Version SHARD_GEN_IN_REPO_DATA_VERSION

OLD_SNAPSHOT_FORMAT

public static final Version OLD_SNAPSHOT_FORMAT

MULTI_DELETE_VERSION

public static final Version MULTI_DELETE_VERSION

UPDATE_SNAPSHOT_STATUS_ACTION_NAME

public static final java.lang.String UPDATE_SNAPSHOT_STATUS_ACTION_NAME

See Also:

Constant Field Values

Constructor Details

SnapshotsService

public SnapshotsService(Settings settings, ClusterService clusterService, IndexNameExpressionResolver indexNameExpressionResolver, RepositoriesService repositoriesService, ThreadPool threadPool)

Method Details

executeSnapshot

public void executeSnapshot(CreateSnapshotRequest request, ActionListener<SnapshotInfo> listener)

Same as createSnapshot(CreateSnapshotRequest, ActionListener) but invokes its callback on completion of the snapshot.

Parameters:

request - snapshot request

listener - snapshot completion listener

createSnapshot

public void createSnapshot(CreateSnapshotRequest request, ActionListener<Snapshot> listener)

Initializes the snapshotting process.

This method is used by clients to start snapshot. It makes sure that there is no snapshots are currently running and creates a snapshot record in cluster state metadata.

Parameters:

request - snapshot request

listener - snapshot creation listener

currentSnapshots

public static java.util.List<SnapshotsInProgress.Entry> currentSnapshots(@Nullable SnapshotsInProgress snapshotsInProgress, java.lang.String repository, java.util.List<java.lang.String> snapshots)

Returns status of the currently running snapshots

This method is executed on master node

Parameters:

snapshotsInProgress - snapshots in progress in the cluster state

repository - repository id

snapshots - list of snapshots that will be used as a filter, empty list means no snapshots are filtered

Returns:

list of metadata for currently running snapshots

applyClusterState

public void applyClusterState(ClusterChangedEvent event)

Description copied from interface: ClusterStateApplier

Called when a new cluster state (ClusterChangedEvent.state() needs to be applied. The cluster state to be applied is already committed when this method is called, so an applier must therefore be prepared to deal with any state it receives without throwing an exception. Throwing an exception from an applier is very bad because it will stop the application of this state before it has reached all the other appliers, and will likely result in another attempt to apply the same (or very similar) cluster state which might continue until this node is removed from the cluster.

Specified by:

applyClusterState in interface ClusterStateApplier

deleteSnapshots

public void deleteSnapshots(DeleteSnapshotRequest request, ActionListener<java.lang.Void> listener)

Deletes snapshots from the repository. In-progress snapshots matched by the delete will be aborted before deleting them.

Parameters:

request - delete snapshot request

listener - listener

minCompatibleVersion

public Version minCompatibleVersion(Version minNodeVersion, java.lang.String repositoryName, RepositoryData repositoryData, @Nullable java.util.Collection<SnapshotId> excluded)

Determines the minimum Version that the snapshot repository must be compatible with from the current nodes in the cluster and the contents of the repository. The minimum version is determined as the lowest version found across all snapshots in the repository and all nodes in the cluster.

Parameters:

minNodeVersion - minimum node version in the cluster

repositoryName - name of the repository to modify

repositoryData - current RepositoryData of that repository

excluded - snapshot id to ignore when computing the minimum version (used to use newer metadata version after a snapshot delete)

Returns:

minimum node version that must still be able to read the repository metadata

useShardGenerations

public static boolean useShardGenerations(Version repositoryMetaVersion)

Checks whether the metadata version supports writing ShardGenerations to the repository.

Parameters:

repositoryMetaVersion - version to check

Returns:

true if version supports ShardGenerations

snapshottingIndices

public static java.util.Set<Index> snapshottingIndices(ClusterState currentState, java.util.Set<Index> indicesToCheck)

Returns the indices that are currently being snapshotted (with partial == false) and that are contained in the indices-to-check set.

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent

assertAllListenersResolved

public boolean assertAllListenersResolved()

Assert that no in-memory state for any running snapshot operation exists in this instance.