Package org.infinispan.xsite.metrics

Class DefaultXSiteMetricsCollector

java.lang.Object

org.infinispan.xsite.metrics.DefaultXSiteMetricsCollector

All Implemented Interfaces:

XSiteMetricsCollector

public class DefaultXSiteMetricsCollector
extends Object
implements XSiteMetricsCollector

Implementation of XSiteMetricsCollector to use when asynchronous backups (cross-site replication) are configured.

Since:

13.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
DefaultXSiteMetricsCollector(Configuration configuration)

Method Summary

Modifier and Type	Method	Description
long	countRequestsReceived()
long	countRequestsReceived(String srcSite)
long	countRequestsSent()
long	countRequestsSent(String dstSite)
long	getAvgRequestSentDuration(long defaultValue, TimeUnit outTimeUnit)
long	getAvgRequestSentDuration(String dstSite, long defaultValue, TimeUnit outTimeUnit)
long	getMaxRequestSentDuration(long defaultValue, TimeUnit outTimeUnit)
long	getMaxRequestSentDuration(String dstSite, long defaultValue, TimeUnit outTimeUnit)
long	getMinRequestSentDuration(long defaultValue, TimeUnit outTimeUnit)
long	getMinRequestSentDuration(String dstSite, long defaultValue, TimeUnit outTimeUnit)
void	recordRequestSent(String dstSite, long duration, TimeUnit timeUnit)
void	recordRequestsReceived(String srcSite)
void	registerTimer(String dstSite, TimerTracker timer)
void	registerTimer(TimerTracker timer)
void	resetRequestReceived()
void	resetRequestsSent()
Collection<String>	sites()

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultXSiteMetricsCollector

public DefaultXSiteMetricsCollector(Configuration configuration)

Method Details

sites

public Collection<String> sites()

Specified by:

sites in interface XSiteMetricsCollector

recordRequestSent

public void recordRequestSent(String dstSite,
 long duration,
 TimeUnit timeUnit)

Specified by:

recordRequestSent in interface XSiteMetricsCollector

getMinRequestSentDuration

public long getMinRequestSentDuration(String dstSite,
 long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getMinRequestSentDuration in interface XSiteMetricsCollector

getMinRequestSentDuration

public long getMinRequestSentDuration(long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getMinRequestSentDuration in interface XSiteMetricsCollector

getMaxRequestSentDuration

public long getMaxRequestSentDuration(String dstSite,
 long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getMaxRequestSentDuration in interface XSiteMetricsCollector

getMaxRequestSentDuration

public long getMaxRequestSentDuration(long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getMaxRequestSentDuration in interface XSiteMetricsCollector

getAvgRequestSentDuration

public long getAvgRequestSentDuration(String dstSite,
 long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getAvgRequestSentDuration in interface XSiteMetricsCollector

getAvgRequestSentDuration

public long getAvgRequestSentDuration(long defaultValue,
 TimeUnit outTimeUnit)

Specified by:

getAvgRequestSentDuration in interface XSiteMetricsCollector

countRequestsSent

public long countRequestsSent(String dstSite)

Specified by:

countRequestsSent in interface XSiteMetricsCollector

countRequestsSent

public long countRequestsSent()

Specified by:

countRequestsSent in interface XSiteMetricsCollector

resetRequestsSent

public void resetRequestsSent()

Specified by:

resetRequestsSent in interface XSiteMetricsCollector

registerTimer

public void registerTimer(String dstSite,
 TimerTracker timer)

Specified by:

registerTimer in interface XSiteMetricsCollector

registerTimer

public void registerTimer(TimerTracker timer)

Specified by:

registerTimer in interface XSiteMetricsCollector

recordRequestsReceived

public void recordRequestsReceived(String srcSite)

Specified by:

recordRequestsReceived in interface XSiteMetricsCollector

countRequestsReceived

public long countRequestsReceived(String srcSite)

Specified by:

countRequestsReceived in interface XSiteMetricsCollector

countRequestsReceived

public long countRequestsReceived()

Specified by:

countRequestsReceived in interface XSiteMetricsCollector

resetRequestReceived

public void resetRequestReceived()

Specified by:

resetRequestReceived in interface XSiteMetricsCollector