Fledge
An open source edge computing platform for industrial users
PipelineWriter Class Reference

A pipeline element that writes to a storage service or buffer. More...

#include <pipeline_element.h>

Inheritance diagram for PipelineWriter:
Collaboration diagram for PipelineWriter:

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.
 
- Public Member Functions inherited from PipelineElement
void setNext (PipelineElement *next)
 
PipelineElementgetNext ()
 
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 Public Member Functions inherited from PipelineElement
static void ingest (void *handle, READINGSET *readings)
 
- Protected Attributes inherited from PipelineElement
std::string m_serviceName
 
PipelineElementm_next
 
StorageClientm_storage
 

Detailed Description

A pipeline element that writes to a storage service or buffer.


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