org.apache.hadoop.hbase.tool

Class Canary.ZookeeperMonitor

java.lang.Object

org.apache.hadoop.hbase.tool.Canary.Monitor

org.apache.hadoop.hbase.tool.Canary.ZookeeperMonitor

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

Enclosing class:

Canary

private static class Canary.ZookeeperMonitor
extends Canary.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.Canary.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, Canary.Sink sink, ExecutorService executor, boolean treatFailureAsError, long allowedFailures)

Method Summary

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

Methods inherited from class org.apache.hadoop.hbase.tool.Canary.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,
                           Canary.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 Canary.Monitor

getSink

private Canary.ZookeeperStdOutSink getSink()