Package org.elasticsearch.gateway

Class GatewayAllocator

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.gateway.GatewayAllocator

public class GatewayAllocator
extends AbstractComponent

Field Summary

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GatewayAllocator(Settings settings)
	GatewayAllocator(Settings settings, ClusterService clusterService, RoutingService routingService, TransportNodesListGatewayStartedShards startedAction, TransportNodesListShardStoreMetaData storeAction)

Method Summary

Modifier and Type	Method	Description
void	allocateUnassigned(RoutingAllocation allocation)
void	applyFailedShards(RoutingAllocation allocation, java.util.List<FailedShard> failedShards)
void	applyStartedShards(RoutingAllocation allocation, java.util.List<ShardRouting> startedShards)
AllocateUnassignedDecision	decideUnassignedShardAllocation(ShardRouting unassignedShard, RoutingAllocation routingAllocation)	Computes and returns the design for allocating a single unassigned shard.
int	getNumberOfInFlightFetch()
protected static void	innerAllocatedUnassigned(RoutingAllocation allocation, PrimaryShardAllocator primaryShardAllocator, ReplicaShardAllocator replicaShardAllocator)

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

GatewayAllocator

@Inject
public GatewayAllocator(Settings settings,
                        ClusterService clusterService,
                        RoutingService routingService,
                        TransportNodesListGatewayStartedShards startedAction,
                        TransportNodesListShardStoreMetaData storeAction)

GatewayAllocator

protected GatewayAllocator(Settings settings)

Method Detail

getNumberOfInFlightFetch

public int getNumberOfInFlightFetch()

applyStartedShards

public void applyStartedShards(RoutingAllocation allocation,
                               java.util.List<ShardRouting> startedShards)

applyFailedShards

public void applyFailedShards(RoutingAllocation allocation,
                              java.util.List<FailedShard> failedShards)

allocateUnassigned

public void allocateUnassigned(RoutingAllocation allocation)

innerAllocatedUnassigned

protected static void innerAllocatedUnassigned(RoutingAllocation allocation,
                                               PrimaryShardAllocator primaryShardAllocator,
                                               ReplicaShardAllocator replicaShardAllocator)

decideUnassignedShardAllocation

public AllocateUnassignedDecision decideUnassignedShardAllocation(ShardRouting unassignedShard,
                                                                  RoutingAllocation routingAllocation)

Computes and returns the design for allocating a single unassigned shard. If called on an assigned shard, AllocateUnassignedDecision.NOT_TAKEN is returned.