Class SingleNodeDisruption

java.lang.Object

org.opensearch.test.disruption.SingleNodeDisruption

All Implemented Interfaces:

ServiceDisruptionScheme

Direct Known Subclasses:

BlockClusterManagerServiceOnClusterManager, BlockClusterStateProcessing, BusyClusterManagerServiceDisruption, LongGCDisruption, SlowClusterStateProcessing

public abstract class SingleNodeDisruption
extends Object
implements ServiceDisruptionScheme

Field Summary

Fields

Modifier and Type	Field	Description
protected InternalTestCluster	cluster
protected String	disruptedNode
protected final org.apache.logging.log4j.Logger	logger
protected final Random	random

Constructor Summary

Constructors

Constructor	Description
SingleNodeDisruption(Random random)

Method Summary

Modifier and Type	Method	Description
void	applyToCluster(InternalTestCluster cluster)
void	applyToNode(String node, InternalTestCluster cluster)
protected void	ensureNodeCount(InternalTestCluster cluster)
void	removeFromCluster(InternalTestCluster cluster)
void	removeFromNode(String node, InternalTestCluster cluster)
void	testClusterClosed()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opensearch.test.disruption.ServiceDisruptionScheme

expectedTimeToHeal, removeAndEnsureHealthy, startDisrupting, stopDisrupting

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

disruptedNode

protected volatile String disruptedNode

cluster

protected volatile InternalTestCluster cluster

random

protected final Random random

Constructor Details

SingleNodeDisruption

public SingleNodeDisruption(Random random)

Method Details

applyToCluster

public void applyToCluster(InternalTestCluster cluster)

Specified by:

applyToCluster in interface ServiceDisruptionScheme

removeFromCluster

public void removeFromCluster(InternalTestCluster cluster)

Specified by:

removeFromCluster in interface ServiceDisruptionScheme

applyToNode

public void applyToNode(String node,
 InternalTestCluster cluster)

Specified by:

applyToNode in interface ServiceDisruptionScheme

removeFromNode

public void removeFromNode(String node,
 InternalTestCluster cluster)

Specified by:

removeFromNode in interface ServiceDisruptionScheme

testClusterClosed

public void testClusterClosed()

Specified by:

testClusterClosed in interface ServiceDisruptionScheme

ensureNodeCount

protected void ensureNodeCount(InternalTestCluster cluster)