co.cask.cdap.test

Class MetricsManager

java.lang.Object

co.cask.cdap.test.MetricsManager

public class MetricsManager
extends Object

Used by tests for querying metrics system.

Constructor Summary

Constructors

Constructor and Description
MetricsManager(MetricStore metricStore)

Method Summary

Methods

Modifier and Type	Method and Description
RuntimeMetrics	getFlowletMetrics(String namespace, String appName, String flowName, String flowletName) returns flowlet related metrics
RuntimeMetrics	getServiceHandlerMetrics(String namespace, String applicationId, String serviceId, String handlerId) returns service handler related metrics
RuntimeMetrics	getServiceMetrics(String namespace, String applicationId, String serviceId) returns service related metrics
long	getTotalMetric(Map<String,String> tags, String metricName) get metrics total count value for a given context and metric.
Collection<MetricTimeSeries>	query(MetricDataQuery query) query the metric store and return the Collection
void	resetAll() deletes all metrics
void	waitForTotalMetricCount(Map<String,String> tags, String metricName, long count, long timeout, TimeUnit timeoutUnit) waitFor a metric value count for the metric identified by metricName and context.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricsManager

public MetricsManager(MetricStore metricStore)

Method Detail

query

public Collection<MetricTimeSeries> query(MetricDataQuery query)
                                   throws Exception

query the metric store and return the Collection

Parameters:

query -

Returns:

Collection

Throws:

Exception

getFlowletMetrics

public RuntimeMetrics getFlowletMetrics(String namespace,
                               String appName,
                               String flowName,
                               String flowletName)

returns flowlet related metrics

Parameters:

namespace -

appName -

flowName -

flowletName -

Returns:

RuntimeMetrics

getServiceMetrics

public RuntimeMetrics getServiceMetrics(String namespace,
                               String applicationId,
                               String serviceId)

returns service related metrics

Parameters:

namespace -

applicationId -

serviceId -

Returns:

RuntimeMetrics

getServiceHandlerMetrics

public RuntimeMetrics getServiceHandlerMetrics(String namespace,
                                      String applicationId,
                                      String serviceId,
                                      String handlerId)

returns service handler related metrics

Parameters:

namespace -

applicationId -

serviceId -

handlerId -

Returns:

getTotalMetric

public long getTotalMetric(Map<String,String> tags,
                  String metricName)

get metrics total count value for a given context and metric.

Parameters:

tags - - tags that identify a context

metricName -

Returns:

waitForTotalMetricCount

public void waitForTotalMetricCount(Map<String,String> tags,
                           String metricName,
                           long count,
                           long timeout,
                           TimeUnit timeoutUnit)
                             throws TimeoutException,
                                    InterruptedException

waitFor a metric value count for the metric identified by metricName and context.

Parameters:

tags - - context identified by tags map

metricName -

count - - expected metric total count value

timeout -

timeoutUnit -

Throws:

TimeoutException

InterruptedException

resetAll

public void resetAll()
              throws Exception

deletes all metrics

Throws:

Exception