public class LocalGatewayAllocator extends AbstractComponent implements GatewayAllocator
Modifier and Type | Field and Description |
---|---|
static String |
INDEX_RECOVERY_INITIAL_SHARDS |
componentSettings, logger, settings
Constructor and Description |
---|
LocalGatewayAllocator(Settings settings,
TransportNodesListGatewayStartedShards startedAction,
TransportNodesListShardStoreMetaData storeAction) |
Modifier and Type | Method and Description |
---|---|
boolean |
allocateUnassigned(RoutingAllocation allocation) |
void |
applyFailedShards(FailedRerouteAllocation allocation) |
void |
applyStartedShards(StartedRerouteAllocation allocation)
Apply all shards
|
int |
getNumberOfInFlightFetch() |
void |
setReallocation(ClusterService clusterService,
RoutingService routingService) |
nodeName
public static final String INDEX_RECOVERY_INITIAL_SHARDS
@Inject public LocalGatewayAllocator(Settings settings, TransportNodesListGatewayStartedShards startedAction, TransportNodesListShardStoreMetaData storeAction)
public void setReallocation(ClusterService clusterService, RoutingService routingService)
public int getNumberOfInFlightFetch()
public void applyStartedShards(StartedRerouteAllocation allocation)
GatewayAllocator
applyStartedShards
in interface GatewayAllocator
public void applyFailedShards(FailedRerouteAllocation allocation)
applyFailedShards
in interface GatewayAllocator
public boolean allocateUnassigned(RoutingAllocation allocation)
allocateUnassigned
in interface GatewayAllocator
Copyright © 2009–2016. All rights reserved.