org.apache.hadoop.hbase.chaos.monkies

Class PolicyBasedChaosMonkey

java.lang.Object

org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey

org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey

All Implemented Interfaces:

org.apache.hadoop.hbase.Stoppable

public class PolicyBasedChaosMonkey
extends ChaosMonkey

Chaos monkey that given multiple policies will run actions against the cluster.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
(package private) Properties	monkeyProps
private ExecutorService	monkeyThreadPool
private static long	ONE_MIN
private static long	ONE_SEC
private Policy[]	policies
static long	TIMEOUT
(package private) IntegrationTestingUtility	util

Constructor Summary

Constructors

Constructor and Description
PolicyBasedChaosMonkey(IntegrationTestingUtility util, Collection<Policy> policies)
PolicyBasedChaosMonkey(IntegrationTestingUtility util, Policy... policies) Construct a new ChaosMonkey
PolicyBasedChaosMonkey(Properties monkeyProps, IntegrationTestingUtility util, Collection<Policy> policies)
PolicyBasedChaosMonkey(Properties monkeyProps, IntegrationTestingUtility util, Policy... policies)

Method Summary

Modifier and Type	Method and Description
private static ExecutorService	buildMonkeyThreadPool(int size)
boolean	isDestructive() Returns whether the CM does destructive actions (killing servers) so that a cluster restore is needed after CM is stopped.
boolean	isStopped()
static <T> T	selectRandomItem(T[] items) Selects a random item from the given items
static <T> List<T>	selectRandomItems(T[] items, float ratio) Selects and returns ceil(ratio * items.length) random items from the given array
static <T> T	selectWeightedRandomItem(List<org.apache.hadoop.hbase.util.Pair<T,Integer>> items) Selects a random item from the given items with weights
void	start()
void	stop(String why)
void	waitForStop()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

ONE_SEC

private static final long ONE_SEC

See Also:

Constant Field Values

ONE_MIN

private static final long ONE_MIN

See Also:

Constant Field Values

TIMEOUT

public static final long TIMEOUT

See Also:

Constant Field Values

util

final IntegrationTestingUtility util

monkeyProps

final Properties monkeyProps

policies

private final Policy[] policies

monkeyThreadPool

private final ExecutorService monkeyThreadPool

Constructor Detail

PolicyBasedChaosMonkey

public PolicyBasedChaosMonkey(IntegrationTestingUtility util,
                              Policy... policies)

Construct a new ChaosMonkey

Parameters:

util - the HBaseIntegrationTestingUtility already configured

policies - custom policies to use

PolicyBasedChaosMonkey

public PolicyBasedChaosMonkey(IntegrationTestingUtility util,
                              Collection<Policy> policies)

PolicyBasedChaosMonkey

public PolicyBasedChaosMonkey(Properties monkeyProps,
                              IntegrationTestingUtility util,
                              Collection<Policy> policies)

PolicyBasedChaosMonkey

public PolicyBasedChaosMonkey(Properties monkeyProps,
                              IntegrationTestingUtility util,
                              Policy... policies)

Method Detail

buildMonkeyThreadPool

private static ExecutorService buildMonkeyThreadPool(int size)

selectRandomItem

public static <T> T selectRandomItem(T[] items)

Selects a random item from the given items

selectWeightedRandomItem

public static <T> T selectWeightedRandomItem(List<org.apache.hadoop.hbase.util.Pair<T,Integer>> items)

Selects a random item from the given items with weights

selectRandomItems

public static <T> List<T> selectRandomItems(T[] items,
                                            float ratio)

Selects and returns ceil(ratio * items.length) random items from the given array

start

public void start()
           throws Exception

Specified by:

start in class ChaosMonkey

Throws:

Exception

stop

public void stop(String why)

Specified by:

stop in interface org.apache.hadoop.hbase.Stoppable

Specified by:

stop in class ChaosMonkey

isStopped

public boolean isStopped()

Specified by:

isStopped in interface org.apache.hadoop.hbase.Stoppable

Specified by:

isStopped in class ChaosMonkey

waitForStop

public void waitForStop()
                 throws InterruptedException

Specified by:

waitForStop in class ChaosMonkey

Throws:

InterruptedException

isDestructive

public boolean isDestructive()

Description copied from class: ChaosMonkey

Returns whether the CM does destructive actions (killing servers) so that a cluster restore is needed after CM is stopped. Otherwise cluster will be left as it is

Specified by:

isDestructive in class ChaosMonkey