Package org.apache.hadoop.hbase

Class ChaosZKClient

java.lang.Object

org.apache.hadoop.hbase.ChaosZKClient

@Private
public class ChaosZKClient
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	CHAOS_AGENT_PARENT_ZNODE
private static final String	CHAOS_AGENT_STATUS_ZNODE
private static final String	CONNECTION_LOSS
(package private) org.apache.zookeeper.AsyncCallback.DataCallback	getStatusCallback
private static final org.slf4j.Logger	LOG
private final String	quorum
private static final 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 final String	TASK_BOOLEAN_FALSE
private static final String	TASK_BOOLEAN_TRUE
private static final String	TASK_COMPLETION_STRING
private static final String	TASK_ERROR_STRING
private static final int	TASK_EXECUTION_TIMEOUT
private static final String	TASK_PREFIX
(package private) org.apache.zookeeper.AsyncCallback.VoidCallback	taskDeleteCallback
private String	taskStatus
private org.apache.zookeeper.ZooKeeper	zk
private static final String	ZNODE_PATH_SEPARATOR

Constructor Summary

Constructors

Constructor	Description
ChaosZKClient(String quorum)

Method Summary

Modifier and Type	Method	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 Details

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 Details

ChaosZKClient

public ChaosZKClient(String quorum)

Method Details

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()