Package org.opensearch.index.shard

Class RestoreOnlyRepository

java.lang.Object
org.opensearch.common.component.AbstractLifecycleComponent
org.opensearch.index.shard.RestoreOnlyRepository
All Implemented Interfaces:
java.io.Closeable, java.lang.AutoCloseable, org.opensearch.common.component.LifecycleComponent, org.opensearch.common.lease.Releasable, org.opensearch.repositories.Repository
public abstract class RestoreOnlyRepository
extends org.opensearch.common.component.AbstractLifecycleComponent
implements org.opensearch.repositories.Repository
A dummy repository for testing which just needs restore overridden

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.opensearch.repositories.Repository

    org.opensearch.repositories.Repository.Factory

  • Field Summary

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

    lifecycle

  • Constructor Summary

    Constructors 
    Constructor Description
    RestoreOnlyRepository​(java.lang.String indexName)  

  • Method Summary

    Modifier and Type Method Description
    void cloneShardSnapshot​(org.opensearch.snapshots.SnapshotId source, org.opensearch.snapshots.SnapshotId target, org.opensearch.repositories.RepositoryShardId repositoryShardId, java.lang.String shardGeneration, org.opensearch.action.ActionListener<java.lang.String> listener)  
    void deleteSnapshots​(java.util.Collection<org.opensearch.snapshots.SnapshotId> snapshotIds, long repositoryStateId, org.opensearch.Version repositoryMetaVersion, org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)  
    protected void doClose()  
    protected void doStart()  
    protected void doStop()  
    void endVerification​(java.lang.String verificationToken)  
    void executeConsistentStateUpdate​(java.util.function.Function<org.opensearch.repositories.RepositoryData,​org.opensearch.cluster.ClusterStateUpdateTask> createUpdateTask, java.lang.String source, java.util.function.Consumer<java.lang.Exception> onFailure)  
    void finalizeSnapshot​(org.opensearch.repositories.ShardGenerations shardGenerations, long repositoryStateId, org.opensearch.cluster.metadata.Metadata clusterMetadata, org.opensearch.snapshots.SnapshotInfo snapshotInfo, org.opensearch.Version repositoryMetaVersion, java.util.function.Function<org.opensearch.cluster.ClusterState,​org.opensearch.cluster.ClusterState> stateTransformer, org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)  
    org.opensearch.cluster.metadata.RepositoryMetadata getMetadata()  
    void getRepositoryData​(org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)  
    long getRestoreThrottleTimeInNanos()  
    org.opensearch.index.snapshots.IndexShardSnapshotStatus getShardSnapshotStatus​(org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId indexId, org.opensearch.index.shard.ShardId shardId)  
    org.opensearch.cluster.metadata.Metadata getSnapshotGlobalMetadata​(org.opensearch.snapshots.SnapshotId snapshotId)  
    org.opensearch.cluster.metadata.IndexMetadata getSnapshotIndexMetaData​(org.opensearch.repositories.RepositoryData repositoryData, org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId index)  
    org.opensearch.snapshots.SnapshotInfo getSnapshotInfo​(org.opensearch.snapshots.SnapshotId snapshotId)  
    long getSnapshotThrottleTimeInNanos()  
    void initializeSnapshot​(org.opensearch.snapshots.SnapshotId snapshotId, java.util.List<org.opensearch.repositories.IndexId> indices, org.opensearch.cluster.metadata.Metadata metadata)  
    boolean isReadOnly()  
    void snapshotShard​(org.opensearch.index.store.Store store, org.opensearch.index.mapper.MapperService mapperService, org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId indexId, org.apache.lucene.index.IndexCommit snapshotIndexCommit, java.lang.String shardStateIdentifier, org.opensearch.index.snapshots.IndexShardSnapshotStatus snapshotStatus, org.opensearch.Version repositoryMetaVersion, java.util.Map<java.lang.String,​java.lang.Object> userMetadata, org.opensearch.action.ActionListener<java.lang.String> listener)  
    java.lang.String startVerification()  
    void updateState​(org.opensearch.cluster.ClusterState state)  
    void verify​(java.lang.String verificationToken, org.opensearch.cluster.node.DiscoveryNode localNode)  

    Methods inherited from class org.opensearch.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

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

    addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

    Methods inherited from interface org.opensearch.common.lease.Releasable

    close

    Methods inherited from interface org.opensearch.repositories.Repository

    adaptUserMetadata, restoreShard, stats

  • Constructor Details

  • Method Details

    • doStart

      protected void doStart()
      Specified by:
      doStart in class org.opensearch.common.component.AbstractLifecycleComponent

    • doStop

      protected void doStop()
      Specified by:
      doStop in class org.opensearch.common.component.AbstractLifecycleComponent

    • doClose

      protected void doClose()
      Specified by:
      doClose in class org.opensearch.common.component.AbstractLifecycleComponent

    • getMetadata

      public org.opensearch.cluster.metadata.RepositoryMetadata getMetadata()
      Specified by:
      getMetadata in interface org.opensearch.repositories.Repository

    • getSnapshotInfo

      public org.opensearch.snapshots.SnapshotInfo getSnapshotInfo​(org.opensearch.snapshots.SnapshotId snapshotId)
      Specified by:
      getSnapshotInfo in interface org.opensearch.repositories.Repository

    • getSnapshotGlobalMetadata

      public org.opensearch.cluster.metadata.Metadata getSnapshotGlobalMetadata​(org.opensearch.snapshots.SnapshotId snapshotId)
      Specified by:
      getSnapshotGlobalMetadata in interface org.opensearch.repositories.Repository

    • getSnapshotIndexMetaData

      public org.opensearch.cluster.metadata.IndexMetadata getSnapshotIndexMetaData​(org.opensearch.repositories.RepositoryData repositoryData, org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId index)
      Specified by:
      getSnapshotIndexMetaData in interface org.opensearch.repositories.Repository

    • getRepositoryData

      public void getRepositoryData​(org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)
      Specified by:
      getRepositoryData in interface org.opensearch.repositories.Repository

    • initializeSnapshot

      public void initializeSnapshot​(org.opensearch.snapshots.SnapshotId snapshotId, java.util.List<org.opensearch.repositories.IndexId> indices, org.opensearch.cluster.metadata.Metadata metadata)
      Specified by:
      initializeSnapshot in interface org.opensearch.repositories.Repository

    • finalizeSnapshot

      public void finalizeSnapshot​(org.opensearch.repositories.ShardGenerations shardGenerations, long repositoryStateId, org.opensearch.cluster.metadata.Metadata clusterMetadata, org.opensearch.snapshots.SnapshotInfo snapshotInfo, org.opensearch.Version repositoryMetaVersion, java.util.function.Function<org.opensearch.cluster.ClusterState,​org.opensearch.cluster.ClusterState> stateTransformer, org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)
      Specified by:
      finalizeSnapshot in interface org.opensearch.repositories.Repository

    • deleteSnapshots

      public void deleteSnapshots​(java.util.Collection<org.opensearch.snapshots.SnapshotId> snapshotIds, long repositoryStateId, org.opensearch.Version repositoryMetaVersion, org.opensearch.action.ActionListener<org.opensearch.repositories.RepositoryData> listener)
      Specified by:
      deleteSnapshots in interface org.opensearch.repositories.Repository

    • getSnapshotThrottleTimeInNanos

      public long getSnapshotThrottleTimeInNanos()
      Specified by:
      getSnapshotThrottleTimeInNanos in interface org.opensearch.repositories.Repository

    • getRestoreThrottleTimeInNanos

      public long getRestoreThrottleTimeInNanos()
      Specified by:
      getRestoreThrottleTimeInNanos in interface org.opensearch.repositories.Repository

    • startVerification

      public java.lang.String startVerification()
      Specified by:
      startVerification in interface org.opensearch.repositories.Repository

    • endVerification

      public void endVerification​(java.lang.String verificationToken)
      Specified by:
      endVerification in interface org.opensearch.repositories.Repository

    • isReadOnly

      public boolean isReadOnly()
      Specified by:
      isReadOnly in interface org.opensearch.repositories.Repository

    • snapshotShard

      public void snapshotShard​(org.opensearch.index.store.Store store, org.opensearch.index.mapper.MapperService mapperService, org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId indexId, org.apache.lucene.index.IndexCommit snapshotIndexCommit, java.lang.String shardStateIdentifier, org.opensearch.index.snapshots.IndexShardSnapshotStatus snapshotStatus, org.opensearch.Version repositoryMetaVersion, java.util.Map<java.lang.String,​java.lang.Object> userMetadata, org.opensearch.action.ActionListener<java.lang.String> listener)
      Specified by:
      snapshotShard in interface org.opensearch.repositories.Repository

    • getShardSnapshotStatus

      public org.opensearch.index.snapshots.IndexShardSnapshotStatus getShardSnapshotStatus​(org.opensearch.snapshots.SnapshotId snapshotId, org.opensearch.repositories.IndexId indexId, org.opensearch.index.shard.ShardId shardId)
      Specified by:
      getShardSnapshotStatus in interface org.opensearch.repositories.Repository

    • verify

      public void verify​(java.lang.String verificationToken, org.opensearch.cluster.node.DiscoveryNode localNode)
      Specified by:
      verify in interface org.opensearch.repositories.Repository

    • updateState

      public void updateState​(org.opensearch.cluster.ClusterState state)
      Specified by:
      updateState in interface org.opensearch.repositories.Repository

    • executeConsistentStateUpdate

      public void executeConsistentStateUpdate​(java.util.function.Function<org.opensearch.repositories.RepositoryData,​org.opensearch.cluster.ClusterStateUpdateTask> createUpdateTask, java.lang.String source, java.util.function.Consumer<java.lang.Exception> onFailure)
      Specified by:
      executeConsistentStateUpdate in interface org.opensearch.repositories.Repository

    • cloneShardSnapshot

      public void cloneShardSnapshot​(org.opensearch.snapshots.SnapshotId source, org.opensearch.snapshots.SnapshotId target, org.opensearch.repositories.RepositoryShardId repositoryShardId, java.lang.String shardGeneration, org.opensearch.action.ActionListener<java.lang.String> listener)
      Specified by:
      cloneShardSnapshot in interface org.opensearch.repositories.Repository