Package org.opencastproject.statistics.provider.influx

Class StatisticsProviderInfluxService

java.lang.Object

org.opencastproject.statistics.provider.influx.StatisticsProviderInfluxService

All Implemented Interfaces:

org.apache.felix.fileinstall.ArtifactInstaller, org.apache.felix.fileinstall.ArtifactListener, StatisticsWriter, org.osgi.service.cm.ManagedService

public class StatisticsProviderInfluxService
extends Object
implements org.osgi.service.cm.ManagedService, org.apache.felix.fileinstall.ArtifactInstaller, StatisticsWriter

Implements statistics providers using influxdb for permanent storage.

Constructor Summary

Constructors

Constructor	Description
StatisticsProviderInfluxService()

Method Summary

Modifier and Type	Method	Description
void	activate(org.osgi.service.component.ComponentContext cc)
boolean	canHandle(File file)
void	deactivate(org.osgi.service.component.ComponentContext cc)
String	getId()	Lorem ipsum dolor sit amet
org.influxdb.InfluxDB	getInfluxDB()
void	install(File file)
void	setStatisticsCoordinator(StatisticsCoordinator service)
void	uninstall(File file)
void	update(File file)
void	updated(Dictionary<String,?> dictionary)
void	writeDuration(String organizationId, String measurementName, String retentionPolicy, String organizationIdResourceName, String fieldName, TimeUnit temporalResolution, Duration duration)	Write a duration to a statistics data base

Methods inherited from class java.lang.Object

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

Constructor Details

StatisticsProviderInfluxService

public StatisticsProviderInfluxService()

Method Details

setStatisticsCoordinator

public void setStatisticsCoordinator(StatisticsCoordinator service)

activate

public void activate(org.osgi.service.component.ComponentContext cc)

deactivate

public void deactivate(org.osgi.service.component.ComponentContext cc)

install

public void install(File file)
             throws Exception

Specified by:

install in interface org.apache.felix.fileinstall.ArtifactInstaller

Throws:

Exception

uninstall

public void uninstall(File file)

Specified by:

uninstall in interface org.apache.felix.fileinstall.ArtifactInstaller

canHandle

public boolean canHandle(File file)

Specified by:

canHandle in interface org.apache.felix.fileinstall.ArtifactListener

update

public void update(File file)
            throws Exception

Specified by:

update in interface org.apache.felix.fileinstall.ArtifactInstaller

Throws:

Exception

updated

public void updated(Dictionary<String,?> dictionary)

Specified by:

updated in interface org.osgi.service.cm.ManagedService

getInfluxDB

public org.influxdb.InfluxDB getInfluxDB()

writeDuration

public void writeDuration(String organizationId,
 String measurementName,
 String retentionPolicy,
 String organizationIdResourceName,
 String fieldName,
 TimeUnit temporalResolution,
 Duration duration)

Description copied from interface: StatisticsWriter

Write a duration to a statistics data base

Specified by:

writeDuration in interface StatisticsWriter

Parameters:

organizationId - Organization ID of the data point

measurementName - Measurement name of the data point

retentionPolicy - Retention policy of the data point

organizationIdResourceName - Resource name for the organization

fieldName - Field name to write

temporalResolution - The temporal resolution to store it in

duration - The actual duration to write

getId

public String getId()

Description copied from interface: StatisticsWriter

Lorem ipsum dolor sit amet

Specified by:

getId in interface StatisticsWriter

Returns:

the writer's ID