Package com.facebook.openwifi.rrm.modules

Class DataCollector

java.lang.Object

com.facebook.openwifi.rrm.modules.DataCollector

All Implemented Interfaces:

Runnable

public class DataCollector
extends Object
implements Runnable

Data collector module.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DataCollector.DataListener	Data listener interface.

Constructor Summary

Constructors

Constructor	Description
DataCollector(RRMConfig.ModuleConfig.DataCollectorParams params, DeviceDataManager deviceDataManager, UCentralClient client, UCentralKafkaConsumer consumer, ConfigManager configManager, DatabaseManager dbManager)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addDataListener(String id, DataCollector.DataListener listener)	Add/overwrite a data listener with an arbitrary identifier.
protected static void	parseStateRecord(String serialNumber, com.google.gson.JsonObject payload, List<StateRecord> results)	Parse a single state record into individual metrics.
boolean	removeDataListener(String id)	Remove a data listener with the given identifier, returning true if anything was actually removed.
void	run()
void	shutdown()	Shut down all resources.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataCollector

public DataCollector(RRMConfig.ModuleConfig.DataCollectorParams params,
                     DeviceDataManager deviceDataManager,
                     UCentralClient client,
                     UCentralKafkaConsumer consumer,
                     ConfigManager configManager,
                     DatabaseManager dbManager)

Constructor.

Method Detail

shutdown

public void shutdown()

Shut down all resources.

run

public void run()

Specified by:

run in interface Runnable

parseStateRecord

protected static void parseStateRecord(String serialNumber,
                                       com.google.gson.JsonObject payload,
                                       List<StateRecord> results)

Parse a single state record into individual metrics.

addDataListener

public void addDataListener(String id,
                            DataCollector.DataListener listener)

Add/overwrite a data listener with an arbitrary identifier. The "id" string determines the order in which listeners are called.

removeDataListener

public boolean removeDataListener(String id)

Remove a data listener with the given identifier, returning true if anything was actually removed.