![]() |
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) |
| bool | attachDebugger () |
| Attach a debugger class to the pipeline. More... | |
| void | detachDebugger () |
| Detach a pipeline debugger from the pipeline element. | |
| void | setDebuggerBuffer (unsigned int size) |
| Setup the size of the debug buffer. More... | |
| std::vector< std::shared_ptr< Reading > > | getDebuggerBuffer () |
| Fetch the content of the debugger buffer. More... | |
| 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 |
| PipelineDebugger * | m_debugger |
The base pipeline element class.
| bool PipelineElement::attachDebugger | ( | ) |
Attach a debugger class to the pipeline.
| vector< shared_ptr< Reading > > PipelineElement::getDebuggerBuffer | ( | ) |
Fetch the content of the debugger buffer.
| void PipelineElement::setDebuggerBuffer | ( | unsigned int | size | ) |
Setup the size of the debug buffer.
| size | Number of readings to buffer |