org.elasticsearch.gateway.local.state.shards
Class LocalGatewayShardsState

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.gateway.local.state.shards.LocalGatewayShardsState

All Implemented Interfaces:

ClusterStateListener

public class LocalGatewayShardsState
extends AbstractComponent
implements ClusterStateListener

Field Summary

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

componentSettings, logger, settings

Constructor Summary

LocalGatewayShardsState(Settings settings, NodeEnvironment nodeEnv, TransportNodesListGatewayStartedShards listGatewayStartedShards, LocalGatewayMetaState metaState)

Method Summary

void	clusterChanged(ClusterChangedEvent event) Called when cluster state changes.
Map<ShardId,ShardStateInfo>	currentStartedShards()
ShardStateInfo	loadShardInfo(ShardId shardId)

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

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalGatewayShardsState

@Inject
public LocalGatewayShardsState(Settings settings,
                                      NodeEnvironment nodeEnv,
                                      TransportNodesListGatewayStartedShards listGatewayStartedShards,
                                      LocalGatewayMetaState metaState)
                        throws Exception

Throws:

Exception

Method Detail

currentStartedShards

public Map<ShardId,ShardStateInfo> currentStartedShards()

loadShardInfo

public ShardStateInfo loadShardInfo(ShardId shardId)
                             throws Exception

Throws:

Exception

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Specified by:

clusterChanged in interface ClusterStateListener