org.elasticsearch.gateway.blobstore
Class BlobStoreGateway

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.common.component.AbstractLifecycleComponent<Gateway>
          org.elasticsearch.gateway.shared.SharedStorageGateway
              org.elasticsearch.gateway.blobstore.BlobStoreGateway

All Implemented Interfaces:

ClusterStateListener, CloseableComponent, LifecycleComponent<Gateway>, Gateway

Direct Known Subclasses:

FsGateway

public abstract class BlobStoreGateway
extends SharedStorageGateway

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.gateway.Gateway

Gateway.GatewayStateRecoveredListener

Field Summary

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

lifecycle

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

componentSettings, logger, settings

Constructor Summary

protected

BlobStoreGateway(Settings settings, ThreadPool threadPool, ClusterService clusterService)

Method Summary

BlobPath	basePath()
BlobStore	blobStore()
ByteSizeValue	chunkSize()
protected void	delete(IndexMetaData indexMetaData)
CommitPoint	findCommitPoint(String index, int shardId)
protected void	initialize(BlobStore blobStore, ClusterName clusterName, ByteSizeValue defaultChunkSize)
MetaData	read()
void	reset()
String	toString()
void	write(MetaData metaData)

Methods inherited from class org.elasticsearch.gateway.shared.SharedStorageGateway

clusterChanged, doClose, doStart, doStop, performStateRecovery, setNodeEnv

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

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

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

nodeName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.gateway.Gateway

suggestIndexGateway, type

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

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

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

close

Constructor Detail

BlobStoreGateway

protected BlobStoreGateway(Settings settings,
                           ThreadPool threadPool,
                           ClusterService clusterService)

Method Detail

initialize

protected void initialize(BlobStore blobStore,
                          ClusterName clusterName,
                          @Nullable
                          ByteSizeValue defaultChunkSize)
                   throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

blobStore

public BlobStore blobStore()

basePath

public BlobPath basePath()

chunkSize

public ByteSizeValue chunkSize()

reset

public void reset()
           throws Exception

Throws:

Exception

read

public MetaData read()
              throws GatewayException

Specified by:

read in class SharedStorageGateway

Throws:

GatewayException

findCommitPoint

public CommitPoint findCommitPoint(String index,
                                   int shardId)
                            throws IOException

Throws:

IOException

delete

protected void delete(IndexMetaData indexMetaData)
               throws ElasticSearchException

Specified by:

delete in class SharedStorageGateway

Throws:

ElasticSearchException

write

public void write(MetaData metaData)
           throws GatewayException

Specified by:

write in class SharedStorageGateway

Throws:

GatewayException