Module org.elasticsearch.server

Package org.elasticsearch.repositories

Class InvalidRepository

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.repositories.InvalidRepository

All Implemented Interfaces:

Closeable, AutoCloseable, LifecycleComponent, Releasable, Repository

public class InvalidRepository
extends AbstractLifecycleComponent
implements Repository

Represents a repository that exists in the cluster state but could not be instantiated on a node, typically due to invalid configuration.

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

Constructor	Description
InvalidRepository(RepositoryMetadata repositoryMetadata, RepositoryException creationException)

Method Summary

Modifier and Type	Method	Description
void	awaitIdle()	Block until all in-flight operations for this repository have completed.
void	cloneShardSnapshot(SnapshotId source, SnapshotId target, RepositoryShardId shardId, ShardGeneration shardGeneration, ActionListener<ShardSnapshotResult> listener)	Clones a shard snapshot.
void	deleteSnapshots(Collection<SnapshotId> snapshotIds, long repositoryStateId, Version repositoryMetaVersion, SnapshotDeleteListener listener)	Deletes snapshots
protected void	doClose()
protected void	doStart()
protected void	doStop()
void	endVerification(String verificationToken)	Called at the end of repository verification process.
void	executeConsistentStateUpdate(Function<RepositoryData,ClusterStateUpdateTask> createUpdateTask, String source, Consumer<Exception> onFailure)	Execute a cluster state update with a consistent view of the current RepositoryData.
void	finalizeSnapshot(FinalizeSnapshotContext finalizeSnapshotContext)	Finalizes snapshotting process
RepositoryMetadata	getMetadata()	Returns metadata about this repository.
void	getRepositoryData(ActionListener<RepositoryData> listener)	Returns a RepositoryData to describe the data in the repository, including the snapshots and the indices across all snapshots found in the repository.
long	getRestoreThrottleTimeInNanos()	Returns restore throttle time in nanoseconds
IndexShardSnapshotStatus	getShardSnapshotStatus(SnapshotId snapshotId, IndexId indexId, ShardId shardId)	Retrieve shard snapshot status for the stored snapshot
Metadata	getSnapshotGlobalMetadata(SnapshotId snapshotId)	Returns global metadata associated with the snapshot.
IndexMetadata	getSnapshotIndexMetaData(RepositoryData repositoryData, SnapshotId snapshotId, IndexId index)	Returns the index metadata associated with the snapshot.
void	getSnapshotInfo(GetSnapshotInfoContext context)	Reads snapshot descriptions from the repository.
long	getSnapshotThrottleTimeInNanos()	Returns snapshot throttle time in nanoseconds
boolean	isReadOnly()	Returns true if the repository supports only read operations
void	restoreShard(Store store, SnapshotId snapshotId, IndexId indexId, ShardId snapshotShardId, RecoveryState recoveryState, ActionListener<Void> listener)	Restores snapshot of the shard.
void	snapshotShard(SnapshotShardContext snapshotShardContext)	Creates a snapshot of the shard referenced by the given SnapshotShardContext.
String	startVerification()	Verifies repository on the master node and returns the verification token.
void	updateState(ClusterState state)	Update the repository with the incoming cluster state.
void	verify(String verificationToken, DiscoveryNode localNode)	Verifies repository settings on data node.

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

addLifecycleListener, close, lifecycleState, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, start, stop

Methods inherited from interface org.elasticsearch.core.Releasable

close

Methods inherited from interface org.elasticsearch.repositories.Repository

adaptUserMetadata, canUpdateInPlace, getSnapshotInfo, stats

Constructor Details

InvalidRepository

public InvalidRepository(RepositoryMetadata repositoryMetadata,
 RepositoryException creationException)

Method Details

getMetadata

public RepositoryMetadata getMetadata()

Description copied from interface: Repository

Returns metadata about this repository.

Specified by:

getMetadata in interface Repository

getSnapshotInfo

public void getSnapshotInfo(GetSnapshotInfoContext context)

Description copied from interface: Repository

Reads snapshot descriptions from the repository.

Specified by:

getSnapshotInfo in interface Repository

Parameters:

context - get-snapshot-info-context

getSnapshotGlobalMetadata

public Metadata getSnapshotGlobalMetadata(SnapshotId snapshotId)

Description copied from interface: Repository

Returns global metadata associated with the snapshot.

Specified by:

getSnapshotGlobalMetadata in interface Repository

Parameters:

snapshotId - the snapshot id to load the global metadata from

Returns:

the global metadata about the snapshot

getSnapshotIndexMetaData

public IndexMetadata getSnapshotIndexMetaData(RepositoryData repositoryData,
 SnapshotId snapshotId,
 IndexId index)
                                       throws IOException

Description copied from interface: Repository

Returns the index metadata associated with the snapshot.

Specified by:

getSnapshotIndexMetaData in interface Repository

Parameters:

repositoryData - current RepositoryData

snapshotId - the snapshot id to load the index metadata from

index - the IndexId to load the metadata from

Returns:

the index metadata about the given index for the given snapshot

Throws:

IOException

getRepositoryData

public void getRepositoryData(ActionListener<RepositoryData> listener)

Description copied from interface: Repository

Returns a RepositoryData to describe the data in the repository, including the snapshots and the indices across all snapshots found in the repository. Throws a RepositoryException if there was an error in reading the data.

Specified by:

getRepositoryData in interface Repository

Parameters:

listener - listener that may be resolved on different kinds of threads including transport and cluster state applier threads and therefore must fork to a new thread for executing any long running actions

finalizeSnapshot

public void finalizeSnapshot(FinalizeSnapshotContext finalizeSnapshotContext)

Description copied from interface: Repository

Finalizes snapshotting process

This method is called on master after all shards are snapshotted.

Specified by:

finalizeSnapshot in interface Repository

Parameters:

finalizeSnapshotContext - finalization context

deleteSnapshots

public void deleteSnapshots(Collection<SnapshotId> snapshotIds,
 long repositoryStateId,
 Version repositoryMetaVersion,
 SnapshotDeleteListener listener)

Description copied from interface: Repository

Deletes snapshots

Specified by:

deleteSnapshots in interface Repository

Parameters:

snapshotIds - snapshot ids

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

repositoryMetaVersion - version of the updated repository metadata to write

listener - completion listener

getSnapshotThrottleTimeInNanos

public long getSnapshotThrottleTimeInNanos()

Description copied from interface: Repository

Returns snapshot throttle time in nanoseconds

Specified by:

getSnapshotThrottleTimeInNanos in interface Repository

getRestoreThrottleTimeInNanos

public long getRestoreThrottleTimeInNanos()

Description copied from interface: Repository

Returns restore throttle time in nanoseconds

Specified by:

getRestoreThrottleTimeInNanos in interface Repository

startVerification

public String startVerification()

Description copied from interface: Repository

Verifies repository on the master node and returns the verification token.

If the verification token is not null, it's passed to all data nodes for verification. If it's null - no additional verification is required

Specified by:

startVerification in interface Repository

Returns:

verification token that should be passed to all Index Shard Repositories for additional verification or null

endVerification

public void endVerification(String verificationToken)

Description copied from interface: Repository

Called at the end of repository verification process.

This method should perform all necessary cleanup of the temporary files created in the repository

Specified by:

endVerification in interface Repository

Parameters:

verificationToken - verification request generated by Repository.startVerification() command

verify

public void verify(String verificationToken,
 DiscoveryNode localNode)

Description copied from interface: Repository

Verifies repository settings on data node.

Specified by:

verify in interface Repository

Parameters:

verificationToken - value returned by Repository.startVerification()

localNode - the local node information, for inclusion in verification errors

isReadOnly

public boolean isReadOnly()

Description copied from interface: Repository

Returns true if the repository supports only read operations

Specified by:

isReadOnly in interface Repository

Returns:

true if the repository is read/only

snapshotShard

public void snapshotShard(SnapshotShardContext snapshotShardContext)

Description copied from interface: Repository

Creates a snapshot of the shard referenced by the given SnapshotShardContext.

As snapshot process progresses, implementation of this method should update IndexShardSnapshotStatus object returned by SnapshotShardContext.status() and check its IndexShardSnapshotStatus.isAborted() to see if the snapshot process should be aborted.

Specified by:

snapshotShard in interface Repository

Parameters:

snapshotShardContext - snapshot shard context that must be completed via SnapshotShardContext.onResponse(org.elasticsearch.repositories.ShardSnapshotResult) or ActionListener.Delegating.onFailure(java.lang.Exception)

restoreShard

public void restoreShard(Store store,
 SnapshotId snapshotId,
 IndexId indexId,
 ShardId snapshotShardId,
 RecoveryState recoveryState,
 ActionListener<Void> listener)

Description copied from interface: Repository

Restores snapshot of the shard.

The index can be renamed on restore, hence different shardId and snapshotShardId are supplied.

Specified by:

restoreShard in interface Repository

Parameters:

store - the store to restore the index into

snapshotId - snapshot id

indexId - id of the index in the repository from which the restore is occurring

snapshotShardId - shard id (in the snapshot)

recoveryState - recovery state

listener - listener to invoke once done

getShardSnapshotStatus

public IndexShardSnapshotStatus getShardSnapshotStatus(SnapshotId snapshotId,
 IndexId indexId,
 ShardId shardId)

Description copied from interface: Repository

Retrieve shard snapshot status for the stored snapshot

Specified by:

getShardSnapshotStatus in interface Repository

Parameters:

snapshotId - snapshot id

indexId - the snapshotted index id for the shard to get status for

shardId - shard id

Returns:

snapshot status

updateState

public void updateState(ClusterState state)

Description copied from interface: Repository

Update the repository with the incoming cluster state. This method is invoked from RepositoriesService.applyClusterState(org.elasticsearch.cluster.ClusterChangedEvent) and thus the same semantics as with ClusterStateApplier.applyClusterState(org.elasticsearch.cluster.ClusterChangedEvent) apply for the ClusterState that is passed here.

Specified by:

updateState in interface Repository

Parameters:

state - new cluster state

executeConsistentStateUpdate

public void executeConsistentStateUpdate(Function<RepositoryData,ClusterStateUpdateTask> createUpdateTask,
 String source,
 Consumer<Exception> onFailure)

Description copied from interface: Repository

Execute a cluster state update with a consistent view of the current RepositoryData. The ClusterState passed to the task generated through createUpdateTask is guaranteed to point at the same state for this repository as the did the state at the time the RepositoryData was loaded. This allows for operations on the repository that need a consistent view of both the cluster state and the repository contents at one point in time like for example, checking if a snapshot is in the repository before adding the delete operation for it to the cluster state.

Specified by:

executeConsistentStateUpdate in interface Repository

Parameters:

createUpdateTask - function to supply cluster state update task

source - the source of the cluster state update task

onFailure - error handler invoked on failure to get a consistent view of the current RepositoryData

cloneShardSnapshot

public void cloneShardSnapshot(SnapshotId source,
 SnapshotId target,
 RepositoryShardId shardId,
 ShardGeneration shardGeneration,
 ActionListener<ShardSnapshotResult> listener)

Description copied from interface: Repository

Clones a shard snapshot.

Specified by:

cloneShardSnapshot in interface Repository

Parameters:

source - source snapshot

target - target snapshot

shardId - shard id

shardGeneration - shard generation in repo

listener - listener to complete with new shard generation once clone has completed

awaitIdle

public void awaitIdle()

Description copied from interface: Repository

Block until all in-flight operations for this repository have completed. Must only be called after this instance has been closed by a call to stop Releasable.close(). Waiting for ongoing operations should be implemented here instead of in LifecycleComponent.stop() or Releasable.close() hooks of this interface as these are expected to be called on the cluster state applier thread (which must not block) if a repository is removed from the cluster. This method is intended to be called on node shutdown instead as a means to ensure no repository operations are leaked.

Specified by:

awaitIdle in interface Repository

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class AbstractLifecycleComponent

Throws:

IOException