Package org.torproject.metrics.collector.bridgedb

Class BridgedbMetricsProcessor

java.lang.Object

org.torproject.metrics.collector.sync.SyncManager

org.torproject.metrics.collector.cron.CollecTorMain

org.torproject.metrics.collector.bridgedb.BridgedbMetricsProcessor

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Callable<java.lang.Object>

public class BridgedbMetricsProcessor
extends CollecTorMain

Field Summary

Fields inherited from class org.torproject.metrics.collector.cron.CollecTorMain

config, mapPathDescriptors, SOURCES

Fields inherited from class org.torproject.metrics.collector.sync.SyncManager

SYNCORIGINS

Constructor Summary

Constructors

Constructor	Description
BridgedbMetricsProcessor(Configuration config)	Initialize this class with the given configuration.

Method Summary

Modifier and Type	Method	Description
void	cleanUpRsyncDirectory()	Delete all files from the rsync directory that have not been modified in the last three days.
java.lang.String	module()	Return the module identifier.
protected void	startProcessing()	Start processing files, which includes reading BridgeDB statistics files from disk, possibly decompressing them and splitting them by date, and writing them back to disk.
protected java.lang.String	syncMarker()	Return the synchronization marker.

Methods inherited from class org.torproject.metrics.collector.cron.CollecTorMain

call, checkAvailableSpace, readProcessedFiles, run, syncMapPathsDescriptors, writeProcessedFiles

Methods inherited from class org.torproject.metrics.collector.sync.SyncManager

merge

Methods inherited from class java.lang.Object

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

Constructor Details

BridgedbMetricsProcessor

public BridgedbMetricsProcessor(Configuration config)

Initialize this class with the given configuration.

Method Details

module

public java.lang.String module()

Return the module identifier.

Specified by:

module in class CollecTorMain

Returns:

Module identifier.

syncMarker

protected java.lang.String syncMarker()

Return the synchronization marker.

Specified by:

syncMarker in class CollecTorMain

Returns:

Synchronization marker.

startProcessing

protected void startProcessing() throws ConfigurationException

Start processing files, which includes reading BridgeDB statistics files from disk, possibly decompressing them and splitting them by date, and writing them back to disk.

Specified by:

startProcessing in class CollecTorMain

Throws:

ConfigurationException - Thrown if configuration values cannot be obtained.

cleanUpRsyncDirectory

public void cleanUpRsyncDirectory()

Delete all files from the rsync directory that have not been modified in the last three days.