public class MetricCollectorSupport extends MetricCollector
RequestMetricCollector
MetricCollector.Factory
Modifier and Type | Field and Description |
---|---|
private CloudWatchMetricConfig |
config |
protected static org.apache.commons.logging.Log |
log |
private java.util.concurrent.BlockingQueue<MetricDatum> |
queue |
private RequestMetricCollectorSupport |
requestMetricCollector |
private ServiceMetricCollectorSupport |
serviceMetricCollector |
private static MetricCollectorSupport |
singleton |
private MetricUploaderThread |
uploaderThread |
NONE
Modifier | Constructor and Description |
---|---|
protected |
MetricCollectorSupport(CloudWatchMetricConfig config) |
Modifier and Type | Method and Description |
---|---|
private static boolean |
createAndStartCollector(CloudWatchMetricConfig config)
Returns true if the collector is successfully created and started;
false otherwise.
|
AmazonCloudWatchClient |
getCloudwatchClient() |
CloudWatchMetricConfig |
getConfig()
Returns the configuration.
|
(package private) static MetricCollectorSupport |
getInstance()
Returns the singleton instance; or null if there isn't one.
|
RequestMetricCollector |
getRequestMetricCollector() |
ServiceMetricCollector |
getServiceMetricCollector() |
boolean |
isEnabled()
Always returns true.
|
(package private) static boolean |
restartSingleton(CloudWatchMetricConfig config)
Retarts with a new CloudWatch collector.
|
boolean |
start()
Starts the request metric collector.
|
(package private) static boolean |
startSingleton(CloudWatchMetricConfig config)
Starts a new CloudWatch collector if it's not already started.
|
boolean |
stop()
Stops this collector immediately, dropping all pending metrics in memory.
|
protected static final org.apache.commons.logging.Log log
private static volatile MetricCollectorSupport singleton
private final RequestMetricCollectorSupport requestMetricCollector
private final ServiceMetricCollectorSupport serviceMetricCollector
private final java.util.concurrent.BlockingQueue<MetricDatum> queue
private final CloudWatchMetricConfig config
private MetricUploaderThread uploaderThread
protected MetricCollectorSupport(CloudWatchMetricConfig config)
static MetricCollectorSupport getInstance()
static boolean startSingleton(CloudWatchMetricConfig config)
static boolean restartSingleton(CloudWatchMetricConfig config)
private static boolean createAndStartCollector(CloudWatchMetricConfig config)
public boolean start()
MetricCollector
start
in class MetricCollector
public boolean stop()
stop
in class MetricCollector
public CloudWatchMetricConfig getConfig()
public AmazonCloudWatchClient getCloudwatchClient()
public final boolean isEnabled()
isEnabled
in class MetricCollector
public RequestMetricCollector getRequestMetricCollector()
getRequestMetricCollector
in class MetricCollector
public ServiceMetricCollector getServiceMetricCollector()
getServiceMetricCollector
in class MetricCollector