Fledge
An open source edge computing platform for industrial users
Ingest Member List

This is the complete list of members for Ingest, including all inherited members.

configChange(const std::string &, const std::string &)Ingestvirtual
configChildCreate(const std::string &, const std::string &, const std::string &) (defined in Ingest)Ingestinlinevirtual
configChildDelete(const std::string &, const std::string &) (defined in Ingest)Ingestinlinevirtual
configureRateMonitor(long interval, long factor)Ingest
createStatsDbEntry(const std::string &assetName)Ingest
flowControl()Ingest
getStringFromSet(const std::set< std::string > &dpSet) (defined in Ingest)Ingest
Ingest(StorageClient &storage, const std::string &serviceName, const std::string &pluginName, ManagementClient *mgmtClient)Ingest
ingest(const Reading &reading)Ingest
ingest(const std::vector< Reading *> *vec)Ingest
isRunning() (defined in Ingest)Ingestinlinevirtual
isStopping()Ingest
loadFilters(const std::string &categoryName)Ingest
passToOnwardFilter(OUTPUT_HANDLE *outHandle, READINGSET *readings)Ingeststatic
processQueue()Ingest
queueLength()Ingest
restart() (defined in Ingest)Ingestinlinevirtual
running()Ingest
securityChange(const std::string &payload) (defined in ServiceHandler)ServiceHandlerinlinevirtual
setFlowControl(unsigned int lowWater, unsigned int highWater) (defined in Ingest)Ingestinline
setPerfMon(PerformanceMonitor *mon) (defined in Ingest)Ingestinline
setStatistics(const std::string &option)Ingest
setThreshold(const unsigned int threshold) (defined in Ingest)Ingestinline
setTimeout(const long timeout) (defined in Ingest)Ingestinline
shutdown() (defined in Ingest)Ingestinlinevirtual
start(long timeout, unsigned int threshold)Ingest
unDeprecateAssetTrackingRecord(AssetTrackingTuple *currentTuple, const std::string &assetName, const std::string &event)Ingest
unDeprecateStorageAssetTrackingRecord(StorageAssetTrackingTuple *currentTuple, const std::string &assetName, const std::string &, const unsigned int &)Ingest
updateStats(void)Ingest
useFilteredData(OUTPUT_HANDLE *outHandle, READINGSET *readings)Ingeststatic
waitForQueue()Ingest
~Ingest()Ingest