Fledge
An open source edge computing platform for industrial users
PipelineElement Class Referenceabstract

The base pipeline element class. More...

#include <pipeline_element.h>

Inheritance diagram for PipelineElement:
Collaboration diagram for PipelineElement:

Public Member Functions

void setNext (PipelineElement *next)
 
PipelineElementgetNext ()
 
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
 
PipelineElementm_next
 
StorageClientm_storage
 
PipelineDebuggerm_debugger
 

Detailed Description

The base pipeline element class.

Member Function Documentation

◆ attachDebugger()

bool PipelineElement::attachDebugger ( )

Attach a debugger class to the pipeline.

Returns
bool True if a debugger is attached to the element

◆ getDebuggerBuffer()

vector< shared_ptr< Reading > > PipelineElement::getDebuggerBuffer ( )

Fetch the content of the debugger buffer.

Returns
vector<shared_ptr<ReadingSet>> The current contents of the debugger buffer

◆ setDebuggerBuffer()

void PipelineElement::setDebuggerBuffer ( unsigned int  size)

Setup the size of the debug buffer.

Parameters
sizeNumber of readings to buffer

The documentation for this class was generated from the following files: