org.apache.hadoop.hbase

Class ChaosZKClient

java.lang.Object

org.apache.hadoop.hbase.ChaosZKClient

@InterfaceAudience.Private
public class ChaosZKClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	ChaosZKClient.TaskObject

Field Summary

Fields

Modifier and Type	Field and Description
private static String	CHAOS_AGENT_PARENT_ZNODE
private static String	CHAOS_AGENT_STATUS_ZNODE
private static String	CONNECTION_LOSS
(package private) org.apache.zookeeper.AsyncCallback.DataCallback	getStatusCallback
private static org.slf4j.Logger	LOG
private String	quorum
private static int	SESSION_TIMEOUT_ZK
(package private) org.apache.zookeeper.AsyncCallback.StatCallback	setStatusWatchCallback
(package private) org.apache.zookeeper.Watcher	setStatusWatcher Watcher to get notification whenever status of task changes.
(package private) org.apache.zookeeper.AsyncCallback.StringCallback	submitTaskCallback
private static String	TASK_BOOLEAN_FALSE
private static String	TASK_BOOLEAN_TRUE
private static String	TASK_COMPLETION_STRING
private static String	TASK_ERROR_STRING
private static int	TASK_EXECUTION_TIMEOUT
private static String	TASK_PREFIX
(package private) org.apache.zookeeper.AsyncCallback.VoidCallback	taskDeleteCallback
private String	taskStatus
private org.apache.zookeeper.ZooKeeper	zk
private static String	ZNODE_PATH_SEPARATOR

Constructor Summary

Constructors

Constructor and Description
ChaosZKClient(String quorum)

Method Summary

Modifier and Type	Method and Description
void	createNewZKConnection() Creates connection with ZooKeeper
private void	deleteTask(String path) Delete task after getting its status
private void	getStatus(String path, Object ctx) To get status of task submitted
private boolean	isChaosAgentRunning(String hostname) Checks if ChaosAgent is running or not on target host by checking its ZNode.
private void	recreateZKConnection()
private void	setStatusWatch(String name, ChaosZKClient.TaskObject taskObject) Set a watch on task submitted
String	submitTask(ChaosZKClient.TaskObject taskObject) Creates tasks for target hosts by creating ZNodes.

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

CHAOS_AGENT_PARENT_ZNODE

private static final String CHAOS_AGENT_PARENT_ZNODE

See Also:

Constant Field Values

CHAOS_AGENT_STATUS_ZNODE

private static final String CHAOS_AGENT_STATUS_ZNODE

See Also:

Constant Field Values

ZNODE_PATH_SEPARATOR

private static final String ZNODE_PATH_SEPARATOR

See Also:

Constant Field Values

TASK_PREFIX

private static final String TASK_PREFIX

See Also:

Constant Field Values

TASK_ERROR_STRING

private static final String TASK_ERROR_STRING

See Also:

Constant Field Values

TASK_COMPLETION_STRING

private static final String TASK_COMPLETION_STRING

See Also:

Constant Field Values

TASK_BOOLEAN_TRUE

private static final String TASK_BOOLEAN_TRUE

See Also:

Constant Field Values

TASK_BOOLEAN_FALSE

private static final String TASK_BOOLEAN_FALSE

See Also:

Constant Field Values

CONNECTION_LOSS

private static final String CONNECTION_LOSS

See Also:

Constant Field Values

SESSION_TIMEOUT_ZK

private static final int SESSION_TIMEOUT_ZK

See Also:

Constant Field Values

TASK_EXECUTION_TIMEOUT

private static final int TASK_EXECUTION_TIMEOUT

See Also:

Constant Field Values

taskStatus

private volatile String taskStatus

quorum

private final String quorum

zk

private org.apache.zookeeper.ZooKeeper zk

setStatusWatcher

org.apache.zookeeper.Watcher setStatusWatcher

Watcher to get notification whenever status of task changes.

getStatusCallback

org.apache.zookeeper.AsyncCallback.DataCallback getStatusCallback

setStatusWatchCallback

org.apache.zookeeper.AsyncCallback.StatCallback setStatusWatchCallback

submitTaskCallback

org.apache.zookeeper.AsyncCallback.StringCallback submitTaskCallback

taskDeleteCallback

org.apache.zookeeper.AsyncCallback.VoidCallback taskDeleteCallback

Constructor Detail

ChaosZKClient

public ChaosZKClient(String quorum)

Method Detail

createNewZKConnection

public void createNewZKConnection()
                           throws IOException

Creates connection with ZooKeeper

Throws:

IOException - when not able to create connection properly

isChaosAgentRunning

private boolean isChaosAgentRunning(String hostname)

Checks if ChaosAgent is running or not on target host by checking its ZNode.

Parameters:

hostname - hostname to check for chaosagent

Returns:

true/false whether agent is running or not

submitTask

public String submitTask(ChaosZKClient.TaskObject taskObject)

Creates tasks for target hosts by creating ZNodes. Waits for a limited amount of time to complete task to execute.

Parameters:

taskObject - Object data represents command

Returns:

returns status

getStatus

private void getStatus(String path,
                       Object ctx)

To get status of task submitted

Parameters:

path - path at which to get status

ctx - path context

setStatusWatch

private void setStatusWatch(String name,
                            ChaosZKClient.TaskObject taskObject)

Set a watch on task submitted

Parameters:

name - ZNode name to set a watch

taskObject - context for ZNode name

deleteTask

private void deleteTask(String path)

Delete task after getting its status

Parameters:

path - path to delete ZNode

recreateZKConnection

private void recreateZKConnection()