![]() |
Fledge
An open source edge computing platform for industrial users
|
A pipeline element that represents a branch in the pipeline. More...
#include <pipeline_element.h>
Public Member Functions | |
PipelineBranch (FilterPipeline *parent) | |
Constructor for a branch in a filter pipeline. | |
~PipelineBranch () | |
Destructor for the pipeline branch. More... | |
void | ingest (READINGSET *readingSet) |
Ingest a set of readings and pass on in the pipeline. More... | |
std::string | getName () |
bool | setupConfiguration (ManagementClient *mgtClient, std::vector< std::string > &children) |
Setup the configuration for a branch in a pipeline. More... | |
bool | setup (ManagementClient *mgmt, void *ingest, std::map< std::string, PipelineElement *> &categories) |
Setup the configuration categories for the branch element of a pipeline. More... | |
bool | init (OUTPUT_HANDLE *outHandle, OUTPUT_STREAM output) |
Initialise the pipeline branch. More... | |
void | shutdown (ServiceHandler *serviceHandler, ConfigHandler *configHandler) |
Setup the configuration categories for the branch element of a pipeline. More... | |
bool | isReady () |
Return if the branch is ready to be executed. | |
bool | isBranch () |
std::vector< PipelineElement * > & | getBranchElements () |
void | setFunctions (void *onward, void *use, void *ingest) |
![]() | |
void | setNext (PipelineElement *next) |
PipelineElement * | getNext () |
void | setService (const std::string &serviceName) |
void | setStorage (StorageClient *storage) |
virtual bool | isFilter () |
virtual void | reconfigure (const std::string &) |
Additional Inherited Members | |
![]() | |
static void | ingest (void *handle, READINGSET *readings) |
![]() | |
std::string | m_serviceName |
PipelineElement * | m_next |
StorageClient * | m_storage |
A pipeline element that represents a branch in the pipeline.
PipelineBranch::~PipelineBranch | ( | ) |
Destructor for the pipeline branch.
If the pipeline is not already shutdown then shut it down Delete the thread if it exists.
|
virtual |
Ingest a set of readings and pass on in the pipeline.
Create a deep copy and queue the copy into the branched pipeline.
readingSet | The set of readings to ingest |
Implements PipelineElement.
|
virtual |
Initialise the pipeline branch.
Initialise the elements of the child pipeline Spawn a thread to excute the child pipeline.
config | The filter configuration |
outHandle | The pipeline element on the "main branch" |
output |
Implements PipelineElement.
|
virtual |
Setup the configuration categories for the branch element of a pipeline.
The branch itself has no category, but it must call the setup method on all items in the child branch of the piepline.
mgmt | The management client |
ingest | The configuration handler for our service |
filterCategories | A map of the category names to pipeline elements |
Implements PipelineElement.
|
virtual |
Setup the configuration for a branch in a pipeline.
mgtClient | The management client |
children | A vector to fill with child configuration categories |
Reimplemented from PipelineElement.
|
virtual |
Setup the configuration categories for the branch element of a pipeline.
The branch itself has no category, but it must call the setup method on all items in the child branch of the piepline.
mgmt | The management client |
ingest | The configuration handler for our service |
filterCategories | A map of the category names to pipeline elements |
Implements PipelineElement.