![]() |
Fledge
An open source edge computing platform for industrial users
|
The base pipeline element class. More...
#include <pipeline_element.h>
Public Member Functions | |
void | setNext (PipelineElement *next) |
PipelineElement * | getNext () |
void | setService (const std::string &serviceName) |
void | setStorage (StorageClient *storage) |
virtual bool | setupConfiguration (ManagementClient *, std::vector< std::string > &) |
virtual bool | isFilter () |
virtual bool | isBranch () |
virtual void | ingest (READINGSET *readingSet)=0 |
virtual bool | setup (ManagementClient *mgmt, void *ingest, std::map< std::string, PipelineElement *> &categories)=0 |
virtual bool | init (OUTPUT_HANDLE *outHandle, OUTPUT_STREAM output)=0 |
virtual void | shutdown (ServiceHandler *serviceHandler, ConfigHandler *configHandler)=0 |
virtual void | reconfigure (const std::string &) |
virtual std::string | getName ()=0 |
virtual bool | isReady ()=0 |
Static Public Member Functions | |
static void | ingest (void *handle, READINGSET *readings) |
Protected Attributes | |
std::string | m_serviceName |
PipelineElement * | m_next |
StorageClient * | m_storage |
The base pipeline element class.