java.io.Closeable
, java.lang.AutoCloseable
, ClusterStateListener
, LifecycleComponent
, Releasable
public class GatewayService extends AbstractLifecycleComponent implements ClusterStateListener
Modifier and Type | Field | Description |
---|---|---|
static TimeValue |
DEFAULT_RECOVER_AFTER_TIME_IF_EXPECTED_NODES_IS_SET |
|
static Setting<java.lang.Integer> |
EXPECTED_DATA_NODES_SETTING |
|
static Setting<java.lang.Integer> |
EXPECTED_MASTER_NODES_SETTING |
|
static Setting<java.lang.Integer> |
EXPECTED_NODES_SETTING |
|
static Setting<java.lang.Integer> |
RECOVER_AFTER_DATA_NODES_SETTING |
|
static Setting<java.lang.Integer> |
RECOVER_AFTER_MASTER_NODES_SETTING |
|
static Setting<java.lang.Integer> |
RECOVER_AFTER_NODES_SETTING |
|
static Setting<TimeValue> |
RECOVER_AFTER_TIME_SETTING |
|
static ClusterBlock |
STATE_NOT_RECOVERED_BLOCK |
deprecationLogger, logger, settings
lifecycle
Constructor | Description |
---|---|
GatewayService(Settings settings,
AllocationService allocationService,
ClusterService clusterService,
ThreadPool threadPool,
GatewayMetaState metaState,
TransportNodesListGatewayMetaState listGatewayMetaState,
IndicesService indicesService) |
Modifier and Type | Method | Description |
---|---|---|
void |
clusterChanged(ClusterChangedEvent event) |
Called when cluster state changes.
|
protected void |
doClose() |
|
protected void |
doStart() |
|
protected void |
doStop() |
|
TimeValue |
recoverAfterTime() |
logDeprecatedSetting, logRemovedSetting, nodeName
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
public static final Setting<java.lang.Integer> EXPECTED_NODES_SETTING
public static final Setting<java.lang.Integer> EXPECTED_DATA_NODES_SETTING
public static final Setting<java.lang.Integer> EXPECTED_MASTER_NODES_SETTING
public static final Setting<java.lang.Integer> RECOVER_AFTER_NODES_SETTING
public static final Setting<java.lang.Integer> RECOVER_AFTER_DATA_NODES_SETTING
public static final Setting<java.lang.Integer> RECOVER_AFTER_MASTER_NODES_SETTING
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, AllocationService allocationService, ClusterService clusterService, ThreadPool threadPool, GatewayMetaState metaState, TransportNodesListGatewayMetaState listGatewayMetaState, IndicesService indicesService)
protected void doStart()
doStart
in class AbstractLifecycleComponent
protected void doStop()
doStop
in class AbstractLifecycleComponent
protected void doClose()
doClose
in class AbstractLifecycleComponent
public void clusterChanged(ClusterChangedEvent event)
ClusterStateListener
clusterChanged
in interface ClusterStateListener
public TimeValue recoverAfterTime()