public abstract static class Canary.Monitor
extends java.lang.Object
implements java.lang.Runnable, java.io.Closeable
Modifier and Type | Field and Description |
---|---|
protected Admin |
admin |
protected Connection |
connection |
protected boolean |
done |
protected int |
errorCode |
protected java.util.concurrent.ExecutorService |
executor |
protected boolean |
initialized |
protected Canary.Sink |
sink |
protected java.lang.String[] |
targets |
protected boolean |
treatFailureAsError |
protected boolean |
useRegExp |
Modifier | Constructor and Description |
---|---|
protected |
Monitor(Connection connection,
java.lang.String[] monitorTargets,
boolean useRegExp,
Canary.Sink sink,
java.util.concurrent.ExecutorService executor,
boolean treatFailureAsError) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
finalCheckForErrors() |
boolean |
hasError() |
protected boolean |
initAdmin() |
boolean |
isDone() |
abstract void |
run() |
protected Connection connection
protected Admin admin
protected java.lang.String[] targets
protected boolean useRegExp
protected boolean treatFailureAsError
protected boolean initialized
protected boolean done
protected int errorCode
protected Canary.Sink sink
protected java.util.concurrent.ExecutorService executor
protected Monitor(Connection connection, java.lang.String[] monitorTargets, boolean useRegExp, Canary.Sink sink, java.util.concurrent.ExecutorService executor, boolean treatFailureAsError)
public boolean isDone()
public boolean hasError()
public boolean finalCheckForErrors()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public abstract void run()
run
in interface java.lang.Runnable
protected boolean initAdmin()