private static class CanaryTool.ZookeeperMonitor extends CanaryTool.Monitor
Modifier and Type | Field and Description |
---|---|
private List<String> |
hosts |
private int |
timeout |
private String |
znode |
admin, allowedFailures, connection, done, errorCode, executor, initialized, sink, targets, treatFailureAsError, useRegExp
Modifier | Constructor and Description |
---|---|
protected |
ZookeeperMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean treatFailureAsError,
long allowedFailures) |
Modifier and Type | Method and Description |
---|---|
private CanaryTool.ZookeeperStdOutSink |
getSink() |
void |
run() |
close, finalCheckForErrors, hasError, initAdmin, isDone
private final int timeout
protected ZookeeperMonitor(Connection connection, String[] monitorTargets, boolean useRegExp, CanaryTool.Sink sink, ExecutorService executor, boolean treatFailureAsError, long allowedFailures)
public void run()
run
in interface Runnable
run
in class CanaryTool.Monitor
private CanaryTool.ZookeeperStdOutSink getSink()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.