public class LocalGateway extends AbstractLifecycleComponent<Gateway> implements Gateway, ClusterStateListener
Gateway.GatewayStateRecoveredListener
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
LocalGateway(Settings settings,
ClusterService clusterService,
NodeEnvironment nodeEnv,
LocalGatewayShardsState shardsState,
LocalGatewayMetaState metaState,
TransportNodesListGatewayMetaState listGatewayMetaState,
ClusterName clusterName) |
Modifier and Type | Method and Description |
---|---|
void |
clusterChanged(ClusterChangedEvent event)
Called when cluster state changes.
|
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
void |
performStateRecovery(Gateway.GatewayStateRecoveredListener listener) |
void |
reset() |
Class<? extends Module> |
suggestIndexGateway() |
String |
type() |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
close
@Inject public LocalGateway(Settings settings, ClusterService clusterService, NodeEnvironment nodeEnv, LocalGatewayShardsState shardsState, LocalGatewayMetaState metaState, TransportNodesListGatewayMetaState listGatewayMetaState, ClusterName clusterName)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<Gateway>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<Gateway>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<Gateway>
ElasticsearchException
public void performStateRecovery(Gateway.GatewayStateRecoveredListener listener) throws GatewayException
performStateRecovery
in interface Gateway
GatewayException
public Class<? extends Module> suggestIndexGateway()
suggestIndexGateway
in interface Gateway
public void reset() throws Exception
public void clusterChanged(ClusterChangedEvent event)
ClusterStateListener
clusterChanged
in interface ClusterStateListener
Copyright © 2009–2015. All rights reserved.