org.apache.hadoop.hbase.tool

Class CanaryTool.ZookeeperMonitor

java.lang.Object

org.apache.hadoop.hbase.tool.CanaryTool.Monitor

org.apache.hadoop.hbase.tool.CanaryTool.ZookeeperMonitor

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

Enclosing class:

CanaryTool

private static class CanaryTool.ZookeeperMonitor
extends CanaryTool.Monitor

Field Summary

Fields

Modifier and Type	Field and Description
private List<String>	hosts
private int	timeout
private String	znode

Fields inherited from class org.apache.hadoop.hbase.tool.CanaryTool.Monitor

admin, allowedFailures, connection, done, errorCode, executor, initialized, sink, targets, treatFailureAsError, useRegExp

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ZookeeperMonitor(Connection connection, String[] monitorTargets, boolean useRegExp, CanaryTool.Sink sink, ExecutorService executor, boolean treatFailureAsError, long allowedFailures)

Method Summary

Modifier and Type	Method and Description
private CanaryTool.ZookeeperStdOutSink	getSink()
void	run()

Methods inherited from class org.apache.hadoop.hbase.tool.CanaryTool.Monitor

close, finalCheckForErrors, hasError, initAdmin, isDone

Methods inherited from class java.lang.Object

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

Field Detail

hosts

private List<String> hosts

znode

private final String znode

timeout

private final int timeout

Constructor Detail

ZookeeperMonitor

protected ZookeeperMonitor(Connection connection,
                           String[] monitorTargets,
                           boolean useRegExp,
                           CanaryTool.Sink sink,
                           ExecutorService executor,
                           boolean treatFailureAsError,
                           long allowedFailures)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class CanaryTool.Monitor

getSink

private CanaryTool.ZookeeperStdOutSink getSink()