public final class Canary
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Canary.Monitor |
static class |
Canary.RegionServerStdOutSink |
static class |
Canary.RegionStdOutSink |
static interface |
Canary.Sink |
static class |
Canary.StdOutSink |
static class |
Canary.ZookeeperStdOutSink |
Modifier and Type | Field and Description |
---|---|
static TableName |
DEFAULT_WRITE_TABLE_NAME |
Constructor and Description |
---|
Canary() |
Canary(java.util.concurrent.ExecutorService executor,
Canary.Sink sink) |
Modifier and Type | Method and Description |
---|---|
Configuration |
getConf() |
java.util.Map<java.lang.String,java.lang.String> |
getReadFailures() |
java.util.Map<java.lang.String,java.lang.String> |
getWriteFailures() |
static void |
main(java.lang.String[] args) |
Canary.Monitor |
newMonitor(Connection connection,
int index,
java.lang.String[] args)
A Factory method for
Canary.Monitor . |
int |
run(java.lang.String[] args) |
void |
setConf(Configuration conf) |
public Canary()
public Canary(java.util.concurrent.ExecutorService executor, Canary.Sink sink)
public Configuration getConf()
public void setConf(Configuration conf)
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public java.util.Map<java.lang.String,java.lang.String> getReadFailures()
public java.util.Map<java.lang.String,java.lang.String> getWriteFailures()
public Canary.Monitor newMonitor(Connection connection, int index, java.lang.String[] args)
Canary.Monitor
.
Can be overridden by user.index
- a start index for monitor targetargs
- args passed from userpublic static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception