public class GatewayService extends AbstractLifecycleComponent<GatewayService> implements ClusterStateListener
Modifier and Type | Field and Description |
---|---|
static TimeValue |
DEFAULT_RECOVER_AFTER_TIME_IF_EXPECTED_NODES_IS_SET |
static ClusterBlock |
STATE_NOT_RECOVERED_BLOCK |
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
GatewayService(Settings settings,
Gateway gateway,
AllocationService allocationService,
ClusterService clusterService,
DiscoveryService discoveryService,
ThreadPool threadPool) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkStateMeetsSettingsAndMaybeRecover(ClusterState state,
boolean asyncRecovery) |
void |
clusterChanged(ClusterChangedEvent event)
Called when cluster state changes.
|
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
TimeValue |
recoverAfterTime() |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
public static final ClusterBlock STATE_NOT_RECOVERED_BLOCK
public static final TimeValue DEFAULT_RECOVER_AFTER_TIME_IF_EXPECTED_NODES_IS_SET
@Inject public GatewayService(Settings settings, Gateway gateway, AllocationService allocationService, ClusterService clusterService, DiscoveryService discoveryService, ThreadPool threadPool)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<GatewayService>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<GatewayService>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<GatewayService>
ElasticsearchException
public void clusterChanged(ClusterChangedEvent event)
ClusterStateListener
clusterChanged
in interface ClusterStateListener
protected void checkStateMeetsSettingsAndMaybeRecover(ClusterState state, boolean asyncRecovery)
public TimeValue recoverAfterTime()
Copyright © 2009–2015. All rights reserved.