private static class Canary.RegionServerMonitor extends Canary.Monitor
Modifier and Type | Field and Description |
---|---|
private boolean |
allRegions |
admin, allowedFailures, connection, done, errorCode, executor, initialized, sink, targets, treatFailureAsError, useRegExp
Constructor and Description |
---|
RegionServerMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
Canary.Sink sink,
ExecutorService executor,
boolean allRegions,
boolean treatFailureAsError,
long allowedFailures) |
Modifier and Type | Method and Description |
---|---|
private boolean |
checkNoTableNames() |
private Map<String,List<RegionInfo>> |
doFilterRegionServerByName(Map<String,List<RegionInfo>> fullRsAndRMap) |
private Map<String,List<RegionInfo>> |
filterRegionServerByName() |
private Map<String,List<RegionInfo>> |
getAllRegionServerByName() |
private Canary.RegionServerStdOutSink |
getSink() |
private void |
monitorRegionServers(Map<String,List<RegionInfo>> rsAndRMap,
Canary.RegionServerStdOutSink regionServerSink) |
void |
run() |
close, finalCheckForErrors, hasError, initAdmin, isDone
private boolean allRegions
public RegionServerMonitor(Connection connection, String[] monitorTargets, boolean useRegExp, Canary.Sink sink, ExecutorService executor, boolean allRegions, boolean treatFailureAsError, long allowedFailures)
private Canary.RegionServerStdOutSink getSink()
public void run()
run
in interface Runnable
run
in class Canary.Monitor
private boolean checkNoTableNames()
private void monitorRegionServers(Map<String,List<RegionInfo>> rsAndRMap, Canary.RegionServerStdOutSink regionServerSink)
private Map<String,List<RegionInfo>> filterRegionServerByName()
private Map<String,List<RegionInfo>> getAllRegionServerByName()
private Map<String,List<RegionInfo>> doFilterRegionServerByName(Map<String,List<RegionInfo>> fullRsAndRMap)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.