Package org.elasticsearch.cluster

Class ESAllocationTestCase.DelayedShardsMockGatewayAllocator

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.gateway.GatewayAllocator

org.elasticsearch.cluster.ESAllocationTestCase.DelayedShardsMockGatewayAllocator

Enclosing class:

ESAllocationTestCase

protected static class ESAllocationTestCase.DelayedShardsMockGatewayAllocator
extends GatewayAllocator

Mocks behavior in ReplicaShardAllocator to remove delayed shards from list of unassigned shards so they don't get reassigned yet.

Field Summary

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
DelayedShardsMockGatewayAllocator()

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)

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.gateway.GatewayAllocator

decideUnassignedShardAllocation, getNumberOfInFlightFetch, innerAllocatedUnassigned

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DelayedShardsMockGatewayAllocator

public DelayedShardsMockGatewayAllocator()

Method Detail

applyStartedShards

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

Overrides:

applyStartedShards in class GatewayAllocator

applyFailedShards

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

Overrides:

applyFailedShards in class GatewayAllocator

allocateUnassigned

public void allocateUnassigned(RoutingAllocation allocation)

Overrides:

allocateUnassigned in class GatewayAllocator