![]() |
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 |