org.apache.dubbo.metrics.collector

Class DefaultMetricsCollector

java.lang.Object

org.apache.dubbo.metrics.listener.AbstractMetricsListener<E>

org.apache.dubbo.metrics.collector.CombMetricsCollector<RequestEvent>

org.apache.dubbo.metrics.collector.DefaultMetricsCollector

All Implemented Interfaces:

ApplicationMetricsCollector<RequestEvent>, MethodMetricsCollector<RequestEvent>, MetricsCollector<RequestEvent>, ServiceMetricsCollector<RequestEvent>, MetricsLifeListener<RequestEvent>, MetricsListener<RequestEvent>

@Activate
public class DefaultMetricsCollector
extends CombMetricsCollector<RequestEvent>

Default implementation of MetricsCollector

Field Summary

Fields

Modifier and Type	Field and Description
SimpleMetricsCountSampler<String,MetricsEvent.Type,ApplicationMetric>	applicationSampler

Constructor Summary

Constructors

Constructor and Description
DefaultMetricsCollector(org.apache.dubbo.rpc.model.ApplicationModel applicationModel)

Method Summary

Modifier and Type	Method and Description
void	addSampler(MetricsSampler sampler)
boolean	calSamplesChanged()
List<MetricSample>	collect()
void	collectApplication()
org.apache.dubbo.rpc.model.ApplicationModel	getApplicationModel()
String	getApplicationName()
void	initMetrics(MetricsEvent event)
boolean	isCollectEnabled()
boolean	isMetricsInitEnabled()
boolean	isSupport(MetricsEvent event)
boolean	isThreadpoolCollectEnabled()
void	onEvent(TimeCounterEvent event)
void	registryDefaultSample()
void	setApplicationName(String applicationName)
void	setCollectEnabled(Boolean collectEnabled)
void	setMetricsInitEnabled(boolean metricsInitEnabled)
void	setThreadpoolCollectEnabled(boolean threadpoolCollectEnabled)

Methods inherited from class org.apache.dubbo.metrics.collector.CombMetricsCollector

addApplicationRt, addMethodRt, addServiceRt, addServiceRt, getEventMulticaster, increment, increment, increment, init, onEventError, onEventFinish, setNum

Methods inherited from class java.lang.Object

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

Field Detail

applicationSampler

public SimpleMetricsCountSampler<String,MetricsEvent.Type,ApplicationMetric> applicationSampler

Constructor Detail

DefaultMetricsCollector

public DefaultMetricsCollector(org.apache.dubbo.rpc.model.ApplicationModel applicationModel)

Method Detail

addSampler

public void addSampler(MetricsSampler sampler)

setApplicationName

public void setApplicationName(String applicationName)

getApplicationName

public String getApplicationName()

getApplicationModel

public org.apache.dubbo.rpc.model.ApplicationModel getApplicationModel()

setCollectEnabled

public void setCollectEnabled(Boolean collectEnabled)

isCollectEnabled

public boolean isCollectEnabled()

isThreadpoolCollectEnabled

public boolean isThreadpoolCollectEnabled()

setThreadpoolCollectEnabled

public void setThreadpoolCollectEnabled(boolean threadpoolCollectEnabled)

isMetricsInitEnabled

public boolean isMetricsInitEnabled()

setMetricsInitEnabled

public void setMetricsInitEnabled(boolean metricsInitEnabled)

collectApplication

public void collectApplication()

registryDefaultSample

public void registryDefaultSample()

collect

public List<MetricSample> collect()

isSupport

public boolean isSupport(MetricsEvent event)

Specified by:

isSupport in interface MetricsListener<RequestEvent>

Overrides:

isSupport in class AbstractMetricsListener<RequestEvent>

onEvent

public void onEvent(TimeCounterEvent event)

Overrides:

onEvent in class CombMetricsCollector<RequestEvent>

initMetrics

public void initMetrics(MetricsEvent event)

calSamplesChanged

public boolean calSamplesChanged()