Package com.norconex.crawler.core.metrics

Class CrawlerMetricsImpl

java.lang.Object

com.norconex.crawler.core.metrics.CrawlerMetricsImpl

All Implemented Interfaces:

CrawlerMetrics, CrawlerMetricsMXBean, Closeable, AutoCloseable

public class CrawlerMetricsImpl
extends Object
implements CrawlerMetrics

Constructor Summary

Constructors

Constructor	Description
CrawlerMetricsImpl()

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()	Flushes the metrics.
long	getBaselineCount()
Map<String,Long>	getEventCounts()
long	getProcessedCount()
long	getProcessingCount()
long	getQueuedCount()
void	incrementCounter(String eventName, long incrementBy)
void	init(CrawlerSession crawlSession)
boolean	isClosed()

Methods inherited from class java.lang.Object

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

Constructor Details

CrawlerMetricsImpl

public CrawlerMetricsImpl()

Method Details

init

public void init(CrawlerSession crawlSession)

Specified by:

init in interface CrawlerMetrics

incrementCounter

public void incrementCounter(String eventName,
 long incrementBy)

getEventCounts

public Map<String,Long> getEventCounts()

Specified by:

getEventCounts in interface CrawlerMetricsMXBean

getProcessingCount

public long getProcessingCount()

Specified by:

getProcessingCount in interface CrawlerMetricsMXBean

getProcessedCount

public long getProcessedCount()

Specified by:

getProcessedCount in interface CrawlerMetricsMXBean

getQueuedCount

public long getQueuedCount()

Specified by:

getQueuedCount in interface CrawlerMetricsMXBean

getBaselineCount

public long getBaselineCount()

Specified by:

getBaselineCount in interface CrawlerMetricsMXBean

isClosed

public boolean isClosed()

flush

public void flush()

Description copied from interface: CrawlerMetrics

Flushes the metrics. Implementation specific, but normally forces a commit of any buffered event to storage and/or the synchronization of metrics across nodes.

Specified by:

flush in interface CrawlerMetrics

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface CrawlerMetrics