![]() |
Fledge
An open source edge computing platform for industrial users
|
A pipeline element that writes to a storage service or buffer. More...
#include <pipeline_element.h>
Public Member Functions | |
void | ingest (READINGSET *readingSet) |
Ingest into a pipeline writer. | |
bool | setup (ManagementClient *mgmt, void *ingest, std::map< std::string, PipelineElement *> &categories) |
Setup the pipeline writer. | |
bool | init (OUTPUT_HANDLE *outHandle, OUTPUT_STREAM output) |
Initialise the pipeline writer. | |
void | shutdown (ServiceHandler *serviceHandler, ConfigHandler *configHandler) |
Shutdown the pipeline writer. | |
bool | isReady () |
Return if the pipeline writer is ready to receive data. | |
![]() | |
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 | reconfigure (const std::string &) |
virtual std::string | getName ()=0 |
Additional Inherited Members | |
![]() | |
static void | ingest (void *handle, READINGSET *readings) |
![]() | |
std::string | m_serviceName |
PipelineElement * | m_next |
StorageClient * | m_storage |
A pipeline element that writes to a storage service or buffer.